From 75355b4549a22262aeda4fe874b7630486d8afd8 Mon Sep 17 00:00:00 2001 From: Ian Clegg Date: Tue, 28 Jun 2016 19:36:48 +0100 Subject: [PATCH] 19615 set redelivery delay on camel unit test to speed it up and support future versions of camel --- .../src/test/scala/akka/camel/ConsumerIntegrationTest.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-camel/src/test/scala/akka/camel/ConsumerIntegrationTest.scala b/akka-camel/src/test/scala/akka/camel/ConsumerIntegrationTest.scala index b673fa9057..1c4f03a16a 100644 --- a/akka-camel/src/test/scala/akka/camel/ConsumerIntegrationTest.scala +++ b/akka-camel/src/test/scala/akka/camel/ConsumerIntegrationTest.scala @@ -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) }