[ https://issues.jboss.org/browse/WFLY-9529?page=com.atlassian.jira.plugin.... ] Peter Schulz edited comment on WFLY-9529 at 2/13/19 5:58 AM: ------------------------------------------------------------- Hi, I just ran into the same issue and started digging further and found the answer in [Kohei Nozaki's blog post|https://nozaki.me/roller/kyle/entry/in-container-jms-consumer-producer]: The bean which gets {{JMSContext}} injected *must be an EJB*, since the "missing" component {{java:comp/TransactionSynchronizationRegistry}} is only known inside the EJB wildfly-module. {code:java} import javax.annotation.Resource; import javax.ejb.LocalBean; import javax.ejb.Stateless; import javax.inject.Inject; import javax.jms.BytesMessage; import javax.jms.CompletionListener; import javax.jms.DeliveryMode; import javax.jms.JMSConnectionFactory; import javax.jms.JMSContext; import javax.jms.JMSException; import javax.jms.JMSProducer; import javax.jms.Message; import javax.jms.Queue; import org.slf4j.Logger; /** * See https://nozaki.me/roller/kyle/entry/in-container-jms-consumer-producer */ @Stateless @LocalBean public class MessageProducer { @Inject private Logger logger; @Inject @JMSConnectionFactory("java:/ConnectionFactory") private JMSContext context; @Resource(name = "java:/jms/queue/requestQueue") private Queue queue; private CompletionListener completionListener = new CompletionListener() { @Override public void onCompletion(Message message) { logger.debug("delivered message"); } @Override public void onException(Message message, Exception exception) { logger.warn("failed to deliver message", exception); } }; public void enqueue(Request request) { try { createProducer().send(queue, convert(request)); } catch (JMSException e) { logger.error("failed to create message/convert request " + request, e); } } private JMSProducer createProducer() { JMSProducer producer = context.createProducer(); producer.setJMSCorrelationID("SEQUENTIAL_REQUEST"); producer.setDeliveryMode(DeliveryMode.PERSISTENT); producer.setDisableMessageTimestamp(false); producer.setDisableMessageID(false); producer.setAsync(completionListener); producer.setTimeToLive(0); return producer; } private BytesMessage convert(Request request) throws JMSException { // ... } } {code} was (Author: schulzp): Hi, I just ran into the same issue and started digging deeper: The bean which gets {{JMSContext}} injected *must be an EJB*, since the "missing" component {{java:comp/TransactionSynchronizationRegistry}} is only known inside the EJB wildfly-module. {code:java} import javax.annotation.Resource; import javax.ejb.LocalBean; import javax.ejb.Stateless; import javax.inject.Inject; import javax.jms.BytesMessage; import javax.jms.CompletionListener; import javax.jms.DeliveryMode; import javax.jms.JMSConnectionFactory; import javax.jms.JMSContext; import javax.jms.JMSException; import javax.jms.JMSProducer; import javax.jms.Message; import javax.jms.Queue; import org.slf4j.Logger; /** * See https://nozaki.me/roller/kyle/entry/in-container-jms-consumer-producer */ @Stateless @LocalBean public class MessageProducer { @Inject private Logger logger; @Inject @JMSConnectionFactory("java:/ConnectionFactory") private JMSContext context; @Resource(name = "java:/jms/queue/requestQueue") private Queue queue; private CompletionListener completionListener = new CompletionListener() { @Override public void onCompletion(Message message) { logger.debug("delivered message"); } @Override public void onException(Message message, Exception exception) { logger.warn("failed to deliver message", exception); } }; public void enqueue(Request request) { try { createProducer().send(queue, convert(request)); } catch (JMSException e) { logger.error("failed to create message/convert request " + request, e); } } private JMSProducer createProducer() { JMSProducer producer = context.createProducer(); producer.setJMSCorrelationID("SEQUENTIAL_REQUEST"); producer.setDeliveryMode(DeliveryMode.PERSISTENT); producer.setDisableMessageTimestamp(false); producer.setDisableMessageID(false); producer.setAsync(completionListener); producer.setTimeToLive(0); return producer; } private BytesMessage convert(Request request) throws JMSException { // ... } } {code} -- This message was sent by Atlassian Jira (v7.12.1#712002)