diff options
| author | Keith Wall <kwall@apache.org> | 2011-11-21 10:54:11 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2011-11-21 10:54:11 +0000 |
| commit | 6a87aae37fd453e320240c64a4629764dd302b3f (patch) | |
| tree | 5907cc2ee897ccd5f39d737be064235d6f556240 /qpid/java | |
| parent | b9d3c7ab66711163a6494fab998bfbc6d483abbf (diff) | |
| download | qpid-python-6a87aae37fd453e320240c64a4629764dd302b3f.tar.gz | |
QPID-3622: Removal of unwanted SortedQueue tests.
Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1204443 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java | 53 |
1 files changed, 0 insertions, 53 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java index 83046b84a5..bf4dbcb19f 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java @@ -257,59 +257,6 @@ public class SortedQueueTest extends QpidBrokerTestCase assertEquals("Incorrect number of messages received", 100, messageCount); } - public void testGetNext() throws JMSException, NamingException, AMQException - { - final Queue queue = createQueue(); - final MessageProducer producer = _producerSession.createProducer(queue); - - sendAndCommitMessage(producer,"2"); - sendAndCommitMessage(producer,"3"); - sendAndCommitMessage(producer,"1"); - - final Session consumerSession = _consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); - final MessageConsumer consumer = consumerSession.createConsumer(queue); - _consumerConnection.start(); - receiveAndValidateMessage(consumer, "1"); - receiveAndValidateMessage(consumer, "2"); - receiveAndValidateMessage(consumer, "3"); - - sendAndCommitMessage(producer,"4"); - - receiveAndValidateMessage(consumer, "4"); - - sendAndCommitMessage(producer,"7"); - sendAndCommitMessage(producer,"6"); - sendAndCommitMessage(producer,"5"); - - // pre-fetch causes "unexpected" order - receiveAndValidateMessage(consumer, "7"); - receiveAndValidateMessage(consumer, "5"); - receiveAndValidateMessage(consumer, "6"); - } - - public void testGetNextPreFetch() throws JMSException, NamingException, AMQException - { - final Queue queue = createQueue(); - final MessageProducer producer = _producerSession.createProducer(queue); - - sendAndCommitMessage(producer,"1"); - - final Session consumerSession = _consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); - final MessageConsumer consumer = consumerSession.createConsumer(queue); - _consumerConnection.start(); - receiveAndValidateMessage(consumer, "1"); - - producer.send(getSortableTestMesssage("4")); - producer.send(getSortableTestMesssage("3")); - producer.send(getSortableTestMesssage("2")); - _producerSession.commit(); - - // pre-fetch causes "unexpected" order - receiveAndValidateMessage(consumer, "4"); - receiveAndValidateMessage(consumer, "2"); - receiveAndValidateMessage(consumer, "3"); - } - public void testGetNextWithAck() throws JMSException, NamingException, AMQException { Queue _queue = createQueue(); |
