Hi,
I suspect now the message not sent out from your client side
When you run client, any exception you see?
Maybe you can change your client code slightly like
try {
....
} catch (Exception e) {
//catch all exception and print the stacktrace
e.printStackTrace();
}
And can you use some tool like jconsole to monitor the jms queue you
are using to see if the jms message really sent to that queue?
Freeman
On 2009-8-21, at 下午11:52, lekkie wrote:
While strating servicemix, here is the output from the console:
INFO - ComponentMBeanImpl - Initializing component:
servicemix-xmpp
INFO - ServiceAssemblyLifeCycle - Starting service assembly:
instantissuance-sa
INFO - ServiceUnitLifeCycle - Initializing service unit:
instantissuance-ftpwriter-su
INFO - ServiceUnitLifeCycle - Initializing service unit:
instantissuance-file-consumer-su
Aug 21, 2009 4:49:16 PM org.apache.cxf.endpoint.ServerImpl
initDestination
INFO: Setting the server's publish address to be null
Aug 21, 2009 4:49:16 PM org.apache.cxf.transport.jms.JMSDestination
activate
INFO: JMSServerTransport activate()....
INFO - ServiceUnitLifeCycle - Starting service unit:
instantissuance-ftpwriter-su
INFO - ServiceUnitLifeCycle - Starting service unit:
instantissuance-file-consumer-su
INFO - JBIContainer - ServiceMix JBI Container
(ServiceMix) started
INFO - JDBCAdapterFactory - Database driver recognized:
[apache_derby_embedded_jdbc_driver]
INFO - LogTask - Logging system reconfigured
using
file:
file:/C:/Program%20Files/Apache%20Software%20Foundation/apache-
servicemix-3.3/c
onf/log4j.xml
Client code here:
public final class
InstantIssuanceServicesPortType_InstantIssuanceServicesJmsPort_Client
{
private static final QName MTOM_SERVICE = new
QName("http://services.instantissuance";, "InstantIssuanceServices");
public final static QName MTOM_PORT = new
QName("http://services.instantissuance";,
"InstantIssuanceServicesJmsPort");
private
InstantIssuanceServicesPortType_InstantIssuanceServicesJmsPort_Client
() {
}
public static void main(String args[]) throws Exception {
InstantIssuanceServicesPortType_InstantIssuanceServicesJmsPort_Client
client = new
InstantIssuanceServicesPortType_InstantIssuanceServicesJmsPort_Client
();
client.sendAttachment();
System.exit(0);
}
public void sendAttachment() throws Exception {
try
{
InstantIssuanceServicesPortType mtomPort =
createPort(MTOM_SERVICE,
MTOM_PORT, InstantIssuanceServicesPortType.class, true);
String fileName = "C:\\myfile.html";
File file = new File(fileName);
FileInputStream in = new FileInputStream(file);
int fileSize = 0;
for (int i = in.read(); i != -1; i = in.read())
fileSize++;
int count = 50;
byte[] data = new byte[fileSize * count];
for (int x = 0; x < count; x++)
in.read(data, fileSize * x, fileSize);
System.out.println("Invoking testXop...");
String _testXop_nameVal = "Attachment";
Holder<String> _testXop_name = new
Holder<String>(_testXop_nameVal);
DataHandler _testXop_attachinfoVal = new DataHandler(new
ByteArrayDataSource(data, "application/octet-stream"));;
Holder<DataHandler> _testXop_attachinfo = new
Holder<DataHandler>(_testXop_attachinfoVal);
mtomPort.testXop(_testXop_name, _testXop_attachinfo);
System.out.println("testXop._testXop_name=" +
_testXop_name.value);
System.out.println("testXop._testXop_attachinfo=" +
_testXop_attachinfo.value);
} catch (SOAPFaultException ex) {
Assert.assertTrue("Expect the configuration exception here",
ex.getCause() instanceof
org.apache.cxf.configuration.ConfigurationException);
}
}
private static <T> T createPort(QName serviceName, QName portName,
Class<T> serviceEndpointInterface, boolean enableMTOM) throws
Exception
{
Bus bus = BusFactory.getDefaultBus();
ReflectionServiceFactoryBean serviceFactory = new
JaxWsServiceFactoryBean();
serviceFactory.setBus(bus);
serviceFactory.setServiceName(serviceName);
serviceFactory.setServiceClass(serviceEndpointInterface);
URL url = new URL("file:wsdl/instantIssuanceServices.wsdl");
serviceFactory.setWsdlURL(url);
Service service = serviceFactory.create();
EndpointInfo ei = service.getEndpointInfo(portName);
JaxWsEndpointImpl jaxwsEndpoint = new JaxWsEndpointImpl(bus,
service, ei);
SOAPBinding jaxWsSoapBinding = new
SOAPBindingImpl(ei.getBinding());
jaxWsSoapBinding.setMTOMEnabled(enableMTOM);
jaxwsEndpoint.getBinding().getInInterceptors().add(new
TestMultipartMessageInterceptor());
jaxwsEndpoint.getBinding().getOutInterceptors().add(new
TestAttachmentOutInterceptor());
Client client = new ClientImpl(bus, jaxwsEndpoint);
InvocationHandler ih = new JaxWsClientProxy(client,
jaxwsEndpoint.getJaxwsBinding());
Object obj =
Proxy.newProxyInstance(serviceEndpointInterface.getClassLoader(), new
Class[] {
serviceEndpointInterface, BindingProvider.class }, ih);
return serviceEndpointInterface.cast(obj);
}
}
Thanks.
Freeman Fang wrote:
Hi,
It seems ok.
Do you see any exception when you deploy your SA?
And could you append the complete code of your standalone jms client?
Freeman
On 2009-8-21, at 下午11:15, lekkie wrote:
Here is it:
<wsdl:service name="InstantIssuanceServices">
<wsdl:port name="InstantIssuanceServicesJmsPort"
binding="tns:InstantIssuanceServicesBinding">
<jms:address
destinationStyle="queue"
jndiConnectionFactoryName="ConnectionFactory"
jndiDestinationName="dynamicQueues/person.queue">
<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>
Freeman Fang wrote:
Hi,
What's the service part of your instantIssuanceServices.wsdl?
Freeman
On 2009-8-21, at 下午10:47, lekkie wrote:
Thanks.
See xbean xml below:
<beans xmlns:cxfbc="http://servicemix.apache.org/cxfbc/1.0";
xmlns:instantissuance="http://services.instantissuance";>
<cxfbc:consumer wsdl="classpath:instantIssuanceServices.wsdl"
service="instantissuance:instantIssuanceServices"
targetService="instantissuance:instantissuanceFTPWriter"
mtomEnabled="true"/>
</beans>
kr.
Freeman Fang wrote:
Hi,
Can you post the xbean.xml for your cxf bc consumer?
Seems your cxf bc comsumer not configured correctly with jms
transport, so it can't pick up the soap message from the jms
queue
which your jms client send soap message with attachment to.
Freeman
On 2009-8-21, at 下午4:50, lekkie wrote:
Hi,
I am trying to send an attachement from a client to service cxf-
bc.
Here is suppose to be the flow
client -> cxf-bc concumer -> NMR -> ftp-sender
Here is my client software for sending
InstantIssuanceServicesPortType mtomPort =
createPort(MTOM_SERVICE,
MTOM_PORT, InstantIssuanceServicesPortType.class, true);
String fileName = "C:\\esocketweb_trace.html";
File file = new File(fileName);
FileInputStream in = new FileInputStream(file);
int fileSize = 0;
for (int i = in.read(); i != -1; i = in.read())
fileSize++;
int count = 50;
byte[] data = new byte[fileSize * count];
for (int x = 0; x < count; x++)
in.read(data, fileSize * x, fileSize);
String _testXop_nameVal = "Attachment";
Holder<String> _testXop_name = new
Holder<String>(_testXop_nameVal);
DataHandler _testXop_attachinfoVal = new DataHandler(new
ByteArrayDataSource(data, "application/octet-stream"));;
Holder<DataHandler> _testXop_attachinfo = new
Holder<DataHandler>(_testXop_attachinfoVal);
mtomPort.testXop(_testXop_name, _testXop_attachinfo);
Whenever I send, the send thread is bloeked forever and there is
no
sign of
it getting to servicemix.
Here is my wsdl
<?xml version="1.0" encoding="utf-8"?>
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
<wsdl:definitions name="SOAPBuilders-mime-cr-test"
xmlns:types="http://services.instantissuance/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.instantissuance";
xmlns:jms="http://cxf.apache.org/transports/jms";
xmlns:xmime="http://www.w3.org/2005/05/xmlmime";
targetNamespace="http://services.instantissuance";>
<wsdl:types>
<schema xmlns="http://www.w3.org/2001/XMLSchema";
targetNamespace="http://services.instantissuance/types";
xmlns:xmime="http://www.w3.org/2005/05/xmlmime";
elementFormDefault="qualified">
<complexType name="XopType">
<sequence>
<element name="name" type="xsd:string" />
<element name="attachinfo"
type="xsd:base64Binary"
xmime:expectedContentTypes="application/octet-stream"/>
</sequence>
</complexType>
<complexType name="XopStringType">
<sequence>
<element name="name" type="xsd:string" />
<element name="attachinfo"
type="xsd:base64Binary"
xmime:expectedContentTypes="text/plain; charset=utf-8"/>
</sequence>
</complexType>
<element name="testXop" type="types:XopType" />
<element name="testXopResponse" type="types:XopType" />
<element name="testXopStringArgument"
type="types:XopStringType"/>
<element name="testXopStringResponse"
type="types:XopStringType"/>
</schema>
</wsdl:types>
<wsdl:message name="testXopIn">
<wsdl:part name="data" element="types:testXop"/>
</wsdl:message>
<wsdl:message name="testXopOut">
<wsdl:part name="data" element="types:testXopResponse" />
</wsdl:message>
<wsdl:message name="testXopStringIn">
<wsdl:part name="data"
element="types:testXopStringArgument" />
</wsdl:message>
<wsdl:message name="testXopStringOut">
<wsdl:part name="data"
element="types:testXopStringResponse" />
</wsdl:message>
<wsdl:portType name="InstantIssuanceServicesPortType">
<wsdl:operation name="testXop">
<wsdl:input message="tns:testXopIn"/>
<wsdl:output message="tns:testXopOut"/>
</wsdl:operation>
<wsdl:operation name="testXopString">
<wsdl:input message="tns:testXopStringIn" />
<wsdl:output message="tns:testXopStringOut"/>
</wsdl:operation>
</wsdl:portType>
<wsdl:binding name="InstantIssuanceServicesBinding"
type="tns:InstantIssuanceServicesPortType">
<soap:binding style="document"
transport="http://schemas.xmlsoap.org/soap/http"; />
<wsdl:operation name="testXop">
<soap:operation soapAction="" />
<wsdl:input>
<soap:body use="literal" />
</wsdl:input>
<wsdl:output>
<soap:body use="literal" />
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="testXopString">
<soap:operation soapAction="" />
<wsdl:input>
<soap:body use="literal" />
</wsdl:input>
<wsdl:output>
<soap:body use="literal" />
</wsdl:output>
</wsdl:operation>
</wsdl:binding>
<wsdl:service name="InstantIssuanceServices">
<!--
<wsdl:port name="InstantIssuanceServicesPort"
binding="tns:InstantIssuancesServicesBinding">
<soap:address location="http://localhost:9036/mime-
test" />
</wsdl:port>
-->
<wsdl:port name="InstantIssuanceServicesJmsPort"
binding="tns:InstantIssuanceServicesBinding">
<jms:address
destinationStyle="queue"
jndiConnectionFactoryName="ConnectionFactory"
jndiDestinationName="dynamicQueues/person.queue">
<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:service name="InstantIssuanceServicesProviderService">
<wsdl:port name="InstantIssuanceServicesProviderJmsPort"
binding="tns:InstantIssuanceServicesBinding">
<jms:address
destinationStyle="queue"
jndiConnectionFactoryName="ConnectionFactory"
jndiDestinationName="dynamicQueues/person.queue">
<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>
Kindly help out.
--
View this message in context:
http://www.nabble.com/No-trace-on-servicemix-
tp25075918p25075918.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/No-trace-on-servicemix-
tp25075918p25081259.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/No-trace-on-servicemix-
tp25075918p25081783.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/No-trace-on-servicemix-tp25075918p25082455.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
--
Freeman Fang
------------------------
Open Source SOA: http://fusesource.com
