Repository: qpid-jms Updated Branches: refs/heads/master 99dde7ac2 -> 85f926628
Add client ack test showing that extension of the link credit does not expand the prefetch window in ActiveMQ currently. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/85f92662 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/85f92662 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/85f92662 Branch: refs/heads/master Commit: 85f926628dcad0cab2c3db11000591a9cee3138f Parents: 99dde7a Author: Timothy Bish <[email protected]> Authored: Wed Dec 10 14:24:11 2014 -0500 Committer: Timothy Bish <[email protected]> Committed: Wed Dec 10 14:24:11 2014 -0500 ---------------------------------------------------------------------- .../qpid/jms/consumer/JmsClientAckTest.java | 36 ++++++++++++++++++++ 1 file changed, 36 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/85f92662/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsClientAckTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsClientAckTest.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsClientAckTest.java index aa97a60..699f9ea 100644 --- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsClientAckTest.java +++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsClientAckTest.java @@ -39,6 +39,7 @@ import org.apache.activemq.broker.jmx.QueueViewMBean; import org.apache.qpid.jms.support.AmqpTestSupport; import org.apache.qpid.jms.support.Wait; import org.junit.After; +import org.junit.Ignore; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -358,4 +359,39 @@ public class JmsClientAckTest extends AmqpTestSupport { assertTrue("we got 6 redeliveries", redelivery.await(20, TimeUnit.SECONDS)); } + + @Ignore("Fails until Broker get it's prefetch issues resolved.") + @Test(timeout=60000) + public void testConsumeBeyondInitialPrefetch() throws Exception { + final int MESSAGE_COUNT = 2000; + + final CountDownLatch consumed = new CountDownLatch(MESSAGE_COUNT); + connection = createAmqpConnection(); + connection.start(); + + final Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + Queue queue = session.createQueue(name.getMethodName()); + MessageConsumer consumer = session.createConsumer(queue); + + consumer.setMessageListener(new MessageListener() { + @Override + public void onMessage(Message message) { + try { + LOG.debug("Got message: " + message.getJMSMessageID()); + consumed.countDown(); + } catch (JMSException e) { + e.printStackTrace(); + } + } + }); + + connection.start(); + + MessageProducer producer = session.createProducer(queue); + for (int i = 0; i < MESSAGE_COUNT; ++i) { + producer.send(session.createTextMessage("test: message[" + (i + 1) + "]")); + } + + assertTrue("Failed to get all deliveries", consumed.await(45, TimeUnit.SECONDS)); + } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
