John created AMQ-6823:
-------------------------

             Summary: 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)

Reply via email to