[
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)
