простое клиент-серверное приложение MDB JMS на JBoss 6.1.0/Hornetq

Я пытаюсь реализовать простое веб-приложение с MDB, работающим на JBoss 6.1.0 (Java EE 6 - Hornetq), чтобы попробовать JMS и MDB. Мне также нужен простой автономный клиент, который отправляет текстовое сообщение в очередь, которую прослушивает MDB. Это всего лишь попытка, поэтому достаточно, чтобы клиент отправил простое «привет, мир!» текстовое сообщение, а MDB просто читает его и записывает в журнал. Я нашел много примеров в Интернете, но кто-то использует Glassfish в качестве сервера, кто-то не объясняет, какие библиотеки правильно импортировать в клиент, кто-то не объясняет, как выполнять поиск очереди и фабрики соединений, когда клиент удален. , поэтому я все еще не могу реализовать работающее приложение.

Ниже приведен код MDB, который я создал:

package it.test.mymdb;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 @messageDriven(
    activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationType",
                                  propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "destination",
                                  propertyValue = "myQueue")})
public class MyMDB implements MessageListener {
    private static final Logger logger = LoggerFactory.getLogger(MyMDB.class);

    @Override
    public void onMessage(Message message) {
        try {
            logger.info("Messaggio ricevuto");
            TextMessage txtMsg = (TextMessage) message;
            logger.info(txtMsg.getText());
        }
        catch (JMSException ex) {
            logger.error("Errore durante la lettura del testo del messaggio.");
        }
    }
}

А это файл hornetq-jms.xml, в котором я определил очередь и фабрику соединений:

<?xml version="1.0"?>
<configuration xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"
               xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
               xmlns="urn:hornetq">
    <connection-factory name="myConnectionFactory">
        <connectors>
            <connector-ref connector-name="netty"/>
        </connectors>
        <entries>
            <entry name="/myConnectionFactory"/>
        </entries>
    </connection-factory>

    <queue name="myQueue">
        <entry name="/queue/myQueue" />
    </queue>
</configuration>

ВОПРОС 1: Должен ли я вставлять в этот файл данные «пользователя» и «пароля», необходимые клиенту для выполнения поиска JNDI? Если да, то как?

Развертывание моего MDB, похоже, работает, если я захожу в панель администратора JBoss, я вижу очередь:

Name: myQueue
JNDI Binding: /queue/myQueue
Address: jms.queue.myQueue
Temporary: false
Paused: false 

и фабрика соединений:

Name: myConnectionFactory
JNDI Bindings: /myConnectionFactory 

Это (не работающий) код моего клиента:

package it.test.mymdbclient;

import java.util.Hashtable;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class MyMdbClient {
    private final static String JNDI_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory";
    private final static String JMS_FACTORY = "myConnectionFactory";
    private final static String QUEUE = "queue/myQueue";
    private final static String jbossUrl = "remote://localhost:4447";

    private static InitialContext getInitialContext() throws NamingException {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
        env.put(Context.PROVIDER_URL, jbossUrl);
        env.put(Context.SECURITY_PRINCIPAL, "admin"); //PROBABLY THOSE CREDENTIALS ARE NOT CORRECT
        env.put(Context.SECURITY_CREDENTIALS, "admin");
        return new InitialContext(env);
    }

    public static void main(String[] args) throws Exception {
        InitialContext ic = getInitialContext();
        QueueConnectionFactory qconFactory = (QueueConnectionFactory) ic.lookup(JMS_FACTORY);
        QueueConnection qcon = qconFactory.createQueueConnection("admin", "admin"); //PROBABLY THOSE CREDENTIALS ARE NOT CORRECT
        QueueSession qsession = qcon.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
        Queue queue = (Queue) ic.lookup(QUEUE);
        QueueSender qsender = qsession.createSender(queue);
        qcon.start();
        TextMessage msg = qsession.createTextMessage();
        msg.setText("Hello world! :)");
        qsender.send(msg);
        qsender.close();
        qsession.close();
        qcon.close();
    }
}

Это библиотека, которую я импортировал, но я почти уверен, что ее недостаточно, и это является причиной возникновения исключения. Если это то, какие еще библиотеки мне нужны?

<dependency>
    <groupId>org.hornetq</groupId>
    <artifactId>hornetq-jms-client</artifactId>
    <version>2.3.9.Final</version>
</dependency>

Это исключение возникает при запуске клиента:

Exception in thread "main" javax.naming.NoInitialContextException: Cannot instantiate class: org.jboss.naming.remote.client.InitialContextFactory [Root exception is java.lang.ClassNotFoundException: org.jboss.naming.remote.client.InitialContextFactory]
    at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:674)
    at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:313)
    at javax.naming.InitialContext.init(InitialContext.java:244)
    at javax.naming.InitialContext.<init>(InitialContext.java:216)
    at it.test.mymdbclient.MyMdbClient.getInitialContext(MyMdbClient.java:27)
    at it.test.mymdbclient.MyMdbClient.main(MyMdbClient.java:31)
Caused by: java.lang.ClassNotFoundException: org.jboss.naming.remote.client.InitialContextFactory
    at java.net.URLClassLoader$1.run(URLClassLoader.java:372)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:360)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:340)
    at com.sun.naming.internal.VersionHelper12.loadClass(VersionHelper12.java:72)
    at com.sun.naming.internal.VersionHelper12.loadClass(VersionHelper12.java:61)
    at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:672)
    ... 5 more