[
https://issues.apache.org/jira/browse/AMQ-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16179390#comment-16179390
]
ASF subversion and git services commented on AMQ-6823:
------------------------------------------------------
Commit eccbd75bcffdb1ae0e160e06383f6a2dffca6e88 in activemq's branch
refs/heads/activemq-5.15.x from [~tabish121]
[ https://git-wip-us.apache.org/repos/asf?p=activemq.git;h=eccbd75 ]
AMQ-6823 Ensure that MessagePull is works across HTTP transport
The MessagePull command needs to have the transients initialized such
that the pull operation works across transports that use XStream or
other marshaling that doesn't performs custom serialization.
(cherry picked from commit a21dd40527d1576c8fa0029ca2996961af12bb9a)
> 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
>
> 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)
