Hi guys,
there is a way to have one and only one instance of a BPEL process into a
Servicemix bus?
I'm using ServiceMix 3.1.2 and ODE jbi 1.1 and I'm trying to orchestrates some
BPEL processes using a Java Class.
I observe a strange behavior try to send a message again I see this log on the
console:
MultiplexingConsumerProcessor - Received jms message ActiveMQTextMessage
{commandId = 5, responseRequired = true, messageId =
ID:jars-desktop-39543-1209346926880-0:9:1:1:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:jars-desktop-39543-1209346926880-0:9:1:1, destination =
queue://replyCCheckNGQueue, transactionId = null, expiration = 0, timestamp =
1209346946400, arrival = 0, correlationId = null, replyTo = null, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content = [EMAIL
PROTECTED], marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = true,
readOnlyBody = true, droppable = false, text = null}
DEBUG - MultiplexingConsumerProcessor - Handling jms message
ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId =
ID:jars-desktop-39543-1209346926880-0:9:1:1:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:jars-desktop-39543-1209346926880-0:9:1:1, destination =
queue://replyCCheckNGQueue, transactionId = null, expiration = 0, timestamp =
1209346946400, arrival = 0, correlationId = null, replyTo = null, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content = [EMAIL
PROTECTED], marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = true,
readOnlyBody = true, droppable = false, text = null}
DEBUG - JmsComponent - Created correlation id:
ID:127.0.1.1-11992af3611-11:4
DEBUG - DeliveryChannelImpl - Send ID:127.0.1.1-11992af3611-11:4 in
DeliveryChannel{servicemix-jms}
DEBUG - SedaFlow - Called Flow send
DEBUG - SedaQueue - [EMAIL PROTECTED] dequeued exchange:
InOnly[
id: ID:127.0.1.1-11992af3611-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-11992af3611-11:4 in DeliveryChannel{OdeBpelEngine}
DEBUG - SQL - <t 20247003, conn 9286669> executing
prepstmnt 28206479 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) hqejbhcnphr38b9jekq3qc, (String)
{http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckN..., (null)
null, (String) ID:127.0.1.1-11992af3611-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) 2855, (null) null]
DEBUG - SQL - <t 20247003, conn 9286669> [1 ms] spent
DEBUG - SQL - <t 20247003, conn 9286669> executing
prepstmnt 29825697 INSERT INTO ODE_MESSAGE (MESSAGE_ID, DATA, TYPE,
MESSAGE_EXCHANGE_ID) VALUES (?, ?, ?, ?) [params=(long) 2855, (Reader) [EMAIL
PROTECTED], (String)
{http://localhost:8080/processes/NextGenWharehouse.wsdl}replyCCheckN...,
(String) hqejbhcnphr38b9jekq3qc]
DEBUG - SQL - <t 20247003, conn 9286669> [0 ms] spent
DEBUG - SQL - <t 20247003, conn 9286669> executing
prepstmnt 3095224 INSERT INTO ODE_MEX_PROP (ID, PROP_KEY, PROP_VALUE, MEX_ID)
VALUES (?, ?, ?, ?) [params=(long) 2856, (String)
org.apache.ode.jbi.msgmap.Mapper, (String)
org.apache.ode.jbi.msgmap.ServiceMixMapper, (String) hqejbhcnphr38b9jekq3qc]
DEBUG - SQL - <t 20247003, conn 9286669> [1 ms] spent
DEBUG - JDBC - <t 20247003, conn 9286669> [0 ms] close
DEBUG - SQL - <t 25117323, conn 26302125> executing
prepstmnt 10912195 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)
hqejbhcnphr38b9jekq3qc]
DEBUG - SQL - <t 25117323, conn 26302125> [1 ms]
spent
DEBUG - JDBC - <t 25117323, conn 26302125> [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 25117323, conn 14973083> executing
prepstmnt 28839694 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 25117323, conn 14973083> [0 ms]
spent
DEBUG - JDBC - <t 25117323, conn 14973083> [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 25117323, conn 17922822> executing
prepstmnt 19606261 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 25117323, conn 17922822> [0 ms]
spent
DEBUG - JDBC - <t 25117323, conn 17922822> [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 25117323, conn 24720883> executing
prepstmnt 15505946 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 25117323, conn 24720883> [0 ms]
spent
DEBUG - JDBC - <t 25117323, conn 24720883> [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 25117323, conn 20316627> executing
prepstmnt 25907218 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) 1847]
DEBUG - SQL - <t 25117323, conn 20316627> [1 ms]
spent
DEBUG - SQL - <t 25117323, conn 20316627> executing
prepstmnt 32029666 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) 1847]
DEBUG - SQL - <t 25117323, conn 20316627> [0 ms]
spent
DEBUG - JDBC - <t 25117323, conn 20316627> [0 ms]
close
DEBUG - SQL - <t 25117323, conn 21210388> executing
prepstmnt 26659935 SELECT t0.DATA, t0.MESSAGE_EXCHANGE_ID, t0.TYPE FROM
ODE_MESSAGE t0 WHERE t0.MESSAGE_ID = ? [params=(long) 2855]
DEBUG - SQL - <t 25117323, conn 21210388> [1 ms]
spent
DEBUG - JDBC - <t 25117323, conn 21210388> [1 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 25117323, conn 12596810> executing
prepstmnt 20684031 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 25117323, conn 12596810> [0 ms]
spent
DEBUG - JDBC - <t 25117323, conn 12596810> [0 ms]
close
DEBUG - SQL - <t 25117323, conn 20873327> executing
prepstmnt 3546947 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) 1849]
DEBUG - SQL - <t 25117323, conn 20873327> [1 ms]
spent
DEBUG - SQL - <t 25117323, conn 20873327> executing
prepstmnt 15380594 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) 1849]
DEBUG - DeliveryChannelImpl - Send ID:127.0.1.1-11992af3611-11:4 in
DeliveryChannel{OdeBpelEngine}
DEBUG - SedaFlow - Called Flow send
DEBUG - SedaQueue - [EMAIL PROTECTED] dequeued exchange:
InOnly[
id: ID:127.0.1.1-11992af3611-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-11992af3611-11:4
DEBUG - SQL - <t 25117323, conn 20873327> [174 ms]
spent
DEBUG - JDBC - <t 25117323, conn 20873327> [0 ms]
close
DEBUG - SQL - <t 25117323, conn 206716> executing
prepstmnt 13166638 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) 1849, (long) 1847, (String) hqejbhcnphr38b9jekq3qc]
DEBUG - SQL - <t 25117323, conn 206716> [2 ms] spent
DEBUG - JDBC - <t 25117323, conn 206716> [0 ms] close
and nothing else happens.
May be that the system is contacting another instance in the system and the one
my process was using before?
May I solve simply using a correlation set??
In witch way I may manage it using a java-jms client?
Have you got any idea??
Please help me, I've to delivery my work tomorrow!!!!
Thank you all,
regards
