On Thu, Feb 6, 2014 at 4:34 AM, Kevin SEJOURNE <[email protected] > 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/> > > > >
