1 package org.jbpm.bpel.service.exe; 2 3 import java.util.Collections ; 4 5 import org.jbpm.graph.exe.ProcessInstance; 6 7 import org.jbpm.bpel.def.BpelDefinition; 8 import org.jbpm.bpel.service.def.Receiver; 9 10 14 public class NonStartListenerTest extends RequestListenerTest { 15 16 protected RequestListener createListener(BpelDefinition process, Receiver receiver) { 17 ProcessInstance pi = process.createProcessInstance(); 19 token = pi.getRootToken(); 20 token.setNode(receiver.getInboundMessageActivity()); 21 CorrelationSetInstance csi = receiver.getCorrelations().getCorrelation("csId").getSet().getInstance(token); 23 csi.initialize(Collections.singletonMap(ID_PROP, ID_VALUE)); 24 return new NonStartListener(receiver, token); 26 } 27 } 28 | Popular Tags |