You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ode.apache.org by Simone Maletta <si...@alice.it> on 2008/04/29 16:39:17 UTC
Stopping BPEL process
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
Re: R: Stopping BPEL process
Posted by Alex Boisvert <bo...@intalio.com>.
Hi Simone,
It would help if you could narrow down your issue to something that's more
specific, without enough context there's not much we can do beyond
guesswork.
alex
On Tue, Apr 29, 2008 at 3:38 PM, <si...@alice.it> wrote:
> Hi Alex,
> I insert correlation in my processes but I'm at the starting point: my
> process blocks waiting for the last message.
> The process is the one you see yet, introducing a correlation set in its
> code.
> Have you got any idea to solve this problem??
> Please help me,
> cheers
> Simone
>
> -----Messaggio originale-----
> Da: Alex Boisvert [mailto:boisvert@intalio.com]
> Inviato: mar 29/04/2008 23.20
> A: user@ode.apache.org
> Oggetto: Re: Stopping BPEL process
>
> On Tue, Apr 29, 2008 at 12:54 PM, Simone Maletta <si...@alice.it>
> wrote:
>
> > Hi Alex,
> > may I use the same identifire for more than a couple of message?
>
>
> Yes, but not for two different instances.
>
> alex
>
>
R: Stopping BPEL process
Posted by si...@alice.it.
Hi Alex,
I insert correlation in my processes but I'm at the starting point: my process blocks waiting for the last message.
The process is the one you see yet, introducing a correlation set in its code.
Have you got any idea to solve this problem??
Please help me,
cheers
Simone
-----Messaggio originale-----
Da: Alex Boisvert [mailto:boisvert@intalio.com]
Inviato: mar 29/04/2008 23.20
A: user@ode.apache.org
Oggetto: Re: Stopping BPEL process
On Tue, Apr 29, 2008 at 12:54 PM, Simone Maletta <si...@alice.it>
wrote:
> Hi Alex,
> may I use the same identifire for more than a couple of message?
Yes, but not for two different instances.
alex
Re: Stopping BPEL process
Posted by Alex Boisvert <bo...@intalio.com>.
On Tue, Apr 29, 2008 at 12:54 PM, Simone Maletta <si...@alice.it>
wrote:
> Hi Alex,
> may I use the same identifire for more than a couple of message?
Yes, but not for two different instances.
alex
Re: Stopping BPEL process
Posted by Simone Maletta <si...@alice.it>.
Hi Alex,
may I use the same identifire for more than a couple of message?
In fact my class needs more than an interaction with the same BPEL pricess,
in fact it stops after the second receipt.
That's all right?
Thank you, cheers
Simone
----- Original Message -----
From: "Alex Boisvert" <bo...@intalio.com>
To: <us...@ode.apache.org>
Sent: Tuesday, April 29, 2008 9:42 PM
Subject: Re: Stopping BPEL process
> Without getting into the details,
>
> 1) Place a (unique) business identifier in your request message
> 2) Place the same identifier in your response message
> 3) Create a propertyAlias to retrieve this identifier from your message(s)
> 4) Add the necessary correlationSets into your BPEL process.
>
> alex
>
>
> On Tue, Apr 29, 2008 at 12:36 PM, Simone Maletta <si...@alice.it>
> wrote:
>
>> Hi Alex,
>> mediator is a Java class, then in witch way I may hang BPEL
>> correlation?
>> My class reads in-coming messages, stores it into an HashTable and
>> recover
>> them when it has to send a message.
>>
>> Are there problems in this manner?
>> I'm sure I'll be at start point?
>>
>> Thank you,
>> Simone
>>
>>
>> ----- Original Message ----- From: "Alex Boisvert" <bo...@intalio.com>
>> To: <us...@ode.apache.org>
>> Sent: Tuesday, April 29, 2008 9:20 PM
>>
>> Subject: Re: Stopping BPEL process
>>
>>
>> JMS correlation ids are not supported right now so you have to use BPEL
>> > correlations.
>> >
>> > alex
>> >
>> >
>> > On Tue, Apr 29, 2008 at 8:24 AM, Simone Maletta
>> > <si...@alice.it>
>> > wrote:
>> >
>> > Hi Alex,
>> > > may I simply hang the correlation using the correlationId field into
>> > > the
>> > > JMS-message header??
>> > > Thank you,
>> > > Simone
>> > >
>> > > ----- Original Message ----- From: "Alex Boisvert" <
>> > > boisvert@intalio.com>
>> > > To: <us...@ode.apache.org>
>> > > Sent: Tuesday, April 29, 2008 5:06 PM
>> > > Subject: Re: Stopping BPEL process
>> > >
>> > >
>> > > On Tue, Apr 29, 2008 at 7:39 AM, Simone Maletta <
>> > > simonemaletta@alice.it>
>> > > > wrote:
>> > > >
>> > > > Hi guys,
>> > > > > there is a way to have one and only one instance of a BPEL
>> > > process
>> > > > > into a Servicemix bus?
>> > > > >
>> > > >
>> > > >
>> > > > Not at the moment.
>> > > >
>> > > >
>> > > > 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:
>> > > > >
>> > > > > 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<http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN>
>> > > .<
>> > > http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN
>> > > .>
>> > > > > .<
>> > > > >
>> > > http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN.
>> > > > > .>.,
>> > > > > (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]
>> > > > >
>> > > >
>> > > >
>> > > > [snip]
>> > > >
>> > > > It looks like the message is received properly by the engine but it
>> > > > doesn't
>> > > > match any instance so the message is persisted until an instance
>> > > can
>> > > > pick
>> > > > it up later on.
>> > > >
>> > > >
>> > > >
>> > > > May be that the system is contacting another instance in the
>> > > > system
>> > > > and
>> > > > > the one my process was using before?
>> > > > >
>> > > >
>> > > >
>> > > > Possible, or not matching any instance at all.
>> > > >
>> > > >
>> > > > May I solve simply using a correlation set??
>> > > > >
>> > > >
>> > > >
>> > > > Yes, you should use some form of correlation. Take a look at the
>> > > BPEL
>> > > > specification for some examples.
>> > > >
>> > > >
>> > > > In witch way I may manage it using a java-jms client?
>> > > > >
>> > > >
>> > > >
>> > > > Normally, you pass some (user-defined) business identifier that's
>> > > known
>> > > > to
>> > > > the instance. Purchase order number, ticket number, customer
>> > > number, > or
>> > > > a
>> > > > combination of identifiers.
>> > > >
>> > > > alex
>> > > >
>> > > >
>> > >
>> > >
>> >
>>
>
Re: Stopping BPEL process
Posted by Alex Boisvert <bo...@intalio.com>.
Without getting into the details,
1) Place a (unique) business identifier in your request message
2) Place the same identifier in your response message
3) Create a propertyAlias to retrieve this identifier from your message(s)
4) Add the necessary correlationSets into your BPEL process.
alex
On Tue, Apr 29, 2008 at 12:36 PM, Simone Maletta <si...@alice.it>
wrote:
> Hi Alex,
> mediator is a Java class, then in witch way I may hang BPEL correlation?
> My class reads in-coming messages, stores it into an HashTable and recover
> them when it has to send a message.
>
> Are there problems in this manner?
> I'm sure I'll be at start point?
>
> Thank you,
> Simone
>
>
> ----- Original Message ----- From: "Alex Boisvert" <bo...@intalio.com>
> To: <us...@ode.apache.org>
> Sent: Tuesday, April 29, 2008 9:20 PM
>
> Subject: Re: Stopping BPEL process
>
>
> JMS correlation ids are not supported right now so you have to use BPEL
> > correlations.
> >
> > alex
> >
> >
> > On Tue, Apr 29, 2008 at 8:24 AM, Simone Maletta <si...@alice.it>
> > wrote:
> >
> > Hi Alex,
> > > may I simply hang the correlation using the correlationId field into
> > > the
> > > JMS-message header??
> > > Thank you,
> > > Simone
> > >
> > > ----- Original Message ----- From: "Alex Boisvert" <
> > > boisvert@intalio.com>
> > > To: <us...@ode.apache.org>
> > > Sent: Tuesday, April 29, 2008 5:06 PM
> > > Subject: Re: Stopping BPEL process
> > >
> > >
> > > On Tue, Apr 29, 2008 at 7:39 AM, Simone Maletta <
> > > simonemaletta@alice.it>
> > > > wrote:
> > > >
> > > > Hi guys,
> > > > > there is a way to have one and only one instance of a BPEL
> > > process
> > > > > into a Servicemix bus?
> > > > >
> > > >
> > > >
> > > > Not at the moment.
> > > >
> > > >
> > > > 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:
> > > > >
> > > > > 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<http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN>
> > > .<
> > > http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN
> > > .>
> > > > > .<
> > > > >
> > > http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN.
> > > > > .>.,
> > > > > (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]
> > > > >
> > > >
> > > >
> > > > [snip]
> > > >
> > > > It looks like the message is received properly by the engine but it
> > > > doesn't
> > > > match any instance so the message is persisted until an instance
> > > can
> > > > pick
> > > > it up later on.
> > > >
> > > >
> > > >
> > > > May be that the system is contacting another instance in the system
> > > > and
> > > > > the one my process was using before?
> > > > >
> > > >
> > > >
> > > > Possible, or not matching any instance at all.
> > > >
> > > >
> > > > May I solve simply using a correlation set??
> > > > >
> > > >
> > > >
> > > > Yes, you should use some form of correlation. Take a look at the
> > > BPEL
> > > > specification for some examples.
> > > >
> > > >
> > > > In witch way I may manage it using a java-jms client?
> > > > >
> > > >
> > > >
> > > > Normally, you pass some (user-defined) business identifier that's
> > > known
> > > > to
> > > > the instance. Purchase order number, ticket number, customer
> > > number, > or
> > > > a
> > > > combination of identifiers.
> > > >
> > > > alex
> > > >
> > > >
> > >
> > >
> >
>
Re: Stopping BPEL process
Posted by Simone Maletta <si...@alice.it>.
Hi Alex,
mediator is a Java class, then in witch way I may hang BPEL correlation?
My class reads in-coming messages, stores it into an HashTable and recover
them when it has to send a message.
Are there problems in this manner?
I'm sure I'll be at start point?
Thank you,
Simone
----- Original Message -----
From: "Alex Boisvert" <bo...@intalio.com>
To: <us...@ode.apache.org>
Sent: Tuesday, April 29, 2008 9:20 PM
Subject: Re: Stopping BPEL process
> JMS correlation ids are not supported right now so you have to use BPEL
> correlations.
>
> alex
>
>
> On Tue, Apr 29, 2008 at 8:24 AM, Simone Maletta <si...@alice.it>
> wrote:
>
>> Hi Alex,
>> may I simply hang the correlation using the correlationId field into
>> the
>> JMS-message header??
>> Thank you,
>> Simone
>>
>> ----- Original Message ----- From: "Alex Boisvert" <bo...@intalio.com>
>> To: <us...@ode.apache.org>
>> Sent: Tuesday, April 29, 2008 5:06 PM
>> Subject: Re: Stopping BPEL process
>>
>>
>> On Tue, Apr 29, 2008 at 7:39 AM, Simone Maletta <si...@alice.it>
>> > wrote:
>> >
>> > Hi guys,
>> > > there is a way to have one and only one instance of a BPEL process
>> > > into a Servicemix bus?
>> > >
>> >
>> >
>> > Not at the moment.
>> >
>> >
>> > 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:
>> > >
>> > > 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.<http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN.>
>> > > .<
>> > > http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN.
>> > > .>.,
>> > > (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]
>> > >
>> >
>> >
>> > [snip]
>> >
>> > It looks like the message is received properly by the engine but it
>> > doesn't
>> > match any instance so the message is persisted until an instance can
>> > pick
>> > it up later on.
>> >
>> >
>> >
>> > May be that the system is contacting another instance in the system
>> > and
>> > > the one my process was using before?
>> > >
>> >
>> >
>> > Possible, or not matching any instance at all.
>> >
>> >
>> > May I solve simply using a correlation set??
>> > >
>> >
>> >
>> > Yes, you should use some form of correlation. Take a look at the BPEL
>> > specification for some examples.
>> >
>> >
>> > In witch way I may manage it using a java-jms client?
>> > >
>> >
>> >
>> > Normally, you pass some (user-defined) business identifier that's known
>> > to
>> > the instance. Purchase order number, ticket number, customer number,
>> > or
>> > a
>> > combination of identifiers.
>> >
>> > alex
>> >
>> >
>>
>
Re: Stopping BPEL process
Posted by Alex Boisvert <bo...@intalio.com>.
JMS correlation ids are not supported right now so you have to use BPEL
correlations.
alex
On Tue, Apr 29, 2008 at 8:24 AM, Simone Maletta <si...@alice.it>
wrote:
> Hi Alex,
> may I simply hang the correlation using the correlationId field into the
> JMS-message header??
> Thank you,
> Simone
>
> ----- Original Message ----- From: "Alex Boisvert" <bo...@intalio.com>
> To: <us...@ode.apache.org>
> Sent: Tuesday, April 29, 2008 5:06 PM
> Subject: Re: Stopping BPEL process
>
>
> On Tue, Apr 29, 2008 at 7:39 AM, Simone Maletta <si...@alice.it>
> > wrote:
> >
> > Hi guys,
> > > there is a way to have one and only one instance of a BPEL process
> > > into a Servicemix bus?
> > >
> >
> >
> > Not at the moment.
> >
> >
> > 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:
> > >
> > > 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.<http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN.>
> > > .<
> > > http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN.
> > > .>.,
> > > (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]
> > >
> >
> >
> > [snip]
> >
> > It looks like the message is received properly by the engine but it
> > doesn't
> > match any instance so the message is persisted until an instance can
> > pick
> > it up later on.
> >
> >
> >
> > May be that the system is contacting another instance in the system and
> > > the one my process was using before?
> > >
> >
> >
> > Possible, or not matching any instance at all.
> >
> >
> > May I solve simply using a correlation set??
> > >
> >
> >
> > Yes, you should use some form of correlation. Take a look at the BPEL
> > specification for some examples.
> >
> >
> > In witch way I may manage it using a java-jms client?
> > >
> >
> >
> > Normally, you pass some (user-defined) business identifier that's known
> > to
> > the instance. Purchase order number, ticket number, customer number, or
> > a
> > combination of identifiers.
> >
> > alex
> >
> >
>
Re: Stopping BPEL process
Posted by Simone Maletta <si...@alice.it>.
Hi Alex,
may I simply hang the correlation using the correlationId field into the
JMS-message header??
Thank you,
Simone
----- Original Message -----
From: "Alex Boisvert" <bo...@intalio.com>
To: <us...@ode.apache.org>
Sent: Tuesday, April 29, 2008 5:06 PM
Subject: Re: Stopping BPEL process
> On Tue, Apr 29, 2008 at 7:39 AM, Simone Maletta <si...@alice.it>
> wrote:
>
>> Hi guys,
>> there is a way to have one and only one instance of a BPEL process
>> into a Servicemix bus?
>
>
> Not at the moment.
>
>
>> 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:
>>
>> 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..<http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN..>.,
>> (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]
>
>
> [snip]
>
> It looks like the message is received properly by the engine but it
> doesn't
> match any instance so the message is persisted until an instance can pick
> it up later on.
>
>
>
>> May be that the system is contacting another instance in the system and
>> the one my process was using before?
>
>
> Possible, or not matching any instance at all.
>
>
>> May I solve simply using a correlation set??
>
>
> Yes, you should use some form of correlation. Take a look at the BPEL
> specification for some examples.
>
>
>> In witch way I may manage it using a java-jms client?
>
>
> Normally, you pass some (user-defined) business identifier that's known to
> the instance. Purchase order number, ticket number, customer number, or a
> combination of identifiers.
>
> alex
>
Re: Stopping BPEL process
Posted by Alex Boisvert <bo...@intalio.com>.
On Tue, Apr 29, 2008 at 7:39 AM, Simone Maletta <si...@alice.it>
wrote:
> Hi guys,
> there is a way to have one and only one instance of a BPEL process
> into a Servicemix bus?
Not at the moment.
> 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:
>
> 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..<http://localhost:8080/processes/NextGenWharehouse.wsdl%7DreplyCCheckN..>.,
> (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]
[snip]
It looks like the message is received properly by the engine but it doesn't
match any instance so the message is persisted until an instance can pick
it up later on.
> May be that the system is contacting another instance in the system and
> the one my process was using before?
Possible, or not matching any instance at all.
> May I solve simply using a correlation set??
Yes, you should use some form of correlation. Take a look at the BPEL
specification for some examples.
> In witch way I may manage it using a java-jms client?
Normally, you pass some (user-defined) business identifier that's known to
the instance. Purchase order number, ticket number, customer number, or a
combination of identifiers.
alex