[
https://issues.apache.org/jira/browse/AMQ-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16179389#comment-16179389
]
ASF subversion and git services commented on AMQ-6823:
------------------------------------------------------
Commit a21dd40527d1576c8fa0029ca2996961af12bb9a in activemq's branch
refs/heads/master from [~tabish121]
[ https://git-wip-us.apache.org/repos/asf?p=activemq.git;h=a21dd40 ]
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.
> 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)
