You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2014/12/10 20:24:41 UTC
qpid-jms git commit: Add client ack test showing that extension of
the link credit does not expand the prefetch window in ActiveMQ currently.
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 <ta...@gmail.com>
Authored: Wed Dec 10 14:24:11 2014 -0500
Committer: Timothy Bish <ta...@gmail.com>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org