Wildfly 10 с JMS (ActiveMQ)

Question

Я успешно настроен сервер Wildfly с ActiveMQ как поток

<subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0"> 
     <server name="default"> 
      <security enabled="false"/> 
      <http-connector name="http-connector" socket-binding="http" endpoint="http-acceptor"/> 
      <http-acceptor name="http-acceptor" http-listener="default"/> 
      <jms-queue name="UpdateQueue" entries="java:/jms/UpdateQueue java:jboss/exported/jms/UpdateQueue"/> 
      <connection-factory name="ConnectionFactory" entries="java:jboss/exported/jms/ConnectionFactory" connectors="http-connector"/> 
     </server> 
    </subsystem> 

Сообщения отправки/успешно получить из очереди, используя по умолчанию реализацию нативные javax.jms.

Я использую следующую конфигурацию для доступа к очереди JMS для отправки/получения.

String EX_JNDI_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory"; 
    String SERVER_URL = "http-remoting://127.0.0.1:8080"; 
    String JMS_FACTORY = "jms/ConnectionFactory"; 
    String QUEUE_NAME = "jms/UpdateQueue"; 

В большинстве случаев сообщения заняло слишком много времени между передачей и приемом, иногда его заняло 3 минуты между отправкой и получением сообщения, я не знаю причину такого поведения. Есть идеи?

Answer 1

I класс получает несколько раз, не закрывая приемник, сеанс и соединение. Я добавил следующий код после qreceiver.receive (0), и все работает нормально.

try{ 
     if (qreceiver != null){ 
      qreceiver.close(); 
      qreceiver = null; 
     } 

     qsession.close(); 
     qcon.close(); 
    }catch (JMSException e) { 
     e.printStackTrace(); 
    }