Блог

Мы запускаем автономный JBoss 7.2 на моем локальном хостинге и используем standalone-full.xml но в облегченной версии, чтобы удалить все, что не используется — например, были удалены разделы обмена сообщениями.

Но теперь я пытаюсь выполнить MessageDrivenBean с очередью, используя jms. Я начал с добавления следующего в standalone-full.xml :

 <extensions>
    <extension module="org.jboss.as.messaging"/>

    <subsystem xmlns="urn:jboss:domain:messaging:1.1">
        <hornetq-server>
            <persistence-enabled>true</persistence-enabled>
            <journal-file-size>102400</journal-file-size>
            <journal-min-files>2</journal-min-files>
            <connectors>
                <netty-connector name="netty" socket-binding="messaging"/>
                <netty-connector name="netty-throughput" socket-binding="messaging-throughput">
                    <param key="batch-delay" value="50"/>
                </netty-connector>
                <in-vm-connector name="in-vm" server-id="0"/>
            </connectors>
            <acceptors>
                <netty-acceptor name="netty" socket-binding="messaging"/>
                <netty-acceptor name="netty-throughput" socket-binding="messaging-throughput">
                    <param key="batch-delay" value="50"/>
                    <param key="direct-deliver" value="false"/>
                </netty-acceptor>
                <in-vm-acceptor name="in-vm" server-id="0"/>
            </acceptors>
            <security-domain>XXSecurityDomain</security-domain>
            <security-settings>
                <security-setting match="#">
                    <permission type="send" roles="guest"/>
                    <permission type="consume" roles="guest"/>
                    <permission type="createNonDurableQueue" roles="guest"/>
                    <permission type="deleteNonDurableQueue" roles="guest"/>
                </security-setting>`
            </security-settings>
            <jms-connection-factories>
                <connection-factory name="InVmConnectionFactory">
                    <connectors>
                        <connector-ref connector-name="in-vm"/>
                    </connectors>
                    <entries>
                        <entry name="java:/ConnectionFactory"/>
                    </entries>
                </connection-factory>
                <connection-factory name="RemoteConnectionFactory">
                    <connectors>
                        <connector-ref connector-name="netty"/>
                    </connectors>
                    <entries>
                        <entry name="java:jboss/exported/jms/RemoteConnectionFactory"/>
                    </entries>
                </connection-factory>
                <pooled-connection-factory name="hornetq-ra">
                    <transaction mode="xa"/>
                    <connectors>
                        <connector-ref connector-name="in-vm"/>
                    </connectors>
                    <entries>
                        <entry name="java:/JmsXA"/>
                    </entries>
                </pooled-connection-factory>
            </jms-connection-factories>
        </hornetq-server>
    </subsystem>

    <socket-binding-group name="standard-sockets" default-interface="public" port-offset="${jboss.socket.binding.port-offset:100}">
        <socket-binding name="messaging" port="5445"/>
        <socket-binding name="messaging-throughput" port="5455"/>
  

Затем я использовал существующий сервлет, который уже работал ранее, и модифицировал его :

 public class XRequestServlet extends HttpServlet
    Context mQueueContext = null;
    ConnectionFactory mConnectionFactory = null;
    Connection mConnection = null;

    public void init() throws ServletException {
        try {
            log.info("init()");

            mQueueContext = new InitialContext();
            mConnectionFactory = (ConnectionFactory) mQueueContext.lookup("/ConnectionFactory");

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


public void doPost(WebSession pWebSession, HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    log.info("doPost()");
    String vDestinationName = "java:jboss/exported/jms/queue/testQueue";
    PrintWriter vOut = response.getWriter();

    try {
    log.info("1");

        mConnection = mConnectionFactory.createConnection();
        log.info("1.5");
        Queue vQueue = (Queue) mQueueContext.lookup(vDestinationName);
        log.info("2");
  

Чтобы протестировать это, я использую плагин RestClient в Firefox, и я могу видеть мой запрос
вводит doPost (), и я вижу протоколирование doPost (), 1 и 1.5, но при попытке создать
сбой очереди.
В журнале jboss я получаю следующую ошибку :

javax.именование.Исключение NameNotFoundException: jms/queue/testQueue — служба jboss.naming.context.java.jboss.exported.jms.queue.testQueue

Может кто-нибудь дать мне совет, что нужно сделать??

Я не просматривал остальную часть вашей конфигурации, но непосредственная причина ошибки, которую вы получаете, заключается в том, что вы, похоже, не настроили никаких очередей в JBoss, поэтому при попытке найти ее с помощью mQueueContext.lookup выдается исключение.

Очереди настраиваются в jms-destinations следующим образом:

 <subsystem xmlns="urn:jboss:domain:messaging:1.0">
   [...]
   <jms-destinations>
       <jms-queue name="testQueue">
           <entry name="jms/queue/test"/>
           <entry name="java:jboss/exported/jms/queue/test"/>
       </jms-queue>
   [...]
</subsystem>
  

Смотрите https://docs.jboss.org/author/display/AS72/Messaging configuration#Messagingconfiguration-JMSQueuesandTopics для получения дополнительной документации по настройке JMS в JBoss 7