raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Merge pull request #20851 from ianclegg/19615-upgrade-to-camel-2.17.1

Browse source 
Make it possible to use both Camel 2.13.4 and 2.17.1 #19615
This commit is contained in:
Patrik Nordwall 2016-08-19 11:16:02 +02:00 • committed by GitHub
commit 53d34f3b09
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-camel/src/test/scala/akka/camel/ConsumerIntegrationTest.scala
View file

@ -123,13 +123,13 @@ class ConsumerIntegrationTest extends WordSpec with Matchers with NonSharedCamel
}
"Error passing consumer supports redelivery through route modification" in {
val ref = start(new FailingOnceConsumer("direct:failing-once-concumer") {
val ref = start(new FailingOnceConsumer("direct:failing-once-consumer") {
override def onRouteDefinition = (rd: RouteDefinition) ⇒ {
rd.onException(classOf[TestException]).maximumRedeliveries(1).end
rd.onException(classOf[TestException]).redeliveryDelay(0L).maximumRedeliveries(1).end
}
}, name = "direct-failing-once-consumer")
filterEvents(EventFilter[TestException](occurrences = 1)) {
camel.sendTo("direct:failing-once-concumer", msg = "hello") should ===("accepted: hello")
camel.sendTo("direct:failing-once-consumer", msg = "hello") should ===("accepted: hello")
}
stop(ref)
}