MASTERTHEBOSS.COM

package com.sample;

import org.jboss.ejb3.annotation.ResourceAdapter;

import javax.ejb.*;
import javax.jms.*;

@MessageDriven(name = "MDBExample",
               activationConfig =
                     {
                        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
                        @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue"),
                     })
 
@ResourceAdapter("hornetq-ra.rar")
public class MDBExample implements MessageListener
{
   public void onMessage(Message message)
   {
      try
      {
         TextMessage textMessage = (TextMessage)message;
 
         String text = textMessage.getText();
         
         System.out.println("message " + text);

      }
      catch (Exception e)
      {
         e.printStackTrace();
      }
   }
}

<queue name="testQueue">
      <entry name="/queue/testQueue"/>
</queue>

package com.sample;

import java.util.Properties;
import javax.jms.*;
import javax.naming.Context;

public class QueueExample   
{

	public void example() throws Exception
	{
		String destinationName = "queue/testQueue";

		Context ic = null;
		ConnectionFactory cf = null;
		Connection connection =  null;

		try
		{         
			ic = getInitialContext();

			cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
			Queue queue = (Queue)ic.lookup(destinationName);

			connection = cf.createConnection();
			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			MessageProducer publisher = session.createProducer(queue);
			MessageConsumer subscriber = session.createConsumer(queue);

			connection.start();

			TextMessage message = session.createTextMessage("Hello!");
			publisher.send(message);
            System.out.println("Message sent!");
 

		}
		finally
		{         
			if(ic != null)
			{
				try
				{
					ic.close();
				}
				catch(Exception e)
				{
					throw e;
				}
			}

			closeConnection(connection);
		}
	}
	private void closeConnection(Connection con)
	{      
		try
		{
			if (con != null)
			{
				con.close();
			}         
		}
		catch(JMSException jmse)
		{
			System.out.println("Could not close connection " + con +" exception was " + jmse);
		}
	}


	public static void main(String[] args) throws Exception
	{
		new QueueExample().example();
	}
	public static 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);
	}  
}

Your example is completed. Remeber to add HornetQ libraries into your build path as shown here: