Injecter JMS ConnectionFactory et la file d'attente dans un WebSocket?

Question

J'ai un simple WebSocket implémenté dans JavaEE 7 que j'aimerais utiliser comme producteur JMS. Cependant, quand j'essaye d'injecter le ConnectionFactory et le Queue dedans comme JavaEE @Resource je vois toujours qu'il est nul. Mon code ressemble à ceci:

@Named 
@ServerEndpoint("/hello") 
public class WebSocketA implements Serializable { 

    @Resource(mappedName = "java:/JmsXA") 
    private ConnectionFactory connectionFactory = null; 

    @Resource(mappedName = "java:jboss/exported/jms/queue/test") 
    private Queue testQueue = null; 

    ... 

} 

Y at-il une raison pour laquelle je ne peux pas injecter ces Resource s? Cela n'est-il pas pris en charge dans JavaEE WebSockets? Je déploie sur Wildfly 8.1, et mon application est une simple WAR avec seulement la classe d'implémentation WebSocket à l'intérieur.

Answer 1

Il semble qu'il y ait quelques problèmes avec l'injection JMS en utilisant certains beans CDI. J'ai été en mesure de faire fonctionner l'injection en utilisant @javax.inject.Singleton ou @javax.ejb.Stateless. J'ai supprimé l'annotation @Named dans les deux cas. Je n'ai pas testé l'injection du Queue, juste le ConnectionFactory

Je l'ai testé avec la dernière Glassfish 4 build promu avec un projet web simple avec juste la classe WebSocket:

@Stateless 
@ServerEndpoint("/hello") 
public class WsTest implements Serializable { 
    private static final Logger LOG = Logger.getLogger(WsTest.class.getName()); 

    @Resource(mappedName = "java:comp/DefaultJMSConnectionFactory") 
    private ConnectionFactory connectionFactory = null; 

    @OnOpen 
    public void onOpen(Session session) throws IOException { 
     LOG.log(Level.INFO, "onOpen {0}", connectionFactory); 
     session.getBasicRemote().sendText("onOpen"); 
    } 

    @OnMessage 
    public String echo(String message) { 
     LOG.log(Level.INFO, "onMessage({0}) {1}", new Object[]{message, connectionFactory}); 
     return message + " (from your server)"; 
    } 

    @OnError 
    public void onError(Throwable t) { 
     LOG.log(Level.INFO, "onError {0}", connectionFactory); 
    } 

    @OnClose 
    public void onClose(Session session) { 
     LOG.log(Level.INFO, "onClose {0}", connectionFactory); 
    } 
}