224225226227228229230231232233234
Thread.sleep(250); ap.process(e2); Thread.sleep(500); ap.process(e3); Thread.sleep(5000); ap.process(e4); assertMockEndpointsSatisfied();
227228229230231232233234235236237
Thread.sleep(500); ap.process(e3); Thread.sleep(5000); ap.process(e4); assertMockEndpointsSatisfied(); ap.stop(); }
266267268269270271272273274275276
Exchange e4 = new DefaultExchange(context); e4.getIn().setBody("D"); e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); Thread.sleep(5000); ap.process(e4);
267268269270271272273274275276277
268269270271272273274275276277278
e4.getIn().setBody("D"); e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); Thread.sleep(5000); ap.process(e4); assertMockEndpointsSatisfied();
271272273274275276277278279280281
ap.process(e1); ap.process(e2); ap.process(e3); Thread.sleep(5000); ap.process(e4); assertMockEndpointsSatisfied(); ap.stop(); }
308309310311312313314315316317318
Exchange e4 = new DefaultExchange(context); e4.getIn().setBody("END"); e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertMockEndpointsSatisfied();
309310311312313314315316317318319
310311312313314315316317318319320
e4.getIn().setBody("END"); e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertMockEndpointsSatisfied(); ap.stop();
311312313314315316317318319320321
e4.getIn().setHeader("id", 123); ap.process(e1); ap.process(e2); ap.process(e3); ap.process(e4); assertMockEndpointsSatisfied(); ap.stop(); }