[AMQ-6823] No message received with prefetch 0 over http

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 5.14.5
• Fix Version/s: 5.15.1, 5.16.0
• Component/s: Connector

Environment

Windows, Linux

• Assignee: Timothy A. Bish
• Reporter: John
• Created: 25/Sep/17 13:33
• Updated: 31/Dec/17 07:16
• Resolved: 25/Sep/17 17:28

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();

Issue Links

• is duplicated by: AMQ-6877 http connector - queuePrefetch=0 not working
• is related to: UIMA-5562 UIMA AS fails with HttpConnector