ode-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Simone Maletta" <simonemale...@alice.it>
Subject Stopping BPEL process
Date Tue, 29 Apr 2008 14:39:17 GMT
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 = org.apache.activemq.util.ByteSequence@11babf8, 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 = org.apache.activemq.util.ByteSequence@11babf8, 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                      - org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@426f80
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) java.io.StringReader@1b84919, (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: {process=org.apache.ode.dao.jpa.ProcessDAOImpl@1a47b0f,
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                      - org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@179c51b
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


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message