import  javax.jms.Queue;
 import  javax.jms.QueueConnectionFactory;
 import  javax.jms.QueueReceiver;
 import  javax.jms.JMSException;
 import  javax.jms.QueueSession;
 import  javax.jms.QueueConnection;
 import  javax.jms.Session;
 import  javax.jms.MessageListener;
 import  javax.jms.Message;

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

 import  ?????.Connector.utils.Utilities;

 public   class  MessageReceiver  implements  MessageListener{
    
     private   final   static  String queueConnFactoyJNDIName="java:/ConnectionFactory";
     private   final   static  String queueJNDIName="java:/queue/Adapter2ConnectorDirectQueue";
    
     private  QueueReceiver receiver;
    
    /** Creates a new instance of MessageReceiver */
     public  MessageReceiver() {
        initQueue();
    }
    
     private   void  initQueue(){
         try {
            InitialContext initContext= new  InitialContext();
            //получение фабрики
            QueueConnectionFactory factory=(QueueConnectionFactory)Utilities.
                    jndiLookup(initContext, queueConnFactoyJNDIName);
            
            //получение очереди
            Queue queue=(Queue)Utilities.jndiLookup(initContext, queueJNDIName);
            
            //создание соединения, сеанса и получателя
            QueueConnection connection=factory.createQueueConnection();
            QueueSession sess=connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            receiver=sess.createReceiver(queue);
            
            //установка слушателя сообщение
            receiver.setMessageListener( this );
            
            //установка соеденения
            connection.start();
            
        } catch (NamingException e){
            e.printStackTrace(System.out);
        } catch (JMSException e){
            e.printStackTrace(System.out);
        }
    }
    
    //прием нового сообщения
     public   void  onMessage(Message msg){
        System.out.println("Message on.");
    }
    
}

### JBossNS properties
java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.provider.url=jnp://some-host:1099
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces