krishanps [http://community.jboss.org/people/krishanps] created the discussion "Re: Message Event (throw and catch problem)" To view the discussion, visit: http://community.jboss.org/message/643406#643406 -------------------------------------------------------------- Thank you for your hint Maciej. You are right I didn't implemented my own MessageEventSendTaskHelper.java. Now I have more options to trigger the message catch event. The model above was a just simple example to check if message events work but it doesn't before. With the Eclipse Bpmn 2.0 - plugin I have modelled 2 pools which I want to connect with the help of message events. My intention: If the first process is at the end node it can throw a message event so the other can continue his steps after it catched the message event. -------------------------------------------------------------- Reply to this message by going to Community [http://community.jboss.org/message/643406#643406] Start a new discussion in jBPM at Community [http://community.jboss.org/choose-container!input.jspa?contentType=1&...]

krishanps [http://community.jboss.org/people/krishanps] created the discussion "Re: Message Event (throw and catch problem)" To view the discussion, visit: http://community.jboss.org/message/643600#643600 -------------------------------------------------------------- Yes, of course. So I just give a reference to ksession from the main-method to the implemented MessageEventSendTaskHandler.java. So I can use it to call a signalEvent to initiate the message catch event. My implementation changes: || **.java * || | public static final void main(String[] args) {         try {             // load up the knowledge base             KnowledgeBase kbase = readKnowledgeBase();             StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();             //creates an own SendTaskHandler to work on the same ksession to initiate a message event catch call MessageSendTaskHandler msgSendTaskHandler = new MessageEventSendTaskHandler();             msgSendTaskHandler.setStatefulKnowledgeSession(ksession);             KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newFileLogger(ksession, "test");             ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new DoNothingWorkItemHandler());             ksession.getWorkItemManager().registerWorkItemHandler("Send Task", msgSendTaskHandler);                                    Map<String, Object> params = new HashMap<String, Object>();             params.put("x", "MyValue");             params.put("y", "OtherValue");             // start a new process instance             ProcessInstance processInstance = ksession.startProcess("IntermediateCatchEvent", params);                                    logger.close();         } catch (Throwable t) {             t.printStackTrace();         }     }     private static KnowledgeBase readKnowledgeBase() throws Exception {         KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();         kbuilder.add(ResourceFactory.newClassPathResource("BPMN2-IntermediateCatchEventMessage.bpmn2"), ResourceType.BPMN2);         return kbuilder.newKnowledgeBase();     } } | The Implemented SendTaskHandler.java || *MessageEventSendTaskHandler.java* || | public class  MessageEventSendTaskHandler implements WorkItemHandler {     private StatefulKnowledgeSession ksession;     private long processInstanceID;     public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {         String message = (String) workItem.getParameter("Message");         System.out.println("Die gesendete Nachricht: " + message);                        //starts Message Catch Event         getStatefulKnowledgeSession().signalEvent("Message-_8_Message", "hi",   getStatefulKnowledgeSession().getProcessInstance(1).getId());         manager.completeWorkItem(workItem.getId(), null);     }     public void setStatefulKnowledgeSession(StatefulKnowledgeSession ksession){         this.ksession = ksession;     }     public StatefulKnowledgeSession getStatefulKnowledgeSession(){         return this.ksession;     } } | If you have questions feel free to post your questions :-) -------------------------------------------------------------- Reply to this message by going to Community [http://community.jboss.org/message/643600#643600] Start a new discussion in jBPM at Community [http://community.jboss.org/choose-container!input.jspa?contentType=1&...]