JMS消息生成器不会将消息发送到队列

Question

我设置了一个EJB项目，使用JMS将持久性实体对象发送到MDB。我使用JBoss EAP 7，使用Apache ActiveMQ作为消息传递提供程序。我像这样设置ConnectionFactory和队列：

这是我的消息生成器，它接收“Account”实体对象作为参数并将其发送到队列：

EntityEnqueueBean。Java语言

@Stateless
@LocalBean
public class EntityEnqueueBean {

  Context context = null;

  public void enqueueEntity(Account accountEntity) {    
      try {
          context = new InitialContext();
          ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("java:/ConnectionFactory");
          Destination queue = (Destination) context.lookup("java:/jms/queue/AccountAccessQueue");
          Connection connection = connectionFactory.createConnection();
          Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
          MessageProducer messageProducer = session.createProducer(queue);
          ObjectMessage objectMessage = session.createObjectMessage(accountEntity);
          messageProducer.send(objectMessage);

          messageProducer.close();
          session.close();
          connection.close();
      } catch (JMSException | NamingException e) {
          e.printStackTrace();
        }
   }
}

MDB从队列接收消息并对其进行处理：

java账户

@MessageDriven(
    activationConfig = { @ActivationConfigProperty(
            propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
            @ActivationConfigProperty( propertyName = "destination", 
            propertyValue ="java:/jms/queue/AccountAccessQueue")
    })
public class AccountPersitenceMDB implements MessageListener {

  public void onMessage(Message message) {
      ObjectMessage objectMessage = null;
      objectMessage = (ObjectMessage) message;
      try {
          Account accountEntity = (Account) objectMessage.getObject();
          System.out.println("MDB accessCount: " + accountEntity.getAccessCount());
      } catch (JMSException e) {
          e.printStackTrace();
      }
  }
}

不确定我做错了什么。我可能把设置ConnectionFactory和队列的代码弄错了，但我不确定，因为我是JavaEE的新手。感谢任何帮助。

Answer 1

多亏了@mendieta，我解决了这个问题。我阅读了JMS会话，它非常有意义。在EntityEnqueueBean中更改此行。java做到了这一点：

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);