Hello Guys,
Iam trying to do integration testing using NotifyBuilder support of camel.
Very basic use as highlighted below
=================
NotifyBuilder notify = new
NotifyBuilder(this.camelContext).whenDone(1).create();
//send a message
boolean done = notify.matches(20, TimeUnit.SECONDS);
assertTrue(done);
//application specific assertions
=================
It was all good before i introduced /.endChoice()/(because of
recipientList).Now notifybuilder is broken and falsely reports that message
has been processed where as Exchange processing is not complete.Any ideas?
from("amqp:queue:ubenev").startupOrder(3)
.process(protoBufMessageProcessor).choice()
.when(header("messagetype").isEqualTo(ProtoMessageType.LIVE_EVENT_OPENED))
.setHeader(Exchange.HTTP_METHOD,
constant(org.apache.camel.component.http4.HttpMethods.GET))
.process(eventSubscribeProcessor)
.marshal(jacksonDataFormatProcessor.getJacksonDataFormat())
.recipientList(simple(liveEventUrlForOpenEvent,
String.class))
.setHeader(CacheConstants.CACHE_OPERATION,
constant(CacheConstants.CACHE_OPERATION_ADD))
.setHeader(CacheConstants.CACHE_KEY, header("eventid"))
.convertBodyTo(String.class, "UTF-8")
.to("cache://LiveOddsCache")
.to("log:LIVE_EVENT_OPENED").endChoice()
.otherwise()
.to("log:foo");
Thanks
--
View this message in context:
http://camel.465427.n5.nabble.com/NotifyBuilder-issue-while-integration-testing-tp5068648p5068648.html
Sent from the Camel - Users mailing list archive at Nabble.com.
