You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by si...@alice.it on 2008/04/27 08:44:00 UTC
Seda doesn't delivery
Hi guys,
I'm using ServiceMix 3.1.2 and Ode JBI 1.1 to deploy my master thesis.
My software creates starting from an XML description some BPEL process, exposing them outside using JMS, that orchestrate using a Java Mediator.
I can execute a pattern but a time it stops without any error and showing on the console the following message:
DEBUG - JmsComponent - Created correlation id: ID:127.0.1.1-1198e606fc3-11:4
DEBUG - DeliveryChannelImpl - Send ID:127.0.1.1-1198e606fc3-11:4 in DeliveryChannel{servicemix-jms}
DEBUG - SedaFlow - Called Flow send
DEBUG - SedaQueue - org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@16edf06 dequeued exchange: InOnly[
id: ID:127.0.1.1-1198e606fc3-11:4
status: Active
role: provider
service: {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckNGService
endpoint: replyCCheckNGPort
operation: {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckNG
in: <?xml version="1.0" encoding="UTF-8"?><replyCCheckNG xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><approved>true</approved></replyCCheckNG>
]
DEBUG - DeliveryChannelImpl - Accepting ID:127.0.1.1-1198e606fc3-11:4 in DeliveryChannel{OdeBpelEngine}
DEBUG - BpelEngineImpl - Routed: svcQname {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckNGService --> BpelProcess[{http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - MessageExchangeImpl - SET MEX property org.apache.ode.jbi.msgmap.Mapper = org.apache.ode.jbi.msgmap.ServiceMixMapper
DEBUG - BpelEngineImpl - Routed: svcQname {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckNGService --> BpelProcess[{http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - MyRoleMessageExchangeImpl - invoke() EPR= null ==> BpelProcess[{http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - SQL - <t 28811928, conn 32625434> executing prepstmnt 15955619 INSERT INTO ODE_MESSAGE_EXCHANGE (MESSAGE_EXCHANGE_ID, CALLEE, CHANNEL, CORRELATION_ID, CORRELATION_KEYS, CORRELATION_STATUS, CREATE_TIME, DIRECTION, EPR, FAULT, FAULT_EXPLANATION, OPERATION, PARTNER_LINK_MODEL_ID, PATTERN, PIPED_ID, PORT_TYPE, PROPAGATE_TRANS, STATUS, CORR_ID, PARTNER_LINK_ID, PROCESS_ID, PROCESS_INSTANCE_ID, REQUEST_MESSAGE_ID, RESPONSE_MESSAGE_ID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) [params=(String) hqejbhcnphr388ldra7ugb, (String) {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckN..., (null) null, (String) ID:127.0.1.1-1198e606fc3-11:4, (null) null, (String) UKNOWN_ENDPOINT, (null) null, (int) 77, (null) null, (null) null, (null) null, (String) replyCCheckNG, (int) 0, (String) UNKNOWN, (null) null, (null) null, (int) 0, (String) ASYNC, (null) null, (null) null, (null) null, (null) null, (long) 1049, (null) null]
DEBUG - SQL - <t 28811928, conn 32625434> [1 ms] spent
DEBUG - SQL - <t 28811928, conn 32625434> executing prepstmnt 32611383 INSERT INTO ODE_MEX_PROP (ID, PROP_KEY, PROP_VALUE, MEX_ID) VALUES (?, ?, ?, ?) [params=(long) 1048, (String) org.apache.ode.jbi.msgmap.Mapper, (String) org.apache.ode.jbi.msgmap.ServiceMixMapper, (String) hqejbhcnphr388ldra7ugb]
DEBUG - SQL - <t 28811928, conn 32625434> [0 ms] spent
DEBUG - SQL - <t 28811928, conn 32625434> executing prepstmnt 1309167 INSERT INTO ODE_MESSAGE (MESSAGE_ID, DATA, TYPE, MESSAGE_EXCHANGE_ID) VALUES (?, ?, ?, ?) [params=(long) 1049, (Reader) java.io.StringReader@de04e7, (String) {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckN..., (String) hqejbhcnphr388ldra7ugb]
DEBUG - SQL - <t 28811928, conn 32625434> [0 ms] spent
DEBUG - JDBC - <t 28811928, conn 32625434> [0 ms] close
DEBUG - BpelProcess - >> handleWorkEvent(jobData={mexid=hqejbhcnphr388ldra7ugb, pid={http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3, type=INVOKE_INTERNAL})
DEBUG - BpelProcess - InvokeInternal event for mexid hqejbhcnphr388ldra7ugb
DEBUG - SQL - <t 15547473, conn 330798> executing prepstmnt 30991002 SELECT t0.CALLEE, t0.CHANNEL, t0.CORRELATION_ID, t0.CORRELATION_KEYS, t0.CORRELATION_STATUS, t0.CORR_ID, t0.CREATE_TIME, t0.DIRECTION, t0.EPR, t0.FAULT, t0.FAULT_EXPLANATION, t0.OPERATION, t0.PARTNER_LINK_ID, t0.PARTNER_LINK_MODEL_ID, t0.PATTERN, t0.PIPED_ID, t0.PORT_TYPE, t0.PROCESS_ID, t0.PROCESS_INSTANCE_ID, t0.PROPAGATE_TRANS, t0.REQUEST_MESSAGE_ID, t0.RESPONSE_MESSAGE_ID, t0.STATUS, t1.MEX_ID, t1.ID, t1.PROP_KEY, t1.PROP_VALUE FROM ODE_MESSAGE_EXCHANGE t0 LEFT OUTER JOIN ODE_MEX_PROP t1 ON t0.MESSAGE_EXCHANGE_ID = t1.MEX_ID WHERE t0.MESSAGE_EXCHANGE_ID = ? ORDER BY t1.MEX_ID ASC [params=(String) hqejbhcnphr388ldra7ugb]
DEBUG - SQL - <t 15547473, conn 330798> [1 ms] spent
DEBUG - JDBC - <t 15547473, conn 330798> [0 ms] close
DEBUG - Query - Executing query: [select x from ProcessDAOImpl x where x._processId = ?1] with parameters: {1={http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3}
DEBUG - SQL - <t 15547473, conn 4027123> executing prepstmnt 26135841 SELECT t0.ID, t0.GUID, t0.NUMBER_OF_INSTANCES, t0.PROCESS_ID, t0.PROCESS_TYPE, t0.VERSION FROM ODE_PROCESS t0 WHERE (t0.PROCESS_ID = ?) [params=(String) {http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - SQL - <t 15547473, conn 4027123> [1 ms] spent
DEBUG - JDBC - <t 15547473, conn 4027123> [0 ms] close
DEBUG - Query - Executing query: [select x from ProcessDAOImpl x where x._processId = ?1] with parameters: {1={http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3}
DEBUG - SQL - <t 15547473, conn 188673> executing prepstmnt 32152931 SELECT t0.ID, t0.GUID, t0.NUMBER_OF_INSTANCES, t0.PROCESS_ID, t0.PROCESS_TYPE, t0.VERSION FROM ODE_PROCESS t0 WHERE (t0.PROCESS_ID = ?) [params=(String) {http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - SQL - <t 15547473, conn 188673> [0 ms] spent
DEBUG - JDBC - <t 15547473, conn 188673> [0 ms] close
DEBUG - Query - Executing query: [select x from ProcessDAOImpl x where x._processId = ?1] with parameters: {1={http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3}
DEBUG - SQL - <t 15547473, conn 329447> executing prepstmnt 11222097 SELECT t0.ID, t0.GUID, t0.NUMBER_OF_INSTANCES, t0.PROCESS_ID, t0.PROCESS_TYPE, t0.VERSION FROM ODE_PROCESS t0 WHERE (t0.PROCESS_ID = ?) [params=(String) {http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - SQL - <t 15547473, conn 329447> [0 ms] spent
DEBUG - JDBC - <t 15547473, conn 329447> [0 ms] close
DEBUG - Query - Executing query: [SELECT c FROM CorrelatorDAOImpl as c WHERE c._correlatorKey = :ckey AND c._process = :process] with parameters: {process=org.apache.ode.dao.jpa.ProcessDAOImpl@172975c, ckey=71.replyCCheckNG}
DEBUG - SQL - <t 15547473, conn 32646315> executing prepstmnt 3100441 SELECT t0.CORRELATOR_ID, t0.CORRELATOR_KEY, t0.PROC_ID FROM ODE_CORRELATOR t0 WHERE (t0.CORRELATOR_KEY = ? AND t0.PROC_ID = ?) [params=(String) 71.replyCCheckNG, (long) 55]
DEBUG - SQL - <t 15547473, conn 32646315> [1 ms] spent
DEBUG - SQL - <t 15547473, conn 32646315> executing prepstmnt 19756588 SELECT t0.CORRELATOR_ID, t1.MESSAGE_ROUTE_ID, t1.CORRELATION_KEY, t1.CORR_ID, t1.GROUP_ID, t1.ROUTE_INDEX, t1.PROCESS_INSTANCE_ID FROM ODE_CORRELATOR t0 INNER JOIN ODE_MESSAGE_ROUTE t1 ON t0.CORRELATOR_ID = t1.CORR_ID WHERE (t0.CORRELATOR_KEY = ? AND t0.PROC_ID = ?) ORDER BY t0.CORRELATOR_ID ASC [params=(String) 71.replyCCheckNG, (long) 55]
DEBUG - SQL - <t 15547473, conn 32646315> [1 ms] spent
DEBUG - JDBC - <t 15547473, conn 32646315> [0 ms] close
DEBUG - SQL - <t 15547473, conn 30656718> executing prepstmnt 6238751 SELECT t0.DATA, t0.MESSAGE_EXCHANGE_ID, t0.TYPE FROM ODE_MESSAGE t0 WHERE t0.MESSAGE_ID = ? [params=(long) 1049]
DEBUG - SQL - <t 15547473, conn 30656718> [0 ms] spent
DEBUG - JDBC - <t 15547473, conn 30656718> [0 ms] close
DEBUG - DeliveryChannelImpl - Send ID:127.0.1.1-1198e606fc3-11:4 in DeliveryChannel{OdeBpelEngine}
DEBUG - SedaFlow - Called Flow send
DEBUG - MessageExchangeImpl - GET MEX property org.apache.ode.bpel.myRoleSessionId = null
DEBUG - MessageExchangeImpl - GET MEX property org.apache.ode.bpel.myRoleSessionId = null
DEBUG - MessageExchangeImpl - GET MEX property org.apache.ode.bpel.partnerRoleSessionId = null
DEBUG - BpelProcess - INPUTMSG: 71.replyCCheckNG: MSG RCVD keys=[] mySessionId=null partnerSessionId=null
DEBUG - BpelProcess - INPUTMSG: 71.replyCCheckNG: SAVING to DB (no match)
DEBUG - Query - Executing query: [select x from ProcessDAOImpl x where x._processId = ?1] with parameters: {1={http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3}
DEBUG - SQL - <t 15547473, conn 8630836> executing prepstmnt 30648105 SELECT t0.ID, t0.GUID, t0.NUMBER_OF_INSTANCES, t0.PROCESS_ID, t0.PROCESS_TYPE, t0.VERSION FROM ODE_PROCESS t0 WHERE (t0.PROCESS_ID = ?) [params=(String) {http://localhost:8080/processes/NextGenWharehouse}NextGenWharehouse-3]
DEBUG - SQL - <t 15547473, conn 8630836> [0 ms] spent
DEBUG - JDBC - <t 15547473, conn 8630836> [1 ms] close
DEBUG - SQL - <t 15547473, conn 16233471> executing prepstmnt 9276499 SELECT t0.MESSAGE_EXCHANGE_ID, t0.CALLEE, t0.CHANNEL, t0.CORRELATION_ID, t0.CORRELATION_KEYS, t0.CORRELATION_STATUS, t0.CORR_ID, t0.CREATE_TIME, t0.DIRECTION, t0.EPR, t0.FAULT, t0.FAULT_EXPLANATION, t0.OPERATION, t0.PARTNER_LINK_ID, t0.PARTNER_LINK_MODEL_ID, t0.PATTERN, t0.PIPED_ID, t0.PORT_TYPE, t0.PROCESS_ID, t0.PROCESS_INSTANCE_ID, t0.PROPAGATE_TRANS, t0.REQUEST_MESSAGE_ID, t0.RESPONSE_MESSAGE_ID, t0.STATUS FROM ODE_MESSAGE_EXCHANGE t0 WHERE t0.CORR_ID = ? [params=(long) 57]
DEBUG - SQL - <t 15547473, conn 16233471> [1 ms] spent
DEBUG - SQL - <t 15547473, conn 16233471> executing prepstmnt 18147857 SELECT t0.MESSAGE_EXCHANGE_ID, t1.ID, t1.MEX_ID, t1.PROP_KEY, t1.PROP_VALUE FROM ODE_MESSAGE_EXCHANGE t0 INNER JOIN ODE_MEX_PROP t1 ON t0.MESSAGE_EXCHANGE_ID = t1.MEX_ID WHERE t0.CORR_ID = ? ORDER BY t0.MESSAGE_EXCHANGE_ID ASC [params=(long) 57]
DEBUG - SQL - <t 15547473, conn 16233471> [53 ms] spent
DEBUG - JDBC - <t 15547473, conn 16233471> [15 ms] close
DEBUG - MessageExchangeImpl - Releasing mex hqejbhcnphr388ldra7ugb
DEBUG - SQL - <t 15547473, conn 11006385> executing prepstmnt 10476058 UPDATE ODE_MESSAGE_EXCHANGE SET CORRELATION_STATUS = ?, PARTNER_LINK_MODEL_ID = ?, PATTERN = ?, CORR_ID = ?, PROCESS_ID = ? WHERE MESSAGE_EXCHANGE_ID = ? [params=(String) QUEUED, (int) 71, (String) REQUEST_ONLY, (long) 57, (long) 55, (String) hqejbhcnphr388ldra7ugb]
DEBUG - SQL - <t 15547473, conn 11006385> [2 ms] spent
DEBUG - JDBC - <t 15547473, conn 11006385> [0 ms] close
DEBUG - SedaQueue - org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1bb9953 dequeued exchange: InOnly[
id: ID:127.0.1.1-1198e606fc3-11:4
status: Done
role: consumer
service: {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckNGService
endpoint: replyCCheckNGPort
operation: {http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckNG
in: <?xml version="1.0" encoding="UTF-8" standalone="no"?><replyCCheckNG xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><approved>true</approved></replyCCheckNG>
]
DEBUG - JmsComponent - Received exchange: status: Done, role: consumer
DEBUG - JmsComponent - Retrieved correlation id: ID:127.0.1.1-1198e606fc3-11:4
It seems that the message is seen in the queue but it is not delivered to my waiting BPEL process.
Here is the queue configuration file:
<jms:endpoint connectionFactory="#jmsFactory" defaultMep="http://www.w3.org/2004/08/wsdl/in-only" defaultOperation="NextGenWharehouseW:replyCCheckNG" destinationStyle="queue" endpoint="replyCCheckNGPort" jmsProviderDestinationName="replyCCheckNGQueue" role="consumer" service="NextGenWharehouseW:replyCCheckNGService" soap="true" targetService="NextGenWharehouseW:replyCCheckNGService"/>
<bean class="org.apache.activemq.pool.PooledConnectionFactory" id="jmsFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
</property>
</bean>
and the wsdl too:
<wsdl:message name="replyCCheckNGMessage">
<wsdl:part name="approved" type="xsd:boolean"/>
</wsdl:message>
<wsdl:portType name="replyCCheckNGPortType">
<wsdl:operation name="replyCCheckNG">
<wsdl:input message="tns:replyCCheckNGMessage" name="replyCCheckNGIn"/>
</wsdl:operation>
</wsdl:portType>
<plnk:partnerLinkType name="replyCCheckNGPartnerLinkType">
<plnk:role name="replyCCheckNGRole" portType="tns:replyCCheckNGPortType"/>
</plnk:partnerLinkType>
All queues are created in such a way and they works fine.
Any Idea about it???
Please help me, this is a very important point in my thesis.
Thank you all, cheers
Simone