Page Comparison

Excerpt

hidden	true

How to use JMS transport with WSO2 MB 2.0.0.

Apache AXIS2 support a JMS transport layer in addition to the existing HTTP transport. This allows Web service clients and servers to communicate via JMS queues and topics instead of HTTP connections. Both one-way and synchronous two-way requests are supported.

...

Following java class with its two operations are hosted in Axis2 server as a web service.

Code Block

language	java

/*
*  Copyright (c) 2005-2010, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
*
*  WSO2 Inc. 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.
*/
 
public class MessageReceiveService {
    public void receive(String message) {
        System.out.println("Got the message ==> " + message);
    }
    public String echo(String message) {
        System.out.println("Got the message ==> " + message);
        return message;
    }
}

As WSDL of the service following will be used. Note how JMS bindings are defined. receive operation is an "in only" operation having only input message. But echo is "in-out" operation which is having an output message as well as an input message.

Code Block

language	html/xml

<?xml version="1.0" encoding="UTF-8"?>
<wsdl:definitions xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/" xmlns:ns1="http://org.apache.axis2/xsd" xmlns:ns="http://transport.sample.org" xmlns:wsaw="http://www.w3.org/2006/05/addressing/wsdl" xmlns:http="http://schemas.xmlsoap.org/wsdl/http/" xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:mime="http://schemas.xmlsoap.org/wsdl/mime/" xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/" xmlns:soap12="http://schemas.xmlsoap.org/wsdl/soap12/" targetNamespace="http://transport.sample.org">
    <wsdl:types>
        <xs:schema attributeFormDefault="qualified" elementFormDefault="unqualified" targetNamespace="http://transport.sample.org">
            <xs:element name="receive">
                <xs:complexType>
                    <xs:sequence>
                        <xs:element minOccurs="0" name="message" nillable="true" type="xs:string"/>
                    </xs:sequence>
                </xs:complexType>
            </xs:element>
            <xs:element name="echo">
                <xs:complexType>
                    <xs:sequence>
                        <xs:element minOccurs="0" name="message" nillable="true" type="xs:string"/>
                    </xs:sequence>
                </xs:complexType>
            </xs:element>
            <xs:element name="echoResponse">
                <xs:complexType>
                    <xs:sequence>
                        <xs:element minOccurs="0" name="return" nillable="true" type="xs:string"/>
                    </xs:sequence>
                </xs:complexType>
            </xs:element>
        </xs:schema>
    </wsdl:types>
    <wsdl:message name="echoRequest">
        <wsdl:part name="parameters" element="ns:echo"/>
    </wsdl:message>
    <wsdl:message name="echoResponse">
        <wsdl:part name="parameters" element="ns:echoResponse"/>
    </wsdl:message>
    <wsdl:message name="receiveRequest">
        <wsdl:part name="parameters" element="ns:receive"/>
    </wsdl:message>
    <wsdl:portType name="MessageReceiveServicePortType">
        <wsdl:operation name="echo">
            <wsdl:input message="ns:echoRequest" wsaw:Action="urn:echo"/>
            <wsdl:output message="ns:echoResponse" wsaw:Action="urn:echoResponse"/>
        </wsdl:operation>
        <wsdl:operation name="receive">
            <wsdl:input message="ns:receiveRequest" wsaw:Action="urn:receive"/>
        </wsdl:operation>
    </wsdl:portType>
    <wsdl:binding name="MessageReceiveServiceSoap11Binding" type="ns:MessageReceiveServicePortType">
        <soap:binding transport="http://schemas.xmlsoap.org/soap/http" style="document"/>
        <wsdl:operation name="echo">
            <soap:operation soapAction="urn:echo" style="document"/>
            <wsdl:input>
                <soap:body use="literal"/>
            </wsdl:input>
            <wsdl:output>
                <soap:body use="literal"/>
            </wsdl:output>
        </wsdl:operation>
        <wsdl:operation name="receive">
            <soap:operation soapAction="urn:receive" style="document"/>
            <wsdl:input>
                <soap:body use="literal"/>
            </wsdl:input>
        </wsdl:operation>
    </wsdl:binding>
    <wsdl:binding name="MessageReceiveServiceSoap12Binding" type="ns:MessageReceiveServicePortType">
        <soap12:binding transport="http://schemas.xmlsoap.org/soap/http" style="document"/>
        <wsdl:operation name="echo">
            <soap12:operation soapAction="urn:echo" style="document"/>
            <wsdl:input>
                <soap12:body use="literal"/>
            </wsdl:input>
            <wsdl:output>
                <soap12:body use="literal"/>
            </wsdl:output>
        </wsdl:operation>
        <wsdl:operation name="receive">
            <soap12:operation soapAction="urn:receive" style="document"/>
            <wsdl:input>
                <soap12:body use="literal"/>
            </wsdl:input>
        </wsdl:operation>
    </wsdl:binding>
    <wsdl:service name="MessageReceiveService">
        <wsdl:port name="MessageReceiveServiceJmsSoap11Endpoint" binding="ns:MessageReceiveServiceSoap11Binding">
            <soap:address location="jms:/MessageReceiveService?transport.jms.DestinationType=queue&amp;transport.jms.ContentTypeProperty=Content-Type&amp;java.naming.provider.url=conf/jndi.properties&amp;java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory&amp;transport.jms.ConnectionFactoryType=queue&amp;transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory"/>
        </wsdl:port>
        <wsdl:port name="MessageReceiveServiceJmsSoap12Endpoint" binding="ns:MessageReceiveServiceSoap12Binding">
            <soap12:address location="jms:/MessageReceiveService?transport.jms.DestinationType=queue&amp;transport.jms.ContentTypeProperty=Content-Type&amp;java.naming.provider.url=conf/jndi.properties&amp;java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory&amp;transport.jms.ConnectionFactoryType=queue&amp;transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory"/>
        </wsdl:port>
    </wsdl:service>
</wsdl:definitions>

Axi2 Configurations

axi2.xml file, which configures the axis2 server on which above service is hosted, should be enabled with JMS transport.

...

Code Block

language	html/xml

<transportSender name="jms" class="org.apache.axis2.transport.jms.JMSSender"/>

...

Message Broker Bindings

conf/jndi.properties file is having all JMS bindings (Queue/QueueConnectionFactory) mentioned above.

Code Block

language	java

connectionfactory.QueueConnectionFactory=amqp://admin:admin@clientid/carbon?brokerlist='tcp://localhost:5672'
queue.MessageReceiveService=MessageReceiveService

Note that WSO2 Message Broker should be running at localhost port 5672 as per this sample.

Start Axis2 Server

Axis2 server is started with above configurations, hosting the above serviceabove MessageReceiveService service.

Code Block

language	java

private AxisServer axisServer;
public void start(){
	try {
	    ConfigurationContext configurationContext =
		    ConfigurationContextFactory.createConfigurationContextFromFileSystem(null,"conf/axis2.xml");
	    this.axisServer = new AxisServer();
	    this.axisServer.setConfigurationContext(configurationContext);
	    this.axisServer.deployService(MessageReceiveService.class.getName());
	    try {
		Thread.sleep(2000);
	    } catch (InterruptedException e) {
	    }
	} catch (AxisFault axisFault) {
	    axisFault.printStackTrace();
	} catch (Exception e) {
	    e.printStackTrace();
	}
}

Send a message to MessageReceiveService service

Now using axis2_client.xml as the config file a ConfigurationContext can be created and a message can be sent to the service. Note that fist "in-only" message is sent and then "in-out" message is sent. Client stub is generated from the above WSDL using WSDL-To-Java tool (when complied using build.xml at <MB_HOME>/Samples/jmstransport using ant this will be done).

Using WSO2 MB management console you can see how MessageReceiveService queue is created. See Message Broker Queues - User Guide for more information.

Code Block

language	java

public void sendMessage(){
	try {

	    ConfigurationContext configurationContext =
		    ConfigurationContextFactory.createConfigurationContextFromFileSystem(null, "conf/axis2_client.xml");
	    MessageReceiveServiceStub stub = new MessageReceiveServiceStub(configurationContext,"http://localhost:8080/axis2/services/MessageReceiveService.MessageReceiveServiceHttpSoap11Endpoint/");
	    //first send the inonly message
	    stub.receive("Test message to receive ");
	    // inout message
	    String response = stub.echo("Test message to echo");
	    System.out.println("Response ==> " + response);

	    try {
		Thread.sleep(10000);
	    } catch (InterruptedException e) {
		e.printStackTrace();
	    }
	} catch (AxisFault axisFault) {
	    axisFault.printStackTrace();
	} catch (java.rmi.RemoteException e) {
	    e.printStackTrace();
	}
}

The complete sample code demonstrating the scenario will be as follows.

Code Block

language	java

/*
*  Copyright (c) 2005-2010, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
*
*  WSO2 Inc. 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.
*/

import org.apache.axis2.AxisFault;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
import org.apache.axis2.engine.AxisServer;
import org.sample.transport.stub.MessageReceiveServiceStub;

public class JMSTransportClient {
    private AxisServer axisServer;
    public void start(){
        try {
            ConfigurationContext configurationContext =
                    ConfigurationContextFactory.createConfigurationContextFromFileSystem(null,"conf/axis2.xml");
            this.axisServer = new AxisServer();
            this.axisServer.setConfigurationContext(configurationContext);
            this.axisServer.deployService(MessageReceiveService.class.getName());
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
            }
        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public void stop(){
        try {
            this.axisServer.stop();
        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        }
    }
    public void sendMessage(){
        try {

            ConfigurationContext configurationContext =
                    ConfigurationContextFactory.createConfigurationContextFromFileSystem(null, "conf/axis2_client.xml");
            MessageReceiveServiceStub stub = new                    MessageReceiveServiceStub(configurationContext,"http://localhost:8080/axis2/services/MessageReceiveService.MessageReceiveServiceHttpSoap11Endpoint/");
            //first send the inonly message
            stub.receive("Test message to receive ");
            // inout message
            String response = stub.echo("Test message to echo");
            System.out.println("Response ==> " + response);

            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        } catch (java.rmi.RemoteException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        
        JMSTransportClient jmsTransportClient = new JMSTransportClient();
        jmsTransportClient.start();
        jmsTransportClient.sendMessage();
        jmsTransportClient.stop();
    }

}

Versions Compared

Old Version 3

New Version Current

Key

Axi2 Configurations

Message Broker Bindings

Start Axis2 Server

Send a message to MessageReceiveService service