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 2015/01/20 17:40:14 UTC
qpid-jms git commit: Run the send / recv bits a couple times in a row.
Repository: qpid-jms
Updated Branches:
refs/heads/master edc8ce8cf -> 3bcaf7dc7
Run the send / recv bits a couple times in a row.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/3bcaf7dc
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/3bcaf7dc
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/3bcaf7dc
Branch: refs/heads/master
Commit: 3bcaf7dc78acc579eec762f731d73887c8ea7bca
Parents: edc8ce8
Author: Timothy Bish <ta...@gmail.com>
Authored: Tue Jan 20 11:40:10 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Tue Jan 20 11:40:10 2015 -0500
----------------------------------------------------------------------
.../usecases/JmsLargeMessagesInGroupsTest.java | 33 +++++++++++---------
1 file changed, 19 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/3bcaf7dc/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java
index 0b29fea..1418451 100644
--- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java
+++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java
@@ -18,6 +18,8 @@ package org.apache.qpid.jms.usecases;
import static org.junit.Assert.assertNotNull;
+import java.util.concurrent.atomic.AtomicInteger;
+
import javax.jms.BytesMessage;
import javax.jms.DeliveryMode;
import javax.jms.Message;
@@ -35,22 +37,25 @@ public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport {
protected static final Logger LOG = LoggerFactory.getLogger(JmsLargeMessagesInGroupsTest.class);
+ private static final int ITERATIONS = 10;
private static final int MESSAGE_COUNT = 10;
- private static final int MESSAGE_SIZE = 100 * 1024;
+ private static final int MESSAGE_SIZE = 200 * 1024;
private static final int RECEIVE_TIMEOUT = 5000;
private static final String JMSX_GROUP_ID = "JmsGroupsTest";
- private int sequenceCount = 0;
-
- @Test
+ @Test(timeout = 60 * 1000)
public void testGroupSeqIsNeverLost() throws Exception {
- connection = createAmqpConnection();
- connection.start();
-
- sendMessagesToBroker(MESSAGE_COUNT);
- readMessagesOnBroker(MESSAGE_COUNT);
- sendMessagesToBroker(MESSAGE_COUNT);
- readMessagesOnBroker(MESSAGE_COUNT);
+ AtomicInteger sequenceCounter = new AtomicInteger();
+
+ for (int i = 0; i < ITERATIONS; ++i) {
+ connection = createAmqpConnection();
+ {
+ sendMessagesToBroker(MESSAGE_COUNT, sequenceCounter);
+ connection.start();
+ readMessagesOnBroker(MESSAGE_COUNT);
+ }
+ connection.close();
+ }
}
protected void readMessagesOnBroker(int count) throws Exception {
@@ -71,7 +76,7 @@ public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport {
consumer.close();
}
- protected void sendMessagesToBroker(int count) throws Exception {
+ protected void sendMessagesToBroker(int count, AtomicInteger sequence) throws Exception {
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(getDestinationName());
MessageProducer producer = session.createProducer(queue);
@@ -84,12 +89,12 @@ public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport {
buffer[count] = (byte) value;
}
- LOG.debug("Sending {} messages to destination: {}", MESSAGE_COUNT, queue);
+ LOG.info("Sending {} messages to destination: {}", MESSAGE_COUNT, queue);
for (int i = 1; i <= MESSAGE_COUNT; i++) {
BytesMessage message = session.createBytesMessage();
message.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
message.setStringProperty("JMSXGroupID", JMSX_GROUP_ID);
- message.setIntProperty("JMSXGroupSeq", ++sequenceCount);
+ message.setIntProperty("JMSXGroupSeq", sequence.incrementAndGet());
message.writeBytes(buffer);
producer.send(message);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org