Follow the instructions below to set up and configure WSO2 ESB with HornetQ embedded in a JBoss EAP server. This section describes the steps to install JBoss EAP server and create a message queue within the server. - Download JBoss EAP Server 7.0.0 from JBoss EAP Downloads and run the JBoss EAP installer as described here.
- Execute one of the following commands in command prompt to create a new application user.
- On Windows:
<EAP_HOME>\bin\add-user.bat -a -u 'SampleUser' -p 'SamplePwd1!' -g 'guest' - On Linux/Mac:
<EAP_HOME>/bin/add-user.sh -a -u 'SampleUser' -p 'SamplePwd1!' -g 'guest'
Create a sample queue by editing the <EAP_HOME>/standalone/configuration/standalone-full.xml file. Add the following content within the <hornetq-server> element: | Code Block |
|---|
| <jms-destinations>
<jms-queue name="sampleQueue">
<entry name="queue/test"/>
<entry name="java:jboss/exported/jms/queue/test"/>
</jms-queue>
</jms-destinations> |
- Start the JBoss EAP server by executing one of the following commands in command prompt:
- Acess the management console of the JBoss EAP server using the following URL:
http://127.0.0.1:9990 - Log in to the Management Console using admin as both the username and password. In the Profile menu, click Messaging -> Destinations and you will be able to see the queue you added in Step 4 in the Queues/Topics section.
Now you have configured the JBoss EAP Server. The next section describes how to configure WSO2 ESB to listen and fetch messages from the queue that you created above. - If you have not already done so, download WSO2 ESB and install WSO2 ESBas described in Getting Started.
Enable the JMS listener with the JBoss EAP configuration parameters in the <ESB_HOME>/repository/conf/axis2/axis2.xml file by adding the following lines of code. | Code Block |
|---|
| <transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener">
<parameter name="QueueConnectionFactory" locked="false">
<parameter name="java.naming.factory.initial" locked="false">org.jboss.naming.remote.client.InitialContextFactory</parameter>
<parameter name="java.naming.provider.url" locked="false">remote://localhost:4447</parameter>
<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">jms/RemoteConnectionFactory</parameter>
<parameter name="transport.jms.UserName" locked="false">SampleUser</parameter>
<parameter name="transport.jms.Password" locked="false">SamplePwd1!</parameter>
<parameter name="java.naming.security.principal" locked="false">SampleUser</parameter>
<parameter name="java.naming.security.credentials" locked="false">SamplePwd1!</parameter>
<parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter>
</parameter>
</transportReceiver> |
| Info |
|---|
The username and password created for the guest user in the above section are used in the configuration. |
Enable the JMS sender by uncommenting the following line of code in the <ESB_HOME>/repository/conf/axis2/axis2.xml file. | Code Block |
|---|
| <transportSender name="jms" class="org.apache.axis2.transport.jms.JMSSender"/> |
Now you have configured the ESB's JMS transport with HornetQ embedded in a JBoss EAP server. The next section describes how you can test the configuration. To test the configuration we create a proxy service named JMSPublisher to publish messages from the ESB to the HornetQ sample queue, and create the JMSListener queue to read messages from the HornetQ sample queue. 
- Start the ESB management console. See Running the Product for more information.
Create the JMSPublisher proxy service with the following configuration: | Code Block |
|---|
| <proxy xmlns="http://ws.apache.org/ns/synapse"
name="JMSPublisher"
transports="https,http"
statistics="enable"
trace="enable"
startOnLoad="true">
<target>
<inSequence>
<property name="FORCE_SC_ACCEPTED" value="true" scope="axis2"/>
<property name="Accept-Encoding" scope="transport" action="remove"/>
<property name="Content-Length" scope="transport" action="remove"/>
<property name="Content-Type" scope="transport" action="remove"/>
<property name="User-Agent" scope="transport" action="remove"/>
<property name="OUT_ONLY" value="true"/>
<log level="full"/>
<send>
<endpoint>
<address uri="jms:/jms/queue/test?transport.jms.ConnectionFactoryJNDIName=jms/RemoteConnectionFactory&java.naming.factory.initial=org.jboss.naming.remote.client.InitialContextFactory&java.naming.provider.url=remote://localhost:4447&transport.jms.DestinationType=queue&transport.jms.UserName=SampleUser&transport.jms.Password=SamplePwd1!&java.naming.security.principal=SampleUser&java.naming.security.credentials=SamplePwd1!"/> </endpoint>
</send>
</inSequence>
</target>
<publishWSDL uri="file:repository/samples/resources/proxy/sample_proxy_1.wsdl"/>
<description>HornetQ-WSO2 ESB sample</description>
</proxy> |
| Info |
|---|
| - The proxy service is created for the
SimpleStockQuoteService service shipped with the ESB samples in this example so that the configuration can be tested by sending a request to call one of the operations of the service. - The
OUT_ONLY parameter is set to true since this proxy service is created only for the purpose of publishing the messages of the ESB to the mySampleQueue queue specified in the address URI. - You may have to change the host name, port etc. of the JMS string based on your environment
|
Create the JMSListener proxy service with the following configuration: | Code Block |
|---|
| <proxy xmlns="http://ws.apache.org/ns/synapse"
name="JMSListener"
transports="jms"
statistics="disable"
trace="disable"
startOnLoad="true">
<target>
<inSequence>
<log level="custom">
<property name="JMS LISTENER PROXY" value="LOCATED"/>
</log>
<log level="full"/>
<drop/>
</inSequence>
</target>
<parameter name="transport.jms.ContentType">
<rules>
<jmsProperty>contentType</jmsProperty>
<default>text/plain</default>
</rules>
</parameter>
<parameter name="transport.jms.ConnectionFactory">QueueConnectionFactory</parameter>
<parameter name="transport.jms.Destination">jms/queue/test</parameter>
<description/>
</proxy> |
Use a client application of your choice to send a request to the endpoint of the JMSPublisher proxy service. In this example, the following request is sent using SOAPUI, calling the placeOrder operation of the SimpleStockQuoteService for which the JMSPublisher proxy service is created. | Code Block |
|---|
| <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ser="http://services.samples" xmlns:xsd="http://services.samples/xsd">
<soapenv:Header/>
<soapenv:Body>
<ser:placeOrder>
<!--Optional:-->
<ser:order>
<!--Optional:-->
<xsd:price>20</xsd:price>
<!--Optional:-->
<xsd:quantity>20</xsd:quantity>
<!--Optional:-->
<xsd:symbol>IBM</xsd:symbol>
</ser:order>
</ser:placeOrder>
</soapenv:Body>
</soapenv:Envelope> |
Check the log on your ESB terminal. You will see the following log, which indicates that the request published in the queue is picked by the JMSListener proxy. | Code Block |
|---|
| [<TIME Stamp>] INFO - LogMediator JMS LISTENER PROXY = LOCATED
[<TIME Stamp>] INFO - LogMediator To: , WSAction: "urn:placeOrder", SOAPAction: "urn:placeOrder", MessageID: ID:be08707e-033d-11e4-8307-25263fbb9173, Direction: request, Envelope: <?xml version="1.0" encoding="utf-8"?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><soapenv:Envelope xmlns:xsd="http://services.samples/xsd" xmlns:ser="http://services.samples"><soapenv:Body>
<ser:placeOrder>
<!--Optional:-->
<ser:order>
<!--Optional:-->
<xsd:price>20</xsd:price>
<!--Optional:-->
<xsd:quantity>20</xsd:quantity>
<!--Optional:-->
<xsd:symbol>IBM</xsd:symbol>
</ser:order>
</ser:placeOrder>
</soapenv:Body></soapenv:Envelope></soapenv:Body></soapenv:Envelope> |
|