541542543544545546547548549550551
Exchange e5 = new DefaultExchange(context); e5.getIn().setBody("END"); e5.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); ap.process(e5);
542543544545546547548549550551552
Exchange e5 = new DefaultExchange(context); e5.getIn().setBody("END"); e5.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); ap.process(e5); assertMockEndpointsSatisfied();
543544545546547548549550551552553
e5.getIn().setBody("END"); e5.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); ap.process(e5); assertMockEndpointsSatisfied();
544545546547548549550551552553554
e5.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); ap.process(e5); assertMockEndpointsSatisfied(); ap.stop();
545546547548549550551552553554555
ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); ap.process(e5); assertMockEndpointsSatisfied(); ap.stop(); }
584585586587588589590591592593594
Exchange e4 = new DefaultExchange(context); e4.getIn().setBody("END"); e4.getIn().setHeader("id", 456); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertEquals("should not have completed yet", 0, mock.getExchanges().size());
585586587588589590591592593594595
586587588589590591592593594595596
e4.getIn().setBody("END"); e4.getIn().setHeader("id", 456); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertEquals("should not have completed yet", 0, mock.getExchanges().size()); ap.forceCompletionOfAllGroups();
587588589590591592593594595596597
e4.getIn().setHeader("id", 456); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertEquals("should not have completed yet", 0, mock.getExchanges().size()); ap.forceCompletionOfAllGroups();
8081828384858687888990
Exchange e4 = new DefaultExchange(context); e4.getIn().setBody("D"); e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertMockEndpointsSatisfied();