591592593594595596597598599600601
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();
592593594595596597598599600601602
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();
8182838485868788899091
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();
8283848586878889909192
8384858687888990919293
e4.getIn().setBody("D"); e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertMockEndpointsSatisfied(); ap.stop();
8485868788899091929394
e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertMockEndpointsSatisfied(); ap.stop(); }
122123124125126127128129130131132
123124125126127128129130131132133
124125126127128129130131132133134
125126127128129130131132133134135