[jira] [Commented] (AMQ-6823) No message received with prefetch 0 over http

["Tim Bain (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/AMQ-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16307132#comment-16307132 ] 

Tim Bain commented on AMQ-6823:
-------------------------------

Do we believe that this was introduced in 5.14.5 as indicated by the Affects Version(s) field, or do we think this goes further back in the version history? Maintaining an accurate Affects Version value helps users know whether their version of the broker is believed to be prone to a bug or not, so if we believe this goes further back (as implied by AMQ-6877), it would be great if we could update the field.

I looked at the fix and wasn't clear on why that would relate to the behavior described, which made it impossible to figure out at which point the problem was introduced, otherwise I'd do this myself. So hopefully [~tabish121] can shed some light on when the problem was introduced.

> No message received with prefetch 0 over http
> ---------------------------------------------
>
>                 Key: AMQ-6823
>                 URL: https://issues.apache.org/jira/browse/AMQ-6823
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Connector
>    Affects Versions: 5.14.5
>         Environment: Windows, Linux
>            Reporter: John
>            Assignee: Timothy Bish
>             Fix For: 5.15.1, 5.16.0
>
>
> The http connector doesn't seem to work with prefetchSize 0.
> It works with tcp connector.
> AMQ configuration:
> {code}
>         <transportConnectors>
>             <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
>             <transportConnector name="http" uri="http://0.0.0.0:8080"/>
>         </transportConnectors>
> {code}
> Code to reproduce:
> {code}
> 	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();
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)