Jboss Remote Connection JMS

[Azrael Noor]

I am Confused how to make remote connection in jboss even tutorials are not able to help me out.
I am using jboss v4.2 and netbeans.

i kept server publishing program at one PC say : 192.122.1.1 and it's code is here under:
package com;

import java.util.Hashtable;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import javax.jms.TopicPublisher;
import javax.jms.Topic;
import javax.jms.TextMessage;
import javax.jms.Session;
import javax.jms.JMSException;

/**
 * <p>Simple JMS client, publish text messages to testTopic Topic.
 * </p>
 *
 * <p><b>NOTE</b>This code is a showcase only. It may not provide
 * a stable production example.</p>
 * @author Peter Antman
 * @version $Revision: 3.1 $
 */
public class HelloPublisher {

    /**
     * Topic connection, hold on to this so you may close it.
     */
    TopicConnection topicConnection;
    /**
     * Topic session, hold on to this so you may close it.
     * Also used to create messages.
     */
    TopicSession topicSession;
    /**
     * Use this to publish messages.
     */
    TopicPublisher topicPublisher;
    /**
     * Destination where to publish.
     */
    Topic topic;

    /**
     * Sets up all the JMS fixtures.
     *
     * Use close() when finished with object.
     *
     * @param factoryJNDI name of the topic connection factory to look up.
     * @param topicJNDI name of the topic destination to look up
     */
    public HelloPublisher(String factoryJNDI, String topicJNDI)
            throws JMSException, NamingException {

        // Populate with needed properties
            Hashtable props = new Hashtable();
            props.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
            props.put(Context.PROVIDER_URL, "localhost:1899.192.1.2.1:1099");
            props.put("java.naming.rmi.security.manager", "yes");
            props.put(Context.URL_PKG_PREFIXES, "org.jboss.naming");

            // Get the initial context with given properties
            Context context = new InitialContext(props);



        // Get the initial context
       // Context context = new InitialContext();

        // Get the connection factory
        TopicConnectionFactory topicFactory = (TopicConnectionFactory) context.lookup(factoryJNDI);

        // Create the connection
        topicConnection = topicFactory.createTopicConnection();

        // Create the session
        topicSession = topicConnection.createTopicSession(
                // No transaction
                false,
                // Auto ack
                Session.AUTO_ACKNOWLEDGE);

        // Look up the destination
        topic = (Topic) context.lookup(topicJNDI);

        // Create a publisher
        topicPublisher = topicSession.createPublisher(topic);

    }

    /**
     * Publish the given String as a JMS message to the testTopic topic.
     */
    public void publish(String msg) throws JMSException {

        // Create a message
        TextMessage message = topicSession.createTextMessage();
        message.setText(msg);

        // Publish the message
        topicPublisher.publish(topic, message);

    }

    /**
     * Close session and connection.
     * When done, no publishing is possible any more.
     */
    public void close() throws JMSException {

        topicSession.close();
        topicConnection.close();

    }

    /**
     * Run an example publishing 10 messages to testTopic.
     * Only works up to and including JBoss 2.4.0
     */
    public static void main(String[] args) {
        try {

            // Create the HelloPublisher, giving it the name of the
            // TopicConnection Factory and the Topic destination to
            // use in lookup.
            HelloPublisher publisher = new HelloPublisher("ConnectionFactory","topic/testTopic");

            // Publish 10 messages
            for (int i = 1; i < 11; i++) {

                String msg = "Hello World no. " + i;
                System.out.println("Publishing message: " + msg);
                publisher.publish(msg);

            }

              publisher.close();

        }
        catch (Exception ex)
        {

            System.err.println("An exception occurred while testing HelloPublisher: " + ex);
            ex.printStackTrace();

        }

    }
}

I am able to send the message.

Now on remote side i have written following MDB, in an EJB Module :

package com;

import java.util.logging.Level;
import java.util.logging.Logger;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

@MessageDriven(mappedName = "topic/testTopic", 

    activationConfig =  {
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "topic/testTopic"),
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
        @ActivationConfigProperty(propertyName = "subscriptionDurability", propertyValue = "NonDurable"),
        @ActivationConfigProperty(propertyName = "clientId", propertyValue = "DrivenBean6"),
        @ActivationConfigProperty(propertyName = "subscriptionName", propertyValue = "DrivenBean6")

                        })

public class DrivenBean implements MessageListener {
    
    public DrivenBean() {
    }

     TextMessage tx=null;
    public void onMessage(Message message)
    {
        tx=(TextMessage) message;
        try {
            System.out.println("Driven Bean -> " + tx.getText());
        } catch (JMSException ex) {
            
        }
        System.out.println("Hello");
    }
    
}

Following XML's i have written on beans side:
for destination

<?xml version="1.0" encoding="UTF-8"?>
<server>
  <mbean code="org.jboss.mq.server.jmx.Topic" name="jboss.mq.destination:service=Topic,name=topic/testTopic">
    <depends optional-attribute-name="DestinationManager"/>
  </mbean>
  <mbean code="org.jboss.mq.server.jmx.Topic" name="jboss.mq.destination:service=Topic,name=testTopic">
    <depends optional-attribute-name="DestinationManager"/>
  </mbean>
</server>

jboss.xml

<?xml version="1.0" encoding="utf-8"?>
<jboss >
    <enterprise-beans>
        <message-driven>
            <ejb-name>DrivenBean</ejb-name>
            <destination-jndi-name>topic/testTopic</destination-jndi-name>
            <resource-ref>
                <res-ref-name>testTopic</res-ref-name>
                <jndi-name>ConnectionFactory</jndi-name>
            </resource-ref>
        </message-driven>
    </enterprise-beans>
   
</jboss>

1) MDB Deployed Fine
2) Message is moving fine

does more settings required in any xml? please tell
Thankyou

[Azrael Noor]

3 Weeks over no improvement
no connection with JMS using Jboss 4.2,

i am fired!!!

voh!!!

the baddest server i have ever seen.
the baddest tutorials i have ever seen on line.

Use Glassfish!!!

[Peter Johnson]

Actually, after looking at your post carefully, I have no idea what it is that you are asking. You said that the MDB deployed just fine and that the messages are moving just fine, so I wasn't quite sure what was not working for you.

Also, your post might be an instance of way too much information. The people who help on this forum are very busy (at least I know I am), and I am not about to dig through many lines of code that may of may not have anything to do with the problem. At times is is best to just state exactly what the issue is (that is, you expected one behavior and instead you got something different) and provide the minimum amount of code to illustrate the code that you think is not working correctly.

[Azrael Noor]

Already said ----> ""how to make remote connection"""???

MDB working fine for stand alone application but
what more settings required for remote communication in Jboss 4.2.2.

but one thing is sure that JBOSS is not user friendly admin and settings. BAD Server

[Jaikiran Pai]

Azrael Noor wrote:Already said ----> ""how to make remote connection"""???

Remote connection to what?

Azrael Noor wrote:
MDB working fine for stand alone application but
what more settings required for remote communication in Jboss 4.2.2.

You'll have to explain what you mean by remote communication. What exactly are you trying?

[Peter Johnson]

Are you asking how does a standalone client application send a message to a message queue so that the MDB can read it? If so, the answer is: pretty much the same way as an application deployed to JBoss AS would do it (which you say you already have working). The key steps are:

1) Look up the messaging server and queues via JNDI (config JNDI to look things up in JBoss AS)
2) Create a message and send it to the queue you looked up in step 1.


Here is an example:
http://docs.jboss.org/jbossas/docs/Server_Configuration_Guide/4/html/JMS_Examples-A_Point_To_Point_Example.html