Hi
What version of Camel are you using?
On Mon, Dec 12, 2011 at 4:34 PM, suman <prashanth.shivaku...@gmail.com> wrote:
> 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.
--
Claus Ibsen
-----------------
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
