You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ode.apache.org by Kevin SEJOURNE <Ke...@intrinsec.com> on 2014/02/06 00:04:50 UTC
Creating instance from jms.
Dear list,
I am trying to use JMS in ODE. My main goal is to create new instances of a process from queues or topics.
For each jms message I want a new instance.
I have setup an activeMq and reconfigure my helloworld process in that way :
<correlationSets>
<correlationSet name="PO1" properties="bonjourlemonde:POUET"></correlationSet>
</correlationSets>
<pick createInstance="yes">
<onMessage partnerLink="helloWorldPartnerLinkClient" operation="sayHi" variable="sayHiRequest">
<correlations><correlation set="PO1" initiate="yes" /></correlations>
<sequence name="MainSequence">
<assign name="myInputInitialization">
<copy>
<from>
....
I have change the wsdl related to helloWorldPartnerLinkClient into :
<wsdl:binding name="HelloWorldClientSoapBinding" type="tns:IHelloWorld">
<soap:binding style="document" transport="http://www.w3.org/2010/soapjms/" />
<soapjms:jndiContextParameter name="name" value="value" />
<soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:jndiConnectionFactoryName>
<soapjms:jndiInitialContextFactory>org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:jndiInitialContextFactory>
<soapjms:jndiURL>tcp://isc-lab-gaia01.isc-lab.lan:19782</soapjms:jndiURL>
<soapjms:deliveryMode>PERSISTENT</soapjms:deliveryMode>
<wsdl:operation name="sayHi">
<soap:operation soapAction="" style="document" />
<wsdl:input name="sayHi">
<soap:body use="literal" />
</wsdl:input>
<wsdl:output name="sayHiResponse">
<soap:body use="literal" />
</wsdl:output>
</wsdl:operation>
</wsdl:binding>
<wsdl:service name="HelloWorldClient">
<soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:jndiConnectionFactoryName>
<soapjms:jndiInitialContextFactory>org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:jndiInitialContextFactory>
<wsdl:port binding="tns:HelloWorldClientSoapBinding" name="HelloWorldPort">
<soap:address location="jms:/jndi:dynamicQueues/helloworldjms.sayHi" />
</wsdl:port>
</wsdl:service>
<prop:property name="POUET" type="xsd:string"/>
<prop:propertyAlias propertyName="tns:POUET" messageType="tns:sayHi" part="parameters">
<prop:query>text</prop:query>
</prop:propertyAlias>
...
<partnerLinkType
name="IHelloWorldPlt"
xmlns="http://docs.oasis-open.org/wsbpel/2.0/plnktype">
<role name="IHelloWorldRoleClientRequest" portType="client:IHelloWorld"/>
</partnerLinkType>
As attachement the complet package (sorry it is configured for my dns), and the main piece of java code to the client & jms sender.
From the activeMq interface I can see ODE waiting for messages.
When I send messages like :
<?xml version="1.0" encoding="utf-8" ?>
<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/">
<S:Body>
<ns2:sayHi xmlns:ns2="BonjourLeMonde.orchestrator.gaia.intrinsec.com">
<text>Coucou</text>
</ns2:sayHi>
</S:Body>
</S:Envelope>
Ode receive the message but the intance of the process never start, and there is no errors or warning, all
informations looks good to me... but it never start :
DEBUG - jms-Worker-3 - JMSMessageReceiver.onMessage(89) | Received new JMS message for service :MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi
Destination : queue://helloworldjms.sayHi
Message ID : ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
Correlation ID : null
ReplyTo : queue://helloworldjms.sayHi.replyQueue
Redelivery ? : false
Priority : 4
Expiration : 0
Timestamp : 1391622698519
Message Type : null
Persistent ? : false
DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for urn:mediate
DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace: http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
DEBUG - jms-Worker-3 - AxisService.getOperation(1758) | Operations aliases map: {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/IHelloWorld/sayHi=org.apache.axis2.description.InOutAxisOperation@2213f290}
DEBUG - jms-Worker-3 - AxisService.getOperation(1767) | Imported namespaces: []
DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis operation: null
DEBUG - jms-Worker-3 - BuilderUtil.getCharSetEncoding(333) | char set encoding set from default =utf-8
DEBUG - jms-Worker-3 - StAXUtils.createXMLStreamReader(207) | XMLStreamReader is org.apache.axiom.util.stax.dialect.WoodstoxStreamReaderWrapper
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.constructNode(316) | Starting to process SOAP 1.1 message
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build the OMElement Envelope by the StaxSOAPModelBuilder
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build the OMElement Body by the StaxSOAPModelBuilder
[ ... ]
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build the OMElement sayHi by the StaxSOAPModelBuilder
DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(71) | Checking for Operation using SOAP message body's first child's local name : sayHi
DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for sayHi
DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace: http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis operation: org.apache.axis2.description.InOutAxisOperation@2213f290
DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(77) | Found operation org.apache.axis2.description.InOutAxisOperation@2213f290
DEBUG - jms-Worker-3 - ProjectResourceBundle.handleGetObject(70) | org.apache.axis2.i18n.resource::handleGetObject(operationfound)
DEBUG - jms-Worker-3 - AbstractDispatcher.invoke(110) | [MessageContext: logID=urn:uuid:7CC27F3856291A52E91391622700744] Found AxisOperation : sayHi
[ ... ]
DEBUG - jms-Worker-3 - ODEMessageReceiver.invokeBusinessLogic(45) | Received request message for MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi.{http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}sayHi
DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(217) | Incoming Transport is JMS, lets check for JMS correlation id
DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(221) | Correlation id is ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
DEBUG - jms-Worker-3 - WSAEndpoint.toMap(198) | Filled transfo map with service: {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient
DEBUG - jms-Worker-3 - WSAEndpoint.toMap(199) | Filled transfo map with port: HelloWorldPort
DEBUG - jms-Worker-3 - Properties$Axis2.translate(141) | Translating Properties for Axis2
DEBUG - jms-Worker-3 - OnDemandLogger.debug(85) | messageID is null.
DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(106) | Starting transaction.
DEBUG - jms-Worker-3 - BpelEngineImpl.route(364) | Routed: svcQname {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient --> [BpelProcess[{http://deployment.orchestrator.intrinsec.com/process}MYSIMPLE-1], BpelProcess[{http://deployment.orchestrator.intrinsec.com/process}MYBPELJMS-25]]
DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(113) | ODE routed to operation null from service {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient
The last line is strange, but then ODE's logs continues as if nothing append.
Can you help me to find what is going wrong ?
best regards,
Kévin.
Kevin SEJOURNE
Ingénieur Recherche et Développement
Standard : +33141917777 • Fax : +33141917778
215, avenue Georges Clemenceau • 92024 Nanterre
[cid:image5f143e.GIF@0dcd32b3.4fa9c6ab]<http://www.intrinsec.com/>
[cid:image71c6be.JPG@221eb861.4d9073c8]<http://www.intrinsec.com/>
RE: Creating instance from jms.
Posted by Kevin SEJOURNE <Ke...@intrinsec.com>.
Hello Sathwik,
Thank to you I have been able to make it by working in the good direction.
I'm not sure what was the problem when receiving the jms messages; I have
trash the tomcat and create a new one. Thank a lot for the time you have
take to help me. I'm starting integration using owl-s to bpel now.
regards,
Kévin
Kevin SEJOURNE
Ingénieur Recherche et Développement
Standard : +33141917777 • Fax : +33141917778
215, avenue Georges Clemenceau • 92024 Nanterre
[cid:imaged626c5.GIF@2122e068.48896e28]<http://www.intrinsec.com/>
[cid:imagee95bd8.JPG@3939f7fe.45ba38ce]<http://www.intrinsec.com/>
________________________________
De : Sathwik B P <sa...@apache.org>
Envoyé : vendredi 7 février 2014 10:38
À : user@ode.apache.org
Objet : Re: Creating instance from jms.
H Kevin,
I was able to get it working. Not sure about the message that you are encountering.
Here is the changed process artifact, the request playload. I sent the soap message from the activeMQ web console.
Kindly find the logs as well.
regards,
sathwik
________________________________
On Fri, Feb 7, 2014 at 2:32 PM, Sathwik B P <sa...@apache.org>> wrote:
On Thu, Feb 6, 2014 at 4:34 AM, Kevin SEJOURNE <Ke...@intrinsec.com>> wrote:
Dear list,
I am trying to use JMS in ODE. My main goal is to create new instances of a process from queues or topics.
For each jms message I want a new instance.
I have setup an activeMq and reconfigure my helloworld process in that way :
<correlationSets>
<correlationSet name="PO1" properties="bonjourlemonde:POUET"></correlationSet>
</correlationSets>
<pick createInstance="yes">
<onMessage partnerLink="helloWorldPartnerLinkClient" operation="sayHi" variable="sayHiRequest">
<correlations><correlation set="PO1" initiate="yes" /></correlations>
<sequence name="MainSequence">
<assign name="myInputInitialization">
<copy>
<from>
....
I have change the wsdl related to helloWorldPartnerLinkClient into :
<wsdl:binding name="HelloWorldClientSoapBinding" type="tns:IHelloWorld">
<soap:binding style="document" transport="http://www.w3.org/2010/soapjms/" />
<soapjms:jndiContextParameter name="name" value="value" />
<soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:jndiConnectionFactoryName>
<soapjms:jndiInitialContextFactory>org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:jndiInitialContextFactory>
<soapjms:jndiURL>tcp://isc-lab-gaia01.isc-lab.lan:19782</soapjms:jndiURL>
<soapjms:deliveryMode>PERSISTENT</soapjms:deliveryMode>
<wsdl:operation name="sayHi">
<soap:operation soapAction="" style="document" />
<wsdl:input name="sayHi">
<soap:body use="literal" />
</wsdl:input>
<wsdl:output name="sayHiResponse">
<soap:body use="literal" />
</wsdl:output>
</wsdl:operation>
</wsdl:binding>
<wsdl:service name="HelloWorldClient">
<soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:jndiConnectionFactoryName>
<soapjms:jndiInitialContextFactory>org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:jndiInitialContextFactory>
<wsdl:port binding="tns:HelloWorldClientSoapBinding" name="HelloWorldPort">
<soap:address location="jms:/jndi:dynamicQueues/helloworldjms.sayHi" />
</wsdl:port>
</wsdl:service>
<prop:property name="POUET" type="xsd:string"/>
<prop:propertyAlias propertyName="tns:POUET" messageType="tns:sayHi" part="parameters">
<prop:query>text</prop:query>
</prop:propertyAlias>
...
<partnerLinkType
name="IHelloWorldPlt"
xmlns="http://docs.oasis-open.org/wsbpel/2.0/plnktype">
<role name="IHelloWorldRoleClientRequest" portType="client:IHelloWorld"/>
</partnerLinkType>
As attachement the complet package (sorry it is configured for my dns), and the main piece of java code to the client & jms sender.
From the activeMq interface I can see ODE waiting for messages.
When I send messages like :
<?xml version="1.0" encoding="utf-8" ?>
<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/">
<S:Body>
<ns2:sayHi xmlns:ns2="BonjourLeMonde.orchestrator.gaia.intrinsec.com<http://BonjourLeMonde.orchestrator.gaia.intrinsec.com>">
<text>Coucou</text>
</ns2:sayHi>
</S:Body>
</S:Envelope>
Ode receive the message but the intance of the process never start, and there is no errors or warning, all
informations looks good to me... but it never start :
DEBUG - jms-Worker-3 - JMSMessageReceiver.onMessage(89) | Received new JMS message for service :MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi
Destination : queue://helloworldjms.sayHi
Message ID : ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
Correlation ID : null
ReplyTo : queue://helloworldjms.sayHi.replyQueue
Redelivery ? : false
Priority : 4
Expiration : 0
Timestamp : 1391622698519
Message Type : null
Persistent ? : false
DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for urn:mediate
DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace: http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
DEBUG - jms-Worker-3 - AxisService.getOperation(1758) | Operations aliases map: {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/IHelloWorld/sayHi=org.apache.axis2.description.InOutAxisOperation@2213f290}
DEBUG - jms-Worker-3 - AxisService.getOperation(1767) | Imported namespaces: []
DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis operation: null
DEBUG - jms-Worker-3 - BuilderUtil.getCharSetEncoding(333) | char set encoding set from default =utf-8
DEBUG - jms-Worker-3 - StAXUtils.createXMLStreamReader(207) | XMLStreamReader is org.apache.axiom.util.stax.dialect.WoodstoxStreamReaderWrapper
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.constructNode(316) | Starting to process SOAP 1.1 message
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build the OMElement Envelope by the StaxSOAPModelBuilder
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build the OMElement Body by the StaxSOAPModelBuilder
[ ... ]
DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build the OMElement sayHi by the StaxSOAPModelBuilder
DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(71) | Checking for Operation using SOAP message body's first child's local name : sayHi
DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for sayHi
DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace: http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis operation: org.apache.axis2.description.InOutAxisOperation@2213f290
DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(77) | Found operation org.apache.axis2.description.InOutAxisOperation@2213f290
DEBUG - jms-Worker-3 - ProjectResourceBundle.handleGetObject(70) | org.apache.axis2.i18n.resource::handleGetObject(operationfound)
DEBUG - jms-Worker-3 - AbstractDispatcher.invoke(110) | [MessageContext: logID=urn:uuid:7CC27F3856291A52E91391622700744] Found AxisOperation : sayHi
[ ... ]
DEBUG - jms-Worker-3 - ODEMessageReceiver.invokeBusinessLogic(45) | Received request message for MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi.{http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}sayHi<http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/%7DsayHi>
DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(217) | Incoming Transport is JMS, lets check for JMS correlation id
DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(221) | Correlation id is ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
DEBUG - jms-Worker-3 - WSAEndpoint.toMap(198) | Filled transfo map with service: {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient<http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/%7DHelloWorldClient>
DEBUG - jms-Worker-3 - WSAEndpoint.toMap(199) | Filled transfo map with port: HelloWorldPort
DEBUG - jms-Worker-3 - Properties$Axis2.translate(141) | Translating Properties for Axis2
DEBUG - jms-Worker-3 - OnDemandLogger.debug(85) | messageID is null.
DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(106) | Starting transaction.
DEBUG - jms-Worker-3 - BpelEngineImpl.route(364) | Routed: svcQname {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient<http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/%7DHelloWorldClient> --> [BpelProcess[{http://deployment.orchestrator.intrinsec.com/process}MYSIMPLE-1<http://deployment.orchestrator.intrinsec.com/process%7DMYSIMPLE-1>], BpelProcess[{http://deployment.orchestrator.intrinsec.com/process}MYBPELJMS-25<http://deployment.orchestrator.intrinsec.com/process%7DMYBPELJMS-25>]]
DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(113) | ODE routed to operation null from service {http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient<http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/%7DHelloWorldClient>
The last line is strange, but then ODE's logs continues as if nothing append.
Can you help me to find what is going wrong ?
best regards,
Kévin.
Kevin SEJOURNE
Ingénieur Recherche et Développement
Standard : +33141917777<tel:%2B33141917777> • Fax : +33141917778<tel:%2B33141917778>
215, avenue Georges Clemenceau • 92024 Nanterre
[cid:image5f143e.GIF@0dcd32b3.4fa9c6ab]<http://www.intrinsec.com/>
[cid:image71c6be.JPG@221eb861.4d9073c8]<http://www.intrinsec.com/>
Re: Creating instance from jms.
Posted by Sathwik B P <sa...@apache.org>.
H Kevin,
I was able to get it working. Not sure about the message that you are
encountering.
Here is the changed process artifact, the request playload. I sent the soap
message from the activeMQ web console.
Kindly find the logs as well.
regards,
sathwik
On Fri, Feb 7, 2014 at 2:32 PM, Sathwik B P <sa...@apache.org> wrote:
>
>
>
> On Thu, Feb 6, 2014 at 4:34 AM, Kevin SEJOURNE <
> Kevin.SEJOURNE@intrinsec.com> wrote:
>
>> Dear list,
>>
>> I am trying to use JMS in ODE. My main goal is to create new instances of
>> a process from queues or topics.
>> For each jms message I want a new instance.
>>
>> I have setup an activeMq and reconfigure my helloworld process in that
>> way :
>> <correlationSets>
>> <correlationSet name="*PO1*" properties="*bonjourlemonde:POUET*"></
>> correlationSet>
>> </correlationSets>
>>
>> <pick createInstance="yes">
>> <onMessage partnerLink="*helloWorldPartnerLinkClient*" operation="
>> *sayHi*" variable="*sayHiRequest*">
>>
>> <correlations><correlation set="*PO1*" initiate="yes" /></
>> correlations>
>> <sequence name="*MainSequence*">
>> <assign name="*myInputInitialization*">
>> <copy>
>> <from>
>> ....
>>
>>
>> I have change the wsdl related to *helloWorldPartnerLinkClient* into :
>>
>> <wsdl:binding name="*HelloWorldClientSoapBinding*" type="
>> *tns:IHelloWorld*">
>> <soap:binding style="*document*" transport="*http://www.w3.org/2010/soapjms/
>> <http://www.w3.org/2010/soapjms/>*" />
>> <soapjms:jndiContextParameter name="*name*" value="*value*" />
>> <soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:
>> jndiConnectionFactoryName>
>> <soapjms:jndiInitialContextFactory
>> >org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:
>> jndiInitialContextFactory>
>> <soapjms:jndiURL>tcp://isc-lab-gaia01.isc-lab.lan:19782</soapjms:
>> jndiURL>
>> <soapjms:deliveryMode>PERSISTENT</soapjms:deliveryMode>
>> <wsdl:operation name="*sayHi*">
>> <soap:operation soapAction="" style="*document*" />
>> <wsdl:input name="*sayHi*">
>> <soap:body use="*literal*" />
>> </wsdl:input>
>> <wsdl:output name="*sayHiResponse*">
>> <soap:body use="*literal*" />
>> </wsdl:output>
>> </wsdl:operation>
>> </wsdl:binding>
>>
>> <wsdl:service name="*HelloWorldClient*">
>> <soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:
>> jndiConnectionFactoryName>
>> <soapjms:jndiInitialContextFactory
>> >org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:
>> jndiInitialContextFactory>
>> <wsdl:port binding="*tns:HelloWorldClientSoapBinding*" name="
>> *HelloWorldPort*">
>> <soap:address location="
>> *jms:/jndi:dynamicQueues/helloworldjms.sayHi*" />
>> </wsdl:port>
>> </wsdl:service>
>>
>> <prop:property name="*POUET*" type="*xsd:string*"/>
>> <prop:propertyAlias propertyName="*tns:POUET*" messageType="
>> *tns:sayHi*" part="*parameters*">
>> <prop:query>text</prop:query>
>> </prop:propertyAlias>
>>
>> ...
>>
>> <partnerLinkType
>> name="*IHelloWorldPlt*"
>> xmlns="*http://docs.oasis-open.org/wsbpel/2.0/plnktype
>> <http://docs.oasis-open.org/wsbpel/2.0/plnktype>*">
>> <role name="*IHelloWorldRoleClientRequest*" portType="
>> *client:IHelloWorld*"/>
>> </partnerLinkType>
>>
>> As attachement the complet package (sorry it is configured for my dns),
>> and the main piece of java code to the client & jms sender.
>>
>>
>> From the activeMq interface I can see ODE waiting for messages.
>> When I send messages like :
>>
>>
>>
>>
>>
>>
>>
>> *<?xml version="1.0" encoding="utf-8" ?> <S:Envelope
>> xmlns:S="http://schemas.xmlsoap.org/soap/envelope/
>> <http://schemas.xmlsoap.org/soap/envelope/>"> <S:Body>
>> <ns2:sayHi xmlns:ns2="BonjourLeMonde.orchestrator.gaia.intrinsec.com
>> <http://BonjourLeMonde.orchestrator.gaia.intrinsec.com>">
>> <text>Coucou</text> </ns2:sayHi> </S:Body> </S:Envelope>*
>>
>> Ode receive the message but the intance of the process never start, and
>> there is no errors or warning, all
>> informations looks good to me... but it never start :
>>
>>
>> DEBUG - jms-Worker-3 - JMSMessageReceiver.onMessage(89) | Received new
>> JMS message for service
>> :MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi
>> Destination : queue://helloworldjms.sayHi
>> Message ID : ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
>> Correlation ID : null
>> ReplyTo : queue://helloworldjms.sayHi.replyQueue
>> Redelivery ? : false
>> Priority : 4
>> Expiration : 0
>> Timestamp : 1391622698519
>> Message Type : null
>> Persistent ? : false
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for
>> urn:mediate
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace:
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1758) | Operations
>> aliases map: {
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/IHelloWorld/sayHi=org.apache.axis2.description.InOutAxisOperation@2213f290
>> }
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1767) | Imported
>> namespaces: []
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis
>> operation: null
>> DEBUG - jms-Worker-3 - BuilderUtil.getCharSetEncoding(333) | char set
>> encoding set from default =utf-8
>> DEBUG - jms-Worker-3 - StAXUtils.createXMLStreamReader(207) |
>> XMLStreamReader is
>> org.apache.axiom.util.stax.dialect.WoodstoxStreamReaderWrapper
>> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.constructNode(316) | Starting
>> to process SOAP 1.1 message
>> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build
>> the OMElement Envelope by the StaxSOAPModelBuilder
>> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build
>> the OMElement Body by the StaxSOAPModelBuilder
>> [ ... ]
>> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build
>> the OMElement sayHi by the StaxSOAPModelBuilder
>> DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(71) |
>> Checking for Operation using SOAP message body's first child's local name :
>> sayHi
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for
>> sayHi
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace:
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
>> DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis
>> operation: org.apache.axis2.description.InOutAxisOperation@2213f290
>> DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(77) |
>> Found operation org.apache.axis2.description.InOutAxisOperation@2213f290
>> DEBUG - jms-Worker-3 - ProjectResourceBundle.handleGetObject(70) |
>> org.apache.axis2.i18n.resource::handleGetObject(operationfound)
>> DEBUG - jms-Worker-3 - AbstractDispatcher.invoke(110) | [MessageContext:
>> logID=urn:uuid:7CC27F3856291A52E91391622700744] Found AxisOperation : sayHi
>> [ ... ]
>> DEBUG - jms-Worker-3 - ODEMessageReceiver.invokeBusinessLogic(45) |
>> Received request message for
>> MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi.{
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}sayHi
>> DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(217) |
>> Incoming Transport is JMS, lets check for JMS correlation id
>> DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(221) |
>> Correlation id is ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
>> DEBUG - jms-Worker-3 - WSAEndpoint.toMap(198) | Filled transfo map with
>> service: {
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient
>> DEBUG - jms-Worker-3 - WSAEndpoint.toMap(199) | Filled transfo map with
>> port: HelloWorldPort
>> DEBUG - jms-Worker-3 - Properties$Axis2.translate(141) | Translating
>> Properties for Axis2
>> DEBUG - jms-Worker-3 - OnDemandLogger.debug(85) | messageID is null.
>> DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(106) | Starting
>> transaction.
>> DEBUG - jms-Worker-3 - BpelEngineImpl.route(364) | Routed: svcQname {
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient--> [BpelProcess[{
>> http://deployment.orchestrator.intrinsec.com/process}MYSIMPLE-1],
>> BpelProcess[{
>> http://deployment.orchestrator.intrinsec.com/process}MYBPELJMS-25]]
>> DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(113) | ODE routed
>> to operation null from service {
>> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient
>>
>>
>> The last line is strange, but then ODE's logs continues as if nothing
>> append.
>>
>> Can you help me to find what is going wrong ?
>>
>>
>> best regards,
>> Kévin.
>>
>>
>>
>> *Kevin SEJOURNE*
>>
>> *Ingénieur Recherche et Développement*
>> Standard : +33141917777 l Fax : +33141917778
>>
>> 215, avenue Georges Clemenceau l 92024 Nanterre
>>
>> <http://www.intrinsec.com/>
>> <http://www.intrinsec.com/>
>>
>>
>>
>>
>
Re: Creating instance from jms.
Posted by Sathwik B P <sa...@apache.org>.
On Thu, Feb 6, 2014 at 4:34 AM, Kevin SEJOURNE <Kevin.SEJOURNE@intrinsec.com
> wrote:
> Dear list,
>
> I am trying to use JMS in ODE. My main goal is to create new instances of
> a process from queues or topics.
> For each jms message I want a new instance.
>
> I have setup an activeMq and reconfigure my helloworld process in that way
> :
> <correlationSets>
> <correlationSet name="*PO1*" properties="*bonjourlemonde:POUET*"></
> correlationSet>
> </correlationSets>
>
> <pick createInstance="yes">
> <onMessage partnerLink="*helloWorldPartnerLinkClient*" operation="
> *sayHi*" variable="*sayHiRequest*">
>
> <correlations><correlation set="*PO1*" initiate="yes" /></
> correlations>
> <sequence name="*MainSequence*">
> <assign name="*myInputInitialization*">
> <copy>
> <from>
> ....
>
>
> I have change the wsdl related to *helloWorldPartnerLinkClient* into :
>
> <wsdl:binding name="*HelloWorldClientSoapBinding*" type="
> *tns:IHelloWorld*">
> <soap:binding style="*document*" transport="*http://www.w3.org/2010/soapjms/
> <http://www.w3.org/2010/soapjms/>*" />
> <soapjms:jndiContextParameter name="*name*" value="*value*" />
> <soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:
> jndiConnectionFactoryName>
> <soapjms:jndiInitialContextFactory
> >org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:
> jndiInitialContextFactory>
> <soapjms:jndiURL>tcp://isc-lab-gaia01.isc-lab.lan:19782</soapjms:
> jndiURL>
> <soapjms:deliveryMode>PERSISTENT</soapjms:deliveryMode>
> <wsdl:operation name="*sayHi*">
> <soap:operation soapAction="" style="*document*" />
> <wsdl:input name="*sayHi*">
> <soap:body use="*literal*" />
> </wsdl:input>
> <wsdl:output name="*sayHiResponse*">
> <soap:body use="*literal*" />
> </wsdl:output>
> </wsdl:operation>
> </wsdl:binding>
>
> <wsdl:service name="*HelloWorldClient*">
> <soapjms:jndiConnectionFactoryName>ConnectionFactory</soapjms:
> jndiConnectionFactoryName>
> <soapjms:jndiInitialContextFactory
> >org.apache.activemq.jndi.ActiveMQInitialContextFactory</soapjms:
> jndiInitialContextFactory>
> <wsdl:port binding="*tns:HelloWorldClientSoapBinding*" name="
> *HelloWorldPort*">
> <soap:address location="
> *jms:/jndi:dynamicQueues/helloworldjms.sayHi*" />
> </wsdl:port>
> </wsdl:service>
>
> <prop:property name="*POUET*" type="*xsd:string*"/>
> <prop:propertyAlias propertyName="*tns:POUET*" messageType="
> *tns:sayHi*" part="*parameters*">
> <prop:query>text</prop:query>
> </prop:propertyAlias>
>
> ...
>
> <partnerLinkType
> name="*IHelloWorldPlt*"
> xmlns="*http://docs.oasis-open.org/wsbpel/2.0/plnktype
> <http://docs.oasis-open.org/wsbpel/2.0/plnktype>*">
> <role name="*IHelloWorldRoleClientRequest*" portType="
> *client:IHelloWorld*"/>
> </partnerLinkType>
>
> As attachement the complet package (sorry it is configured for my dns),
> and the main piece of java code to the client & jms sender.
>
>
> From the activeMq interface I can see ODE waiting for messages.
> When I send messages like :
>
>
>
>
>
>
>
> *<?xml version="1.0" encoding="utf-8" ?> <S:Envelope
> xmlns:S="http://schemas.xmlsoap.org/soap/envelope/
> <http://schemas.xmlsoap.org/soap/envelope/>"> <S:Body>
> <ns2:sayHi xmlns:ns2="BonjourLeMonde.orchestrator.gaia.intrinsec.com
> <http://BonjourLeMonde.orchestrator.gaia.intrinsec.com>">
> <text>Coucou</text> </ns2:sayHi> </S:Body> </S:Envelope>*
>
> Ode receive the message but the intance of the process never start, and
> there is no errors or warning, all
> informations looks good to me... but it never start :
>
>
> DEBUG - jms-Worker-3 - JMSMessageReceiver.onMessage(89) | Received new JMS
> message for service
> :MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi
> Destination : queue://helloworldjms.sayHi
> Message ID : ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
> Correlation ID : null
> ReplyTo : queue://helloworldjms.sayHi.replyQueue
> Redelivery ? : false
> Priority : 4
> Expiration : 0
> Timestamp : 1391622698519
> Message Type : null
> Persistent ? : false
> DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for
> urn:mediate
> DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace:
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
> DEBUG - jms-Worker-3 - AxisService.getOperation(1758) | Operations aliases
> map: {
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/IHelloWorld/sayHi=org.apache.axis2.description.InOutAxisOperation@2213f290
> }
> DEBUG - jms-Worker-3 - AxisService.getOperation(1767) | Imported
> namespaces: []
> DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis
> operation: null
> DEBUG - jms-Worker-3 - BuilderUtil.getCharSetEncoding(333) | char set
> encoding set from default =utf-8
> DEBUG - jms-Worker-3 - StAXUtils.createXMLStreamReader(207) |
> XMLStreamReader is
> org.apache.axiom.util.stax.dialect.WoodstoxStreamReaderWrapper
> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.constructNode(316) | Starting
> to process SOAP 1.1 message
> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build
> the OMElement Envelope by the StaxSOAPModelBuilder
> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build
> the OMElement Body by the StaxSOAPModelBuilder
> [ ... ]
> DEBUG - jms-Worker-3 - StAXSOAPModelBuilder.createOMElement(273) | Build
> the OMElement sayHi by the StaxSOAPModelBuilder
> DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(71) |
> Checking for Operation using SOAP message body's first child's local name :
> sayHi
> DEBUG - jms-Worker-3 - AxisService.getOperation(1741) | Get operation for
> sayHi
> DEBUG - jms-Worker-3 - AxisService.getOperation(1750) | Target namespace:
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/
> DEBUG - jms-Worker-3 - AxisService.getOperation(1784) | Found axis
> operation: org.apache.axis2.description.InOutAxisOperation@2213f290
> DEBUG - jms-Worker-3 - ODEAxisOperationDispatcher.findOperation(77) |
> Found operation org.apache.axis2.description.InOutAxisOperation@2213f290
> DEBUG - jms-Worker-3 - ProjectResourceBundle.handleGetObject(70) |
> org.apache.axis2.i18n.resource::handleGetObject(operationfound)
> DEBUG - jms-Worker-3 - AbstractDispatcher.invoke(110) | [MessageContext:
> logID=urn:uuid:7CC27F3856291A52E91391622700744] Found AxisOperation : sayHi
> [ ... ]
> DEBUG - jms-Worker-3 - ODEMessageReceiver.invokeBusinessLogic(45) |
> Received request message for
> MYBPELJMS-25/bpelContent/HelloWorld/MYBPELJMS/jndi:dynamicQueues/helloworldjms.sayHi.{
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}sayHi
> DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(217) |
> Incoming Transport is JMS, lets check for JMS correlation id
> DEBUG - jms-Worker-3 - MessageContextBuilder.handleCorrelationID(221) |
> Correlation id is ID:isc-wks-064-53119-1391622672792-1:1:1:1:52
> DEBUG - jms-Worker-3 - WSAEndpoint.toMap(198) | Filled transfo map with
> service: {
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient
> DEBUG - jms-Worker-3 - WSAEndpoint.toMap(199) | Filled transfo map with
> port: HelloWorldPort
> DEBUG - jms-Worker-3 - Properties$Axis2.translate(141) | Translating
> Properties for Axis2
> DEBUG - jms-Worker-3 - OnDemandLogger.debug(85) | messageID is null.
> DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(106) | Starting
> transaction.
> DEBUG - jms-Worker-3 - BpelEngineImpl.route(364) | Routed: svcQname {
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient--> [BpelProcess[{
> http://deployment.orchestrator.intrinsec.com/process}MYSIMPLE-1],
> BpelProcess[{
> http://deployment.orchestrator.intrinsec.com/process}MYBPELJMS-25]]
> DEBUG - jms-Worker-3 - ODEService.onAxisMessageExchange(113) | ODE routed
> to operation null from service {
> http://BonjourLeMonde.orchestrator.gaia.intrinsec.com/}HelloWorldClient
>
>
> The last line is strange, but then ODE's logs continues as if nothing
> append.
>
> Can you help me to find what is going wrong ?
>
>
> best regards,
> Kévin.
>
>
>
> *Kevin SEJOURNE*
>
> *Ingénieur Recherche et Développement*
> Standard : +33141917777 l Fax : +33141917778
>
> 215, avenue Georges Clemenceau l 92024 Nanterre
>
> <http://www.intrinsec.com/>
> <http://www.intrinsec.com/>
>
>
>
>