1 package org.jbpm.bpel.service.exe; 2 3 import org.jbpm.bpel.def.BpelDefinition; 4 import org.jbpm.bpel.service.def.Receiver; 5 6 10 public class StartListenerTest extends RequestListenerTest { 11 12 private static final int RECEPTION_COUNT = 5; 13 14 protected RequestListener createListener(BpelDefinition process, Receiver receiver) { 15 return new StartListener(receiver); 16 } 17 18 public void testMultipleReception() throws Exception { 19 listener.receiveRequest(messagerSession); 20 for (int i = 0; i < RECEPTION_COUNT; i++) { 22 sendRequest(); 24 synchronized (listener) { 26 listener.wait(); 27 } 28 assertReception(); 30 } 31 } 32 } 33 | Popular Tags |