Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-609

session = conn.createSession(false,Session.AUTO_ACKNOWLEDGE); hangs for amqp, and amqp+nio

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Critical Critical
    • JBoss A-MQ 6.1
    • JBoss A-MQ 6.1
    • broker
    • None
    • Hide

      Steps to reproduce:
      0) Uncomment line admin=admin,admin in etc/users.properties
      1)Before starting fuse in etc/activemq.xml substitute line:

      <transportConnector name="openwire" uri="tcp://0.0.0.0:0?maximumConnections=1000"/>
      

      with

         <transportConnector name="amqp" uri="amqp://0.0.0.0:5672"/>
      

      or

       <transportConnector name="amqp" uri="amqp+nio://localhost:5672"/>
      

      2) Using the following dependencies:

       <dependency>
                  <groupId>org.apache.qpid</groupId>
                  <artifactId>qpid-amqp-1-0-client-jms</artifactId>
                  <version>0.26</version>
              </dependency>
              <dependency>
        <groupId>org.apache.geronimo.specs</groupId>
        <artifactId>geronimo-jms_1.1_spec</artifactId>
        <version>1.0</version>
      </dependency>
      

      I ran the following test:

      @Before
          public void init() throws JMSException, NamingException {     
          	// JNDI lookup of JMS Connection Factory and JMS Destination
              Context context = new InitialContext();
              conFactiory = (ConnectionFactory) context.lookup(CONNECTION_FACTORY_NAME);
              conn=conFactiory.createConnection();
              session=conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
              conn.start();
          }
      
      @Test
      ...

      and the tests hangs on the line

       session = conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
      
      Show
      Steps to reproduce: 0) Uncomment line admin=admin,admin in etc/users.properties 1)Before starting fuse in etc/activemq.xml substitute line: <transportConnector name= "openwire" uri= "tcp: //0.0.0.0:0?maximumConnections=1000" /> with <transportConnector name= "amqp" uri= "amqp: //0.0.0.0:5672" /> or <transportConnector name= "amqp" uri= "amqp+nio: //localhost:5672" /> 2) Using the following dependencies: <dependency> <groupId>org.apache.qpid</groupId> <artifactId>qpid-amqp-1-0-client-jms</artifactId> <version>0.26</version> </dependency> <dependency> <groupId>org.apache.geronimo.specs</groupId> <artifactId>geronimo-jms_1.1_spec</artifactId> <version>1.0</version> </dependency> I ran the following test: @Before public void init() throws JMSException, NamingException { // JNDI lookup of JMS Connection Factory and JMS Destination Context context = new InitialContext(); conFactiory = (ConnectionFactory) context.lookup(CONNECTION_FACTORY_NAME); conn=conFactiory.createConnection(); session=conn.createSession( false ,Session.AUTO_ACKNOWLEDGE); conn.start(); } @Test ... and the tests hangs on the line session = conn.createSession( false ,Session.AUTO_ACKNOWLEDGE);

            gertv_jira Gert Vanthienen (Inactive)
            emedvede Elena Medvedeva (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

              Created:
              Updated:
              Resolved: