JMS生产者关闭

Question

通过HornetQ的使用Wildfly和JMS，我得到这个例外

javax.ejb.EJBTransactionRolledbackException: Producer is closed 

它发生每隔几小时一次或两次。

Caused by: javax.jms.IllegalStateRuntimeException: Producer is closed 
     at org.hornetq.jms.client.JmsExceptionUtils.convertToRuntimeException(JmsExceptionUtils.java:60) [hornetq-jms-client-2.4.1.Final.jar:] 
     at org.hornetq.jms.client.HornetQJMSProducer.send(HornetQJMSProducer.java:112) [hornetq-jms-client-2.4.1.Final.jar:] 
     at org.hornetq.jms.client.HornetQJMSProducer.send(HornetQJMSProducer.java:230) [hornetq-jms-client-2.4.1.Final.jar:] 
     at com.turbineam.tradeagent.message.MessageSender.sendMessage(MessageSender.java:26) [classes:] 
     at com.turbineam.tradeagent.agent.TradeAgent.sendMessage(TradeAgent.java:36) [classes:] 
     at com.turbineam.tradeagent.agent.TradeAgent.handleMessage(TradeAgent.java:82) [classes:] 
     at sun.reflect.GeneratedMethodAccessor273.invoke(Unknown Source) [:1.8.0_05] 
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_05] 
     at java.lang.reflect.Method.invoke(Method.java:483) [rt.jar:1.8.0_05] 
     at org.jboss.as.ee.component.ManagedReferenceMethodInterceptor.processInvocation(ManagedReferenceMethodInterceptor.java:52) 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.WeavedInterceptor.processInvocation(WeavedInterceptor.java:53) 
     at org.jboss.as.ee.component.interceptors.UserInterceptorFactory$1.processInvocation(UserInterceptorFactory.java:63) 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.InterceptorContext$Invocation.proceed(InterceptorContext.java:407) 
     at org.jboss.as.weld.ejb.Jsr299BindingsInterceptor.doMethodInterception(Jsr299BindingsInterceptor.java:82) [wildfly-weld-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.as.weld.ejb.Jsr299BindingsInterceptor.processInvocation(Jsr299BindingsInterceptor.java:93) [wildfly-weld-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.as.ee.component.interceptors.UserInterceptorFactory$1.processInvocation(UserInterceptorFactory.java:63) 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.WeavedInterceptor.processInvocation(WeavedInterceptor.java:53) 
     at org.jboss.as.ee.component.interceptors.UserInterceptorFactory$1.processInvocation(UserInterceptorFactory.java:63) 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.as.ejb3.component.invocationmetrics.ExecutionTimeInterceptor.processInvocation(ExecutionTimeInterceptor.java:43) [wildfly-ejb3-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.InterceptorContext$Invocation.proceed(InterceptorContext.java:407) 
     at org.jboss.as.ejb3.concurrency.ContainerManagedConcurrencyInterceptor.processInvocation(ContainerManagedConcurrencyInterceptor.java:104) [wildfly-ejb3-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.InterceptorContext$Invocation.proceed(InterceptorContext.java:407) 
     at org.jboss.weld.ejb.AbstractEJBRequestScopeActivationInterceptor.aroundInvoke(AbstractEJBRequestScopeActivationInterceptor.java:46) [weld-core-impl-2.2.6.Final.jar:2014-10-03 10:05] 
     at org.jboss.as.weld.ejb.EjbRequestScopeActivationInterceptor.processInvocation(EjbRequestScopeActivationInterceptor.java:83) [wildfly-weld-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.as.ee.concurrent.ConcurrentContextInterceptor.processInvocation(ConcurrentContextInterceptor.java:45) [wildfly-ee-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.InitialInterceptor.processInvocation(InitialInterceptor.java:21) 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:61) 
     at org.jboss.as.ee.component.interceptors.ComponentDispatcherInterceptor.processInvocation(ComponentDispatcherInterceptor.java:53) 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.as.ejb3.component.singleton.SingletonComponentInstanceAssociationInterceptor.processInvocation(SingletonComponentInstanceAssociationInterceptor.java:52) [wildfly-ejb3-8.2.0.Final.jar:8.2.0.Final] 
     at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309) 
     at org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInCallerTx(CMTTxInterceptor.java:251) [wildfly-ejb3-8.2.0.Final.jar:8.2.0.Final] 
     ... 201 more 
Caused by: javax.jms.IllegalStateException: Producer is closed 
     at org.hornetq.jms.client.HornetQMessageProducer.checkClosed(HornetQMessageProducer.java:537) [hornetq-jms-client-2.4.1.Final.jar:] 
     at org.hornetq.jms.client.HornetQMessageProducer.send(HornetQMessageProducer.java:206) [hornetq-jms-client-2.4.1.Final.jar:] 
     at org.hornetq.jms.client.HornetQMessageProducer.send(HornetQMessageProducer.java:200) [hornetq-jms-client-2.4.1.Final.jar:] 
     at org.hornetq.ra.HornetQRAMessageProducer.send(HornetQRAMessageProducer.java:145) 
     at org.hornetq.jms.client.HornetQJMSProducer.send(HornetQJMSProducer.java:107) [hornetq-jms-client-2.4.1.Final.jar:] 
     ... 240 more 

发件人创建如下：

@Slf4j 
public class MessageSender { 

    @Inject 
    @JMSConnectionFactory("java:jboss/DefaultJMSConnectionFactory") 
    private JMSContext context; 

    public void sendMessage(Destination destination, String messageId, Serializable serializable) throws NamingException, JMSException { 

     log.debug("Sending a message: " + serializable.toString()); 
     context.createProducer().setJMSCorrelationID(messageId).send(destination, serializable); 
    } 
} 

也许我失去了一些东西，但我不明白为什么会发生。如何正确处理？我绝对需要这个消息发送不管什么。提前致谢。

编辑：

我想这导致我解决这个问题最重要的是，不时我得到了（除了封闭的监制）：

WARN [org.hornetq.core.client] (ejb) HQ214021: Invalid concurrent session usage. Sessions are not supposed to be used by more than one thread concurrently. 

豆我注入MessageSender用@Stateless注释。

Answer 1

好吧，在我设法解决这个问题的许多尝试之后。这个设置有什么问题，如果MessageSender没有提供确定范围，那么它就是@Dependent。这意味着它是注入到bean的范围。在这种情况下，@Stateless。只创建了一个会话。来自@Stateless bean的方法可以同时运行，这是问题的主要原因。 sendMeasge使用相同的JMS会话。解决此问题最简单的方法是确保sendMessage中始终存在一个或创建多个会话。一个我找到了解决办法是通过以下方式使用@RequestScope：

@Slf4j 
@RequestScope 
public class MessageSender { 

    @Inject 
    @JMSConnectionFactory("java:jboss/DefaultJMSConnectionFactory") 
    private JMSContext context; 

    public void sendMessage(Destination destination, String messageId, Serializable serializable) throws NamingException, JMSException { 

     log.debug("Sending a message: " + serializable.toString()); 
     context.createProducer().setJMSCorrelationID(messageId).send(destination, serializable); 
    } 
} 

在上面的例子中，我们每次我们发送消息时，创建会话 - 所以不再并发会话使用的问题，它的封闭生产者的问题也消失了。

如果有人有兴趣，我建议futher阅读来自： http://www.mastertheboss.com/jboss-server/jboss-jms/jms-20-tutorial-on-wildfly-as