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 - [EMAIL PROTECTED] 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) [EMAIL
PROTECTED], (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: [EMAIL PROTECTED], 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 - [EMAIL PROTECTED] 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
