Uploaded image for project: 'ActiveMQ Classic'
  1. ActiveMQ Classic
  2. AMQ-6823

No message received with prefetch 0 over http

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 5.14.5
    • 5.15.1, 5.16.0
    • Connector
    • None
    • Windows, Linux

    Description

      The http connector doesn't seem to work with prefetchSize 0.
      It works with tcp connector.

      AMQ configuration:

              <transportConnectors>
                  <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
                  <transportConnector name="http" uri="http://0.0.0.0:8080"/>
              </transportConnectors>
      

      Code to reproduce:

      	String brokerURL = "http://localhost:8080";
      	//String brokerURL = "tcp://localhost:61616";
      	ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(brokerURL);
      	ActiveMQPrefetchPolicy pp = new ActiveMQPrefetchPolicy();
      	pp.setQueuePrefetch(0);
      	cf.setPrefetchPolicy(pp);
      	Connection con = cf.createConnection();
      	con.start();
      	Session s = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
      	Destination d = s.createQueue("test");
      	MessageProducer p = s.createProducer(d);
      	MessageConsumer c = s.createConsumer(d);
      	Message m = new ActiveMQTextMessage();
      	m.setStringProperty("test", "test");
      	p.send(m);
      	c.receive();
      	p.close();
      	s.close();
      	con.stop();
      

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            tabish Timothy A. Bish
            john123 John
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment