How to use Hornet Q in JBoss 6.0 Final

[Jose Alvarez de Lara]

Hi

I am trying to configure and deploy on JBoss 6.0 AS an app client that includes a MDB Topic with a selector.

This is the code,

@MessageDriven(mappedName = "jms/Topic", activationConfig =  {
	@ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "MsgType = 'TR' OR MsgType = 'ET' OR MsgType = 'PP'")
	, @ActivationConfigProperty(propertyName = "subscriptionDurability", propertyValue = "Durable")
	, @ActivationConfigProperty(propertyName = "clientId", propertyValue = "MyID")
	, @ActivationConfigProperty(propertyName = "subscriptionName", propertyValue = "MySub")
	})
public class MessageBean implements MessageListener {
	static final Logger logger = Logger.getLogger("MessageBean");
    @Resource
    public MessageDrivenContext mdc;
    
    /**
     * Default constructor. 
     */
    public MessageBean() {
        // TODO Auto-generated constructor stub
    }
	
	/**
     * @see MessageListener#onMessage(Message)
     */
    public void onMessage(Message inMessage) {
        // TODO Auto-generated method stub
    	TextMessage msg = null;
        try {
            if (inMessage instanceof TextMessage) {
                msg = (TextMessage) inMessage;
                String type = msg.getStringProperty("MsgType");
                String message = msg.getText();
                String sender = message.substring(0, message.indexOf("#"));
                message = message.substring(message.indexOf("#") + 1);
                System.out.println(sender + " to " + type + " say :" + message);
            } else {
                System.out.println(
                        "Message of wrong type: "
                        + inMessage.getClass().getName());
            }
        } catch (JMSException e) {
            logger.severe(
                    "MessageBean.onMessage: JMSException: " + e.toString());
            e.printStackTrace();
            mdc.setRollbackOnly();
        } catch (Throwable te) {
            logger.severe("MessageBean.onMessage: Exception: " + te.toString());
            te.printStackTrace();
        }
    }

}

I use an EJB 3.0 to publish messages. It has a remote interface,

@Remote
public interface PublisherBeanRemote {

	void publishNews(String msgType, String msgText);
}

@Stateless
@Remote({
    PublisherBeanRemote.class
})
public class PublisherBean implements PublisherBeanRemote {
	static final Logger logger = Logger.getLogger("PublisherBean");
    Connection connection = null;
    @Resource(mappedName = "jms/ConnectionFactory")
    private ConnectionFactory connectionFactory;
    @Resource
    private SessionContext sc;
    @Resource(mappedName = "jms/Topic")
    private Topic topic;
    
    /**
     * Default constructor. 
     */
    public PublisherBean() {
        // TODO Auto-generated constructor stub
    }
    
    /**
     * Creates the connection.
     */
    @PostConstruct
    public void makeConnection() {
        try {
        	Context ic = getInitialContext();
        	connectionFactory = (ConnectionFactory)ic.lookup("jms/ConnectionFactory");
            connection = connectionFactory.createConnection();
        } catch (Throwable t) {
            // JMSException could be thrown
            logger.severe(
                    "PublisherBean.makeConnection:" + "Exception: "
                    + t.toString());
        }
    }
    
	private Context getInitialContext( )
			throws javax.naming.NamingException {

		Properties p = new Properties( );
		p.put(Context.INITIAL_CONTEXT_FACTORY,
				"org.jnp.interfaces.NamingContextFactory");
		p.put(Context.URL_PKG_PREFIXES,
		" org.jboss.naming:org.jnp.interfaces");
		p.put(Context.PROVIDER_URL, "jnp://localhost:1099");
		
		return new javax.naming.InitialContext(p);
	}  

    
    public void publishNews(String msgType, String msgText) {
    	Session session = null;
        MessageProducer publisher = null;
        TextMessage message = null;

        try {
            session = connection.createSession(true, 0);
            publisher = session.createProducer(topic);
            message = session.createTextMessage();
            message.setStringProperty("MsgType", msgType);
            message.setText(msgText);
            System.out.println(
                    "PUBLISHER: Setting " + "message text to: "
                    + msgType);
            publisher.send(message);
        } catch (Throwable t) {
            // JMSException could be thrown
            logger.severe(
                    "PublisherBean.publishNews: " + "Exception: "
                    + t.toString());
            sc.setRollbackOnly();
        } finally {
            if (session != null) {
                try {
                    session.close();
                } catch (JMSException e) {
                }
            }
        }
    }

    /**
     * Closes the connection.
     */
    @PreDestroy
    public void endConnection() throws RuntimeException {
        if (connection != null) {
            try {
                connection.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

How must I do to configure the server using Hornet Q?

I am using Eclipse Helios SR1 to develop and deploy this MDB app

Thanks in advance,
Jose

[anandraj tadkal]

Hi Jose,

Refer the below link for a sample configuration of HornetQ with JBoss Messaging with sample Queue Sender / Receiver Program.

http://weblogic-wonders.com/weblogic/2010/12/01/jboss-jms-using-hornetq/

Cheers,
Anandraj
http://weblogic-wonders.com

[Jose Alvarez de Lara]

Hi,

Thanks Anandraj for your helping.

Your link took me to the user manual of Hornet Q and at the end to download hornetq-2.1.1.Final.
Now I am trying topic-selector-example1 but I am having some problems. I have created two projects
in Eclipse Helios SR1: one for the common feature and the second is topic-selector-example1 witch the
main class extends HornetQExample from common. I have included the common project into the build
path of the topic-selector-example1 project so the compiling is right.

But when I try to run the application I find the main() method of the main class is waiting for some arguments
from the command line (my system is Win XP). This means the output of the program is the following exception,

serverProps = null
28-feb-2011 18:49:47 org.hornetq.common.example.HornetQExample run
INFO: hornetq.example.runServer is true
28-feb-2011 18:49:47 org.hornetq.common.example.HornetQExample getContext
INFO: using server0\client-jndi.properties for jndi
log4j:WARN No appenders could be found for logger (org.jnp.interfaces.TimedSocketFactory).
log4j:WARN Please initialize the log4j system properly.
javax.naming.NameNotFoundException: topic not bound
at org.jnp.server.NamingServer.getBinding(NamingServer.java:771)
at org.jnp.server.NamingServer.getBinding(NamingServer.java:779)
at org.jnp.server.NamingServer.getObject(NamingServer.java:785)
at org.jnp.server.NamingServer.lookup(NamingServer.java:396)
at sun.reflect.GeneratedMethodAccessor266.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:305)
at sun.rmi.transport.Transport$1.run(Transport.java:159)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.Transport.serviceCall(Transport.java:155)
at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:535)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:790)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:649)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:255)
at sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:233)
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:142)
at org.jnp.server.NamingServer_Stub.lookup(Unknown Source)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:728)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:688)
at javax.naming.InitialContext.lookup(InitialContext.java:392)
at org.hornetq.jms.example.TopicSelectorExample1.runExample(TopicSelectorExample1.java:51)
at org.hornetq.common.example.HornetQExample.run(HornetQExample.java:73)
at org.hornetq.jms.example.TopicSelectorExample1.main(TopicSelectorExample1.java:35)

#####################
### FAILURE! ###
#####################

From the start can you see the first line? (serverProps = null) I guess this is the reason I am getting the exception
but I am not sure if it is all or there be some errors in the configuration of the projects.

Let me know if you need more information because we are talking about a lot of several files between code and configuration files.

Best Regards,
Jose

[Jose Alvarez de Lara]

Here is my code.

This is the main class where I run the app from,

public class TopicSelectorExample1 extends HornetQExample
{
   public static void main(final String[] args)
   {
      new TopicSelectorExample1().run(args);
   }

   @Override
   public boolean runExample() throws Exception
   {
      Connection connection = null;

      InitialContext initialContext = null;
      try
      {

         // Step 1. Create an initial context to perform the JNDI lookup.
         initialContext = getContext(0);

         // Step 2. Look-up the JMS topic
         Topic topic = (Topic)initialContext.lookup("/topic/exampleTopic");

         // Step 3. Look-up the JMS connection factory
         ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory");

         // Step 4. Create a JMS connection
         connection = cf.createConnection();

         // Step 5. Create a JMS session
         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

         // Step 6. Create a JMS message producer
         MessageProducer producer = session.createProducer(topic);

         // Step 7. Create one subscription with a specific Filter for someID=1
         MessageConsumer messageConsumer1 = session.createConsumer(topic, "someID=1", false);

         // Step 8. Create another subscription with a specific Filter for someID=2
         MessageConsumer messageConsumer2 = session.createConsumer(topic, "someID=2", false);

         // Step 9. Create another subscription with no filters, which will receive every message sent to the topic
         MessageConsumer messageConsumer3 = session.createConsumer(topic);

         // Step 10. Send 20 messages, 10 with someID=1, 10 with someID=2

         for (int i = 1; i < 10; i++)
         {
            for (int someID = 1; someID <= 2; someID++)
            {
               // Step 10.1 Create a text message
               TextMessage message1 = session.createTextMessage("This is a text message " + i +
                                                                " sent for someID=" +
                                                                someID);

               // Step 10.1 Set a property
               message1.setIntProperty("someID", someID);

               // Step 10.2 Send the message
               producer.send(message1);

               System.out.println("Sent message: " + message1.getText());
            }
         }

         // Step 11. Start the JMS Connection. This step will activate the subscribers to receive messages.
         connection.start();

         // Step 12. Consume the messages from MessageConsumer1, filtering out someID=2

         System.out.println("*************************************************************");
         System.out.println("MessageConsumer1 will only receive messages where someID=1:");
         for (;;)
         {
            TextMessage messageReceivedA = (TextMessage)messageConsumer1.receive(1000);
            if (messageReceivedA == null)
            {
               break;
            }

            System.out.println("messageConsumer1 received " + messageReceivedA.getText() +
                               " someID = " +
                               messageReceivedA.getIntProperty("someID"));
         }

         // Step 13. Consume the messages from MessageConsumer2, filtering out someID=2
         System.out.println("*************************************************************");
         System.out.println("MessageConsumer2 will only receive messages where someID=2:");
         for (;;)
         {
            TextMessage messageReceivedB = (TextMessage)messageConsumer2.receive(1000);
            if (messageReceivedB == null)
            {
               break;
            }

            System.out.println("messageConsumer2 received " + messageReceivedB.getText() +
                               " someID = " +
                               messageReceivedB.getIntProperty("someID"));
         }

         // Step 14. Consume the messages from MessageConsumer3, receiving the complete set of messages
         System.out.println("*************************************************************");
         System.out.println("MessageConsumer3 will receive every message:");
         for (;;)
         {
            TextMessage messageReceivedC = (TextMessage)messageConsumer3.receive(1000);
            if (messageReceivedC == null)
            {
               break;
            }
            System.out.println("messageConsumer3 received " + messageReceivedC.getText() +
                               " someID = " +
                               messageReceivedC.getIntProperty("someID"));
         }

         // Step 15. Close the subscribers
         messageConsumer1.close();
         messageConsumer2.close();
         messageConsumer3.close();

         return true;

      }
      finally
      {
         // Step 15. Be sure to close our JMS resources!
         if (initialContext != null)
         {
            initialContext.close();
         }
         if (connection != null)
         {
            connection.close();
         }
      }
   }
}

Here is HornetQExample witch is causing me (I guess) the problems,

public abstract class HornetQExample
{
   protected static Logger log = Logger.getLogger(HornetQExample.class.getName());

   private Process[] servers;

   private Connection conn;

   private boolean failure = false;

   private String serverClasspath;

   private String serverProps;

   public abstract boolean runExample() throws Exception;

   private boolean logServerOutput;

   private String[] configs;

   protected void run(final String[] configs)
   {
      String runServerProp = System.getProperty("hornetq.example.runServer");
      String logServerOutputProp = System.getProperty("hornetq.example.logserveroutput");
      serverClasspath = System.getProperty("hornetq.example.server.classpath");
      boolean runServer = runServerProp == null ? true : Boolean.valueOf(runServerProp);
      logServerOutput = logServerOutputProp == null ? false : Boolean.valueOf(logServerOutputProp);
      serverProps = System.getProperty("hornetq.example.server.args");
      if (System.getProperty("hornetq.example.server.override.args") != null)
      {
         serverProps = System.getProperty("hornetq.example.server.override.args");
      }
      System.out.println("serverProps = " + serverProps);
      HornetQExample.log.info("hornetq.example.runServer is " + runServer);

      this.configs = configs;

      try
      {
         if (runServer)
         {
            startServers();
         }

         if (!runExample())
         {
            failure = true;
         }
         System.out.println("example complete");
      }
      catch (Throwable e)
      {
         failure = true;
         e.printStackTrace();
      }
      finally
      {
         if (conn != null)
         {
            try
            {
               conn.close();
            }
            catch (JMSException e)
            {
               // ignore
            }
         }
         if (runServer)
         {
            try
            {
               stopServers();
            }
            catch (Throwable throwable)
            {
               throwable.printStackTrace();
            }
         }
      }
      reportResultAndExit();
   }

   protected void killServer(final int id) throws Exception
   {
      System.out.println("Killing server " + id);

      // We kill the server by creating a new file in the server dir which is checked for by the server
      // We can't use Process.destroy() since this does not do a hard kill - it causes shutdown hooks
      // to be called which cleanly shutdown the server
      File file = new File("server" + id + "/KILL_ME");

      file.createNewFile();
   }

   protected void stopServer(final int id) throws Exception
   {
      System.out.println("Stopping server " + id);

      stopServer(servers[id]);
   }

   protected InitialContext getContext(final int serverId) throws Exception
   {
      String jndiFilename = "server" + serverId + "/client-jndi.properties";
      File jndiFile = new File(jndiFilename);
      HornetQExample.log.info("using " + jndiFile + " for jndi");
      Properties props = new Properties();
      FileInputStream inStream = null;
      try
      {
         inStream = new FileInputStream(jndiFile);
         props.load(inStream);
      }
      finally
      {
         if (inStream != null)
         {
            inStream.close();
         }
      }
      return new InitialContext(props);
   }

   protected void startServer(final int index) throws Exception
   {
      String config = configs[index];
      HornetQExample.log.info("starting server with config '" + config + "' " + "logServerOutput " + logServerOutput);
      servers[index] = SpawnedVMSupport.spawnVM(serverClasspath,
                                                "HornetQServer_" + index,
                                                SpawnedHornetQServer.class.getName(),
                                                serverProps,
                                                logServerOutput,
                                                "STARTED::",
                                                "FAILED::",
                                                config,
                                                "hornetq-beans.xml");
   }

   private void startServers() throws Exception
   {
      servers = new Process[configs.length];
      for (int i = 0; i < configs.length; i++)
      {
         startServer(i);
      }
   }

   private void stopServers() throws Exception
   {
      for (Process server : servers)
      {
         if (server != null)
         {
            stopServer(server);
         }
      }
   }

   private void stopServer(final Process server) throws Exception
   {
      if (!System.getProperty("os.name").contains("Windows") && !System.getProperty("os.name").contains("Mac OS X"))
      {
         if (server.getInputStream() != null)
         {
            server.getInputStream().close();
         }
         if (server.getErrorStream() != null)
         {
            server.getErrorStream().close();
         }
      }
      server.destroy();
   }

   private void reportResultAndExit()
   {
      if (failure)
      {
         System.err.println();
         System.err.println("#####################");
         System.err.println("###    FAILURE!   ###");
         System.err.println("#####################");
         System.exit(1);
      }
      else
      {
         System.out.println();
         System.out.println("#####################");
         System.out.println("###    SUCCESS!   ###");
         System.out.println("#####################");
         System.exit(0);
      }
   }
}

And here are the configuration files.

hornetq-jms.xml

<configuration xmlns="urn:hornetq"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">
   <!--the connection factory used by the example-->
   <connection-factory name="ConnectionFactory">
      <connectors>
         <connector-ref connector-name="netty-connector"/>
      </connectors>
      <entries>
         <entry name="ConnectionFactory"/>
      </entries>
   </connection-factory>

   <!--the topic used by the example-->
   <topic name="exampleTopic">
      <entry name="/topic/exampleTopic"/>
   </topic>

</configuration>

and the client-jndi.properties,

java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.provider.url=jnp://localhost:1199
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces

Thanks in advance,
Jose

[Jose Alvarez de Lara]

Hi,

I have made some changes in the code and the configuration files as well.
And now the app works fine.

These are the changes,

In TopicSelectorExample1.java

// Step 2. Look-up the JMS topic
Topic topic = (Topic)initialContext.lookup("/jms/Topic");

Now look up /jms/Topic instead of /topic/exampleTopic so the configuration files leave as follow,

hornetq-jms.xml

<!--the topic used by the example-->
<topic name="Topic">
   <entry name="/jms/Topic"/>
</topic>

here I have changed the name of the topic. It was exampleTopic and now is Topic and
the entry name was /topic/exampleTopic

hornetq-configuration.xml

<security-settings>
   <!--security for example topic-->
   <security-setting match="jms.Topic">
      <permission type="createDurableQueue" roles="guest"/>
      <permission type="deleteDurableQueue" roles="guest"/>
      <permission type="createNonDurableQueue" roles="guest"/>
      <permission type="deleteNonDurableQueue" roles="guest"/>
      <permission type="consume" roles="guest"/>
      <permission type="send" roles="guest"/>
   </security-setting>
</security-settings>

here I have changed <security-setting match="jms.topic.exampleTopic">

And that was all. Resolved!!!

[anandraj tadkal]

Great job!!

Thanks for sharing the solution. That would definitely help out many people running into similar issues.

Cheers,
Anandraj
http://weblogic-wonders.com