Flex jms client with OC4J Queue ( blazeds)

In this blog I will show what you have to do to send and receive jms text messages in flex. For this I use the embedded container of jdeveloper 10.1.3.3 with the blazeds libraries and the blazeds configuration xml files( this is very easy, how to do this see this blog). I also use the j2ee container of jdeveloper 10.1.3.3 so I can use the jms queues and do the rmi jndi lookup. First we create a queue in the oc4j container. I will do it manually by editing the jms.xml in the j2ee\home\config folder. Here we add a queue and a queue connection factory.
<queue name="MyJMSQueue" location="jms/MyJMSQueue">
<queue-connection-factory location="jms/MyJMSQCF"/>
Now you can start the j2ee server and use this java code to test the queue. You have to add a lot of oc4j libraries (located in j2ee\home\ ) to get rmi jndi lookup standalone working.

package jms2;

import java.sql.Timestamp;
import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;

import javax.naming.Context;
import javax.naming.InitialContext;


public class jmsclientoc4j {

    private QueueConnection         connection  = null;
    private QueueSession            session     = null;
    private QueueSender             sender      = null;
    private QueueReceiver           receiver    = null;
    private Queue                   queue       = null;
    private long                    waitTime    = 0;

    public jmsclientoc4j() {

    }

    public static void main(String[] args) {
        new jmsclientoc4j().execute();
    }
    
    public void tearDown() {
        try {
            sender.close(); 
            receiver.close(); 
            session.close(); 
            connection.close();

        } catch (JMSException je) {
            je.printStackTrace();
        } finally {
        }
    }


    public void execute() {
        setUp();
        put();
        get(); 
        tearDown();
    }


    public void get(){

                try {
                    javax.jms.TextMessage textMessage = (javax.jms.TextMessage)receiver.receive();
                    System.out.println("Receiving message [" + textMessage.getJMSMessageID() + "] enqueued at " + new Timestamp(textMessage.getJMSTimestamp()).toString());
                    String xmlText = textMessage.getText();
                    System.out.println(xmlText);
                } catch (JMSException jmse) {
                    jmse.printStackTrace();
                }
    }

    public void put(){

        String messageId = null;
        String xmlData = "1111";
        try {
              TextMessage message = session.createTextMessage(xmlData);
              sender.send(message);
             } catch (JMSException jmse) {
                 jmse.printStackTrace();
             }
    }

    protected void setUp() {

        //  Haal instellingen voor de verbinding op
        String queueName = "jms/MyJMSQueue";
        String queueConnectionFactoryName = "jms/MyJMSQCF";
        Context ctx;

        try {
            Properties parm = new Properties();
            parm.setProperty("java.naming.factory.initial","com.evermind.server.rmi.RMIInitialContextFactory");
            parm.setProperty("java.naming.provider.url","ormi://localhost:23791/");
            parm.setProperty("java.naming.security.principal","oc4jadmin");
            parm.setProperty("java.naming.security.credentials","welcome");

            ctx = new InitialContext(parm);

            QueueConnectionFactory connectionFactory = 
            (QueueConnectionFactory)ctx.lookup(queueConnectionFactoryName);

            connection = connectionFactory.createQueueConnection();        
            connection.start();        
            session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);          
            queue = (Queue)ctx.lookup(queueName); 
            sender   = session.createSender(queue); 
            receiver = session.createReceiver(queue); 


        } catch (JMSException je) {
            throw new RuntimeException("Fout opgetreden bij het starten ", 
                                       je);
        } catch (Throwable t) {
            throw new RuntimeException("Fout opgetreden bij het starten ", 
                                       t);
                                       
        }
    }
}

Here are the blazeds configurations files, these files are located in public_html/WEB-INF/flex/. For jms we need services-config.xml for the channel defitions. You can define two jms channels one for streaming, this mean blazeds is continually connected to the queue, the other polls the queue every few seconds.
The second blazeds configuration xml is the messaging-config.xml file. In this file we define the jms adapter.
here is the service-config.xml
<br /><?xml version="1.0" encoding="UTF-8"?><br /><services-config><br /> <services><br /> <service-include file-path="messaging-config.xml"/><br /> <default-channels><br /> <channel ref="my-amf"/><br /> </default-channels><br /> </services><br /><br /> <channels><br /> <channel-definition id="my-streaming-amf" class="mx.messaging.channels.StreamingAMFChannel"><br /> <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/streamingamf" class="flex.messaging.endpoints.StreamingAMFEndpoint"/><br /> </channel-definition><br /> <channel-definition id="my-polling-amf" class="mx.messaging.channels.AMFChannel"><br /> <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amfpolling" class="flex.messaging.endpoints.AMFEndpoint"/><br /> <properties><br /> <polling-enabled>true</polling-enabled><br /> <polling-interval-seconds>4</polling-interval-seconds><br /> </properties><br /> </channel-definition><br /> </channels><br /><br /> <logging><br /> <target class="flex.messaging.log.ConsoleTarget" level="Debug"><br /> <properties><br /> <prefix>[Flex] </prefix><br /> <includeDate>false</includeDate><br /> <includeTime>false</includeTime><br /> <includeLevel>false</includeLevel><br /> <includeCategory>false</includeCategory><br /> </properties><br /> </target><br /> </logging><br /></services-config><br />
Here is messaging-config.xml with the jms configuration
<br /><?xml version="1.0" encoding="UTF-8"?><br /><service id="message-service" class="flex.messaging.services.MessageService"><br /> <adapters><br /> <adapter-definition id="jms" class="flex.messaging.services.messaging.adapters.JMSAdapter"/><br /> </adapters><br /> <br /> <destination id="jms-feed"><br /> <adapter ref="jms"/><br /> <properties><br /> <jms><br /> <destination-type>queue</destination-type><br /> <message-type>javax.jms.TextMessage</message-type><br /> <connection-factory>jms/MyJMSQCF</connection-factory><br /> <destination-jndi-name>jms/MyJMSQueue</destination-jndi-name><br /> <delivery-mode>PERSISTENT</delivery-mode><br /> <message-priority>9</message-priority><br /> <preserve-jms-headers>"true"</preserve-jms-headers><br /> <acknowledge-mode>AUTO_ACKNOWLEDGE</acknowledge-mode><br /> <max-producers>1</max-producers><br /> <initial-context-environment><br /> <property><br /> <name>Context.SECURITY_PRINCIPAL</name><br /> <value>oc4jadmin</value><br /> </property><br /> <property><br /> <name>Context.SECURITY_CREDENTIALS</name><br /> <value>welcome</value><br /> </property><br /> <property><br /> <name>Context.PROVIDER_URL</name><br /> <value>ormi://localhost:23791/</value><br /> </property><br /> <property><br /> <name>Context.INITIAL_CONTEXT_FACTORY</name><br /> <value>com.evermind.server.rmi.RMIInitialContextFactory</value><br /> </property><br /> </initial-context-environment><br /> </jms><br /> <network><br /> <session-timeout>0</session-timeout><br /> <throttle-inbound policy="ERROR" max-frequency="50"/><br /> <throttle-outbound policy="REPLACE" max-frequency="500"/><br /> </network><br /> <server><br /> <max-cache-size>1000</max-cache-size><br /> <message-time-to-live>0</message-time-to-live><br /> <durable>true</durable><br /> </server><br /> </properties><br /> <channels><br /> <channel ref="my-polling-amf"/><br /> <channel ref="my-streaming-amf"/><br /> </channels> <br /> </destination><br /></service><br />
Now we are raedy with the java side now we can go to the flex builder. first we create the flex project. Follow the pictures belows



The jms producer and consumer mxml looks like this. Here we can send text messages to the queue and the consumer automatically receive these messages and displays it on the screen.
<br /><?xml version="1.0"?><br /><mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" creationComplete="init()"><br /> <mx:Script><br /> <![CDATA[<br /> import mx.messaging.*;<br /> import mx.messaging.messages.*;<br /> import mx.messaging.events.*;<br /> import mx.messaging.channels.StreamingAMFChannel;<br /> import mx.messaging.ChannelSet;<br /> import mx.messaging.channels.AMFChannel;<br /> <br /> private function faultHandler(event:MessageFaultEvent):void{<br /> }<br /> private function acknowledgeHandler(event:MessageAckEvent):void {<br /> } <br /> private function messageHandler(event: MessageEvent):void {<br /> ta.text += event.message.body + "\n";<br /> }<br /> private function sendMessage():void {<br /> var message:AsyncMessage = new AsyncMessage();<br /> message.body = input.text;<br /> producer.send(message);<br /> }<br /> private function init():void<br /> {<br /> var myStreamingAMF:AMFChannel = new StreamingAMFChannel("my-streaming-amf", "../messagebroker/streamingamf");<br /> var myPollingAMF:AMFChannel = new AMFChannel("my-polling-amf", "../messagebroker/amfpolling");<br /> myPollingAMF.pollingEnabled = true;<br /> myPollingAMF.pollingInterval = 2000;<br /> var channelSet:ChannelSet = new ChannelSet();<br /> channelSet.addChannel(myStreamingAMF);<br /> channelSet.addChannel(myPollingAMF);<br /> consumer.channelSet = channelSet; <br /> producer.channelSet = channelSet;<br /><br /> consumer.subscribe();<br /> }<br /> ]]><br /> </mx:Script><br /><br /> <mx:Producer id="producer"<br /> destination="jms-feed"<br /> acknowledge="acknowledgeHandler(event)"<br /> fault="faultHandler(event)"/><br /><br /> <mx:Consumer id="consumer"<br /> destination="jms-feed"<br /> message="messageHandler(event)"<br /> fault="faultHandler(event)"/><br /><br /> <mx:TextInput id="input" width="314"/><br /> <mx:Button label="Send" click="sendMessage();"/><br /> <mx:TextArea id="ta" height="172" width="308"/><br /></mx:Application><br />
Here is the result.