Thanks. I got this to work but got into another trouble.
I followed the wsdl and edited as apt. Here is my own wsdl: <wsdl:definitions name="isServices" xmlns:types="http://services.is/types"; xmlns:xsd="http://www.w3.org/2001/XMLSchema"; xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"; xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"; xmlns:tns="http://services.is"; xmlns:jms="http://cxf.apache.org/transports/jms"; xmlns:xmime="http://www.w3.org/2005/05/xmlmime"; targetNamespace="http://services.is";> <wsdl:types> <schema xmlns="http://www.w3.org/2001/XMLSchema"; targetNamespace="http://services.is/types"; xmlns:xmime="http://www.w3.org/2005/05/xmlmime"; elementFormDefault="qualified"> <complexType name="isBinary"> <sequence> <element name="name" type="xsd:string" /> <element name="attachinfo" type="xsd:base64Binary" xmime:expectedContentTypes="application/octet-stream"/> </sequence> </complexType> <element name="isBinary" type="types:isBinaryType"/> </schema> </wsdl:types> <wsdl:message name="sendAttachmentRequest"> <wsdl:part name="data" element="types:isBinary"/> </wsdl:message> <wsdl:portType name="isServicesPortType"> <wsdl:operation name="sendAttachment"> <wsdl:input message="tns:sendAttachmentRequest"/> </wsdl:operation> </wsdl:portType> <wsdl:binding name="isServicesBinding" type="tns:isServicesPortType"> <soap:binding style="document" transport="http://schemas.xmlsoap.org/soap/http"; /> <wsdl:operation name="sendAttachment"> <soap:operation soapAction="http://services.is/sendAttachment"; /> <wsdl:input> <soap:body use="literal" /> </wsdl:input> </wsdl:operation> </wsdl:binding> <wsdl:service name="isServices"> <wsdl:port name="isServicesJmsPort" binding="tns:isServicesBinding"> <jms:address destinationStyle="queue" jndiConnectionFactoryName="ConnectionFactory" jndiDestinationName="dynamicQueues/i.s"> <jms:JMSNamingProperty name="java.naming.factory.initial" value="org.apache.activemq.jndi.ActiveMQInitialContextFactory"/> <jms:JMSNamingProperty name="java.naming.provider.url" value="tcp://localhost:61616"/> </jms:address> <jms:client messageType="byte"/> </wsdl:port> </wsdl:service> </wsdl:definitions> Here is my xbean for the JMS consumer: <beans xmlns:cxfbc="http://servicemix.apache.org/cxfbc/1.0"; xmlns:is="http://services.is";> <cxfbc:consumer wsdl="classpath:isServices.wsdl" service="is:isServices" targetService="is:isFTPWriter" mtomEnabled="true"/> </beans> Here is the xbean for the target service which I guess is an in-only MEP: <beans xmlns:ftp="http://servicemix.apache.org/ftp/1.0"; xmlns:is="http://services.is";> <bean id="myMarshaler" class="org.apache.servicemix.components.util.BinaryFileMarshaler"/> <ftp:sender service="is:isFTPWriter" endpoint="isFTPWriter" uri="ftp://is:i...@localhost/"; overwrite="true" uploadSuffix=".dat" marshaler="#myMarshaler"> </ftp:sender> </beans> The project is suppose to achieve the flow below: JMS producer -> JMS Consumer -> NMR -> FTPWriter where JMS producer is the java client code to send binary files Here is the java client code for sending an attachment to the jms consumer String fileName = "file.dat"; byte[] payload = getBytesFromFile(fileName); String dest = "dynamicQueues/i.s"; Properties env = new Properties(); if (System.getProperty("java.naming.provider.url") == null) env.put("java.naming.provider.url", "tcp://localhost:61616"); if (System.getProperty("java.naming.factory.initial") == null) env.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); InitialContext ic = new InitialContext(env); ConnectionFactory confac = (ConnectionFactory) ic.lookup("ConnectionFactory"); Connection connection = confac.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer producer = session.createProducer((Destination) ic.lookup(dest)); BytesMessage bm = session.createBytesMessage(); bm.writeBytes(payload); producer.send(bm); connection.close(); However I end up with this exception Aug 5, 2009 11:35:21 AM org.apache.cxf.transport.jms.JMSDestination$JMSExecutor run INFO: run the incoming message in the threadpool Aug 5, 2009 11:35:21 AM org.apache.cxf.phase.PhaseInterceptorChain doIntercept INFO: Interceptor has thrown exception, unwinding now org.apache.cxf.binding.soap.SoapFault: No namespace on "FRAMESET" element.at org.apache.cxf.binding.soap.interceptor.ReadHeadersInterceptor.handle Message(ReadHeadersInterceptor.java:86) at org.apache.cxf.binding.soap.interceptor.ReadHeadersInterceptor.handle Message(ReadHeadersInterceptor.java:54) at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseIntercept orChain.java:220) at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainIniti ationObserver.java:78) at org.apache.cxf.transport.jms.JMSDestination.incoming(JMSDestination.j ava:209) at org.apache.cxf.transport.jms.JMSDestination$JMSExecutor.run(JMSDestin ation.java:352) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec utor.java:650) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:675) at java.lang.Thread.run(Thread.java:595) Aug 5, 2009 11:35:21 AM org.apache.cxf.phase.PhaseInterceptorChain doIntercept INFO: Interceptor has thrown exception, unwinding now java.lang.UnsupportedOperationException: A destination must be specified. at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProdu cer.java:195) at org.apache.activemq.ActiveMQQueueSender.send(ActiveMQQueueSender.java :133) at org.apache.cxf.transport.jms.JMSDestination$JMSOutputStream.sendRespo nse(JMSDestination.java:528) at org.apache.cxf.transport.jms.JMSDestination$JMSOutputStream.commitOut putMessage(JMSDestination.java:473) at org.apache.cxf.transport.jms.JMSDestination$JMSOutputStream.doClose(J MSDestination.java:547) at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:16 7) at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:6 6) at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndi ngInterceptor.handleMessage(MessageSenderInterceptor.java:62) at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseIntercept orChain.java:220) at org.apache.cxf.interceptor.AbstractFaultChainInitiatorObserver.onMess age(AbstractFaultChainInitiatorObserver.java:96) at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseIntercept orChain.java:260) at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainIniti ationObserver.java:78) at org.apache.cxf.transport.jms.JMSDestination.incoming(JMSDestination.j ava:209) at org.apache.cxf.transport.jms.JMSDestination$JMSExecutor.run(JMSDestin ation.java:352) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec utor.java:650) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:675) at java.lang.Thread.run(Thread.java:595) Freeman Fang wrote: > > Hi, > > A couple of issues in your wsdl > 1. The jms namespace in your wsdl isn't valid for cxf, it should be > http://cxf.apache.org/transports/jms > instead, > 2. Also, the binding part in your wsdl is incorrect, it should use > soap binding, but not jms binding, jms is transport, not binding. > 3. To use mtom, your wsdl should define element with something like > xmime:expectedContentTypes="application/octet-stream" > 4. And the jms:address in your port part is incorrect. > > We have an wsdl example[1] how the wsdl should look like when use soap > binding over jms transport with mtom enabled, and a testcase[2] > which use this wsdl and in this testcase there's a cxf bc consumer > using mtom/soap/jms, I guess you may need take a look at those example. > > [1]https://svn.apache.org/repos/asf/servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/resources/org/apache/servicemix/cxfbc/mtom_xop.wsdl > [2]https://svn.apache.org/repos/asf/servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcHttpJmsBridgeMtomTest.java > > Freeman > On 2009-8-4, at 下午8:17, lekkie wrote: > >> >> Hi Freeman, >> >> After following your advice, I got this far. >> >> Here is the exception thrown during deployment of my sa: >> >> Caused by: org.apache.cxf.endpoint.EndpointException >> >> at >> org.apache.cxf.endpoint.EndpointImpl.createBinding(EndpointImpl.java: >> 132) >> >> at org.apache.cxf.endpoint.EndpointImpl.<init>(EndpointImpl.java:81) >> >> at >> org >> .apache.servicemix.cxfbc.CxfBcConsumer.validate(CxfBcConsumer.java: >> 402) >> >> ... 13 more >> >> Caused by: org.apache.cxf.BusException: No binding factory for >> namespace >> http://schemas.sun.com/jbi/wsdl-extensions/jms/ registered. >> >> at >> org >> .apache >> .cxf >> .binding >> .BindingFactoryManagerImpl >> .getBindingFactory(BindingFactoryManagerImpl.java:91) >> >> at >> org.apache.cxf.endpoint.EndpointImpl.createBinding(EndpointImpl.java: >> 129) >> >> ... 15 more >> >> >> >> Here is the content of my wsdl >> >> <?xml version="1.0" encoding="UTF-8"?> >> <definitions name="isJMSConsumer" targetNamespace="http://services.is"; >> xmlns="http://schemas.xmlsoap.org/wsdl/"; >> xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"; >> xmlns:xsd="http://www.w3.org/2001/XMLSchema"; >> xmlns:tns="http://services.is"; >> xmlns:plnk="http://docs.oasis-open.org/wsbpel/2.0/plnktype"; >> xmlns:jms="http://schemas.sun.com/jbi/wsdl-extensions/jms/";> >> <types/> >> <message name="isJMSConsumerOperationRequest"> >> <part name="part1" type="xsd:base64Binary"/> >> </message> >> <portType name="isJMSConsumerPortType"> >> <operation name="isJMSConsumerOperation"> >> <input name="input1" >> message="tns:isJMSConsumerOperationRequest"/> >> </operation> >> </portType> >> <binding name="isJMSConsumerBinding" >> type="tns:isJMSConsumerPortType"> >> <jms:binding/> >> <operation name="isJMSConsumerOperation"> >> <jms:operation destination="Queue/A" >> destinationType="Queue"/> >> <input name="input1"> >> <jms:message messageType="BytesMessage" >> bytesPart="part1" >> forwardAsAttachment="true"/> >> </input> >> </operation> >> </binding> >> <service name="isJMSConsumerService"> >> <port name="isJMSConsumerPort" >> binding="tns:isJMSConsumerBinding"> >> <jms:address connectionURL="mq://localhost:7676"/> >> </port> >> </service> >> <plnk:partnerLinkType name="isJMSConsumer"> >> <plnk:role name="isJMSConsumerPortTypeRole" >> portType="tns:isJMSConsumerPortType"/> >> </plnk:partnerLinkType> >> </definitions> >> >> >> and here is my xbean.xml >> >> <beans xmlns:cxfbc="http://servicemix.apache.org/cxfbc/1.0"; >> xmlns:is="http://services.is";> >> >> <!-- wsdlResource="classpath:isFileConsumer.wsdl" --> >> >> <cxfbc:consumer wsdl="classpath:isJMSConsumer.wsdl" >> service="is:isJMSConsumerService" >> targetService="is:isFTPWriter" >> mtomEnabled="true"/> >> </beans> >> >> >> thanks. >> >> >> >> Freeman Fang wrote: >>> >>> Hi, >>> >>> If you want to send attachment over soap with jms transport, could >>> you >>> consider to use the cxf bc component with mtom over jms transport? >>> Freeman >>> >>> On 2009-8-3, at 下午8:02, lekkie wrote: >>> >>>> >>>> >>>> Hi Guys, >>>> >>>> While trying to create a WSDL for my consumer JMS BC on servicemix I >>>> got the >>>> following error >>>> >>>> <loc-message>WSDL is not WS-I BP compliant: [binding >>>> "{http://services.is}isJMSFileConsumerInBinding"; : Basic Profile >>>> Violation >>>> #R2401: A wsdl:binding element in a DESCRIPTION MUST use WSDL SOAP >>>> Binding >>>> as defined in WSDL 1.1 Section 3.]</loc-message> >>>> <stack-trace><![CDATA[javax.jbi.management.DeploymentException: WSDL >>>> is not >>>> WS-I BP compliant: [binding "{http:// >>>> services.is}isJMSFileConsumerInBinding" >>>> : Basic Profile Violation #R2401: A wsdl:binding element in a >>>> DESCRIPTION >>>> MUST use WSDL SOAP Binding as defined in WSDL 1.1 Section 3.] >>>> >>>> at >>>> org >>>> .apache >>>> .servicemix >>>> .jms >>>> .endpoints >>>> .JmsSoapConsumerEndpoint.validateWsdl1(JmsSoapConsumerEndpoint.java: >>>> 198) >>>> >>>> at >>>> org >>>> .apache >>>> .servicemix >>>> .jms >>>> .endpoints >>>> .JmsSoapConsumerEndpoint.validate(JmsSoapConsumerEndpoint.java:138) >>>> >>>> While the exception is in itself self explanatory, I ws wondering >>>> what the >>>> best way it is to generate a WSDL. >>>> >>>> Here is the WSDL I generated from Netbeans wizard: >>>> >>>> <?xml version="1.0" encoding="UTF-8"?> >>>> <definitions name="isJMSFileConsumer" >>>> targetNamespace="http://services.is >>>> " >>>> xmlns="http://schemas.xmlsoap.org/wsdl/"; >>>> xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"; >>>> xmlns:xsd="http://www.w3.org/2001/XMLSchema"; >>>> xmlns:tns="http://services.is"; >>>> xmlns:plnk="http://docs.oasis-open.org/wsbpel/2.0/plnktype"; >>>> xmlns:jms="http://schemas.sun.com/jbi/wsdl-extensions/jms/";> >>>> <types/> >>>> <message name="isJMSFileConsumerInOperationRequest"> >>>> <part name="part1" type="xsd:base64Binary"/> >>>> </message> >>>> <portType name="isJMSFileConsumerInPortType"> >>>> <operation name="isJMSFileConsumerInOperation"> >>>> <input name="input1" >>>> message="tns:isJMSFileConsumerInOperationRequest"/> >>>> </operation> >>>> </portType> >>>> <binding name="isJMSFileConsumerInBinding" >>>> type="tns:isJMSFileConsumerInPortType"> >>>> <jms:binding/> >>>> <operation name="isJMSFileConsumerInOperation"> >>>> <jms:operation destination="DefaultQueue" >>>> destinationType="Queue"/> >>>> <input name="input1"> >>>> <jms:message messageType="BytesMessage" >>>> bytesPart="part1"/> >>>> </input> >>>> </operation> >>>> </binding> >>>> <service name="isJMSFileConsumerIn"> >>>> <port name="isJMSFileConsumerInPortType" >>>> binding="tns:isJMSFileConsumerInBinding"> >>>> <jms:address connectionURL="mq://localhost:61616"/> >>>> </port> >>>> </service> >>>> <plnk:partnerLinkType name="isJMSFileConsumer"> >>>> <!-- A partner link type is automatically generated when a >>>> new port >>>> type is added. Partner link types are used by BPEL processes. >>>> In a BPEL process, a partner link represents the interaction between >>>> the >>>> BPEL process and a partner service. Each partner link is associated >>>> with a >>>> partner link type. >>>> A partner link type characterizes the conversational relationship >>>> between >>>> two services. The partner link type can have one or two roles.--> >>>> <plnk:role name="isJMSFileConsumerInPortTypeRole" >>>> portType="tns:isJMSFileConsumerInPortType"/> >>>> </plnk:partnerLinkType> >>>> </definitions> >>>> >>>> >>>> >>>> And here is the xbean.xml for this service unit >>>> >>>> <beans xmlns:jms="http://servicemix.apache.org/jms/1.0"; >>>> xmlns:is="http://services.is"; >>>> xmlns:amqpool="http://jencks.org/amqpool/2.0";> >>>> >>>> >>>> <classpath> >>>> <location>.</location> >>>> </classpath> >>>> >>>> <bean id="connectionFactory" >>>> class="org.apache.activemq.pool.PooledConnectionFactory"> >>>> >>>> <property name="connectionFactory"> >>>> <bean >>>> class="org.apache.activemq.ActiveMQConnectionFactory"> >>>> <property name="brokerURL" value="tcp://localhost: >>>> 61616" /> >>>> </bean> >>>> </property> >>>> >>>> <!--Configure maximum connections used by the pool --> >>>> <property name="maxConnections" value="10" /> >>>> >>>> <!--Configure maximum sessions per connection --> >>>> <property name="maximumActive" value="10" /> >>>> </bean> >>>> >>>> <!-- add the sender endpoint here --> >>>> <bean id="myMarshaler" >>>> class="org.apache.servicemix.components.util.BinaryFileMarshaler"/> >>>> >>>> <jms:soap-consumer service="is:isJMSFileConsumer" >>>> endpoint="isJMSFileConsumer" >>>> wsdl="classpath:isJMSFileConsumer.wsdl" >>>> validateWsdl="true" >>>> targetService="is:isFTPWriter" >>>> destinationName="queue/A/Soap" >>>> connectionFactory="#connectionFactory"/> >>>> </beans> >>>> >>>> What is the best way to generate a WSDL for a binary message >>>> (attachment) >>>> through JMS BC over SOAP? >>>> >>>> kr. >>>> -- >>>> View this message in context: >>>> http://www.nabble.com/Binary-Message-WSDL-for-JMS-BC-%28Consumer%29-tp24789561p24789561.html >>>> Sent from the ServiceMix - User mailing list archive at Nabble.com. >>>> >>> >>> >>> -- >>> Freeman Fang >>> ------------------------ >>> Open Source SOA: http://fusesource.com >>> >>> >>> >> >> -- >> View this message in context: >> http://www.nabble.com/Binary-Message-WSDL-for-JMS-BC-%28Consumer%29-tp24789561p24807302.html >> Sent from the ServiceMix - User mailing list archive at Nabble.com. >> > > > -- > Freeman Fang > ------------------------ > Open Source SOA: http://fusesource.com > > > -- View this message in context: http://www.nabble.com/Binary-Message-WSDL-for-JMS-BC-%28Consumer%29-tp24789561p24824802.html Sent from the ServiceMix - User mailing list archive at Nabble.com.
