JMS queue не найден в поиске JNDI, когда он есть

Question

Я создал образец настройки для проверки очередей сообщений JMS. Настройка выглядит следующим образом:

Wildfly 8.1.0.Финансный сервер с проектами switchyard (у меня скоро будет назначение коммутатора). Я добавил очередь JMS к серверу, используя следующий фрагмент кода:

if (outcome != success) of /subsystem=messaging/hornetq-server=default/jms-queue=HelloQueue:read-resource 
    jms-queue add --queue-address=HelloQueue --entries=java:/jms/queue/HelloQueue, java:jboss/exported/jms/queue/HelloQueue 
end-if 

я получил следующий ответ от Wildfly:

20:13:36,647 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 59) JBAS011601: Bound messaging object to jndi name java:/jms/queue/HelloQueue 

Я создал распредустройство проект, который связан с этой очередью, и печатает все полученные через эту очередь до стандартного вывода. Затем я создал простой клиент для отправки сообщений через эту очередь. Код клиента:

package soi.syhello.jms.client; 

import java.util.Properties; 
import java.util.logging.Logger; 

import javax.jms.ConnectionFactory; 
import javax.jms.Destination; 
import javax.jms.JMSContext; 
import javax.naming.Context; 
import javax.naming.InitialContext; 
import javax.naming.NamingException; 

public class HelloJmsClient { 

    private static final Logger log = Logger.getLogger(HelloJmsClient.class.getName()); 
    private static final String DEFAULT_MESSAGE = "Alice & Bob"; 
    private static final String DEFAULT_CONNECTION_FACTORY = "jms/RemoteConnectionFactory"; 
    private static final String DEFAULT_DESTINATION = "java:/jms/queue/HelloQueue"; 
    private static final String DEFAULT_USERNAME = "guest"; 
    private static final String DEFAULT_PASSWORD = "guest"; 
    private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory"; 
    private static final String PROVIDER_URL = "http-remoting://localhost:18080"; 

    public static void main(String[] args) { 
     Context namingContext = null; 
     try { 
      try { 
       String userName = System.getProperty("username", DEFAULT_USERNAME); 
       String password = System.getProperty("password", DEFAULT_PASSWORD); 

       final Properties env = new Properties(); 
       env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY); 
       env.put(Context.PROVIDER_URL, System.getProperty(Context.PROVIDER_URL, PROVIDER_URL)); 
       env.put(Context.SECURITY_PRINCIPAL, userName); 
       env.put(Context.SECURITY_CREDENTIALS, password); 
       namingContext = new InitialContext(env); 

       String connectionFactoryString = System.getProperty("connection.factory", DEFAULT_CONNECTION_FACTORY); 
       log.info("Attempting to acquire connection factory \"" + connectionFactoryString + "\""); 
       ConnectionFactory connectionFactory = (ConnectionFactory) namingContext.lookup(connectionFactoryString); 
       log.info("Found connection factory \"" + connectionFactoryString + "\" in JNDI"); 

       String destinationString = System.getProperty("destination", DEFAULT_DESTINATION); 
       log.info("Attempting to acquire destination \"" + destinationString + "\""); 
       Destination destination = (Destination) namingContext.lookup(destinationString); 
       log.info("Found destination \"" + destinationString + "\" in JNDI"); 

       String content = System.getProperty("message.content", DEFAULT_MESSAGE); 
       JMSContext context = connectionFactory.createContext(userName, password); 
       log.info("Sending message with content: " + content); 
       context.createProducer().send(destination, content); 
       context.close(); 
      } catch (Exception e) { 
       e.printStackTrace(); 
       log.severe(e.getMessage()); 
      } 
     } finally { 
      if (namingContext != null) { 
       try { 
        namingContext.close(); 
       } catch (NamingException e) { 
        log.severe(e.getMessage()); 
       } 
      } 
     } 
    } 

} 

Теперь, при запуске клиента, я получаю сообщение об ошибке:

ápr. 09, 2015 8:16:24 DU org.xnio.Xnio <clinit> 
INFO: XNIO version 3.2.2.Final 
ápr. 09, 2015 8:16:24 DU org.xnio.nio.NioXnio <clinit> 
INFO: XNIO NIO Implementation Version 3.2.2.Final 
ápr. 09, 2015 8:16:24 DU org.jboss.remoting3.EndpointImpl <clinit> 
INFO: JBoss Remoting version 4.0.3.Final 
ápr. 09, 2015 8:16:25 DU soi.syhello.jms.client.HelloJmsClient main 
INFO: Attempting to acquire connection factory "jms/RemoteConnectionFactory" 
ápr. 09, 2015 8:16:26 DU soi.syhello.jms.client.HelloJmsClient main 
INFO: Found connection factory "jms/RemoteConnectionFactory" in JNDI 
ápr. 09, 2015 8:16:26 DU soi.syhello.jms.client.HelloJmsClient main 
INFO: Attempting to acquire destination "java:/jms/queue/HelloQueue" 
javax.naming.NameNotFoundException: jms/queue/HelloQueue -- service jboss.naming.context.java.jboss.exported.jms.queue.HelloQueue 
    at org.jboss.as.naming.ServiceBasedNamingStore.lookup(ServiceBasedNamingStore.java:104) 
    at org.jboss.as.naming.NamingContext.lookup(NamingContext.java:202) 
    at org.jboss.as.naming.NamingContext.lookup(NamingContext.java:179) 
    at org.jboss.naming.remote.protocol.v1.Protocol$1.handleServerMessage(Protocol.java:127) 
    at org.jboss.naming.remote.protocol.v1.RemoteNamingServerV1$MessageReciever$1.run(RemoteNamingServerV1.java:73) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745) 
ápr. 09, 2015 8:16:26 DU soi.syhello.jms.client.HelloJmsClient main 
SEVERE: jms/queue/HelloQueue -- service jboss.naming.context.java.jboss.exported.jms.queue.HelloQueue 

Хотя очередь видна в консоли администратора:

http://kepfeltoltes.hu/150409/1142213920K_pkiv_g_s_www.kepfeltoltes.hu_.png

проблема со всей этой ситуацией заключается в том, что я создал это из подробного учебника, данного мне моим профессором. Все остальные части работали до сих пор. Что может быть проблемой здесь?

Answer 1

Созданная вами очередь не связана под java:jboss/exported. В случае WildFly доступны только записи под java:jboss/exported через удаленный поиск JNDI.

Измените запись JNDI java:/jms/queue/HelloQueue на queue/HelloQueue.

if (outcome != success) of /subsystem=messaging/hornetq-server=default/jms-queue=HelloQueue:read-resource 
    jms-queue add --queue-address=HelloQueue --entries=queue/HelloQueue,java:jboss/exported/jms/queue/HelloQueue 
end-if