summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorKeith Wall <kwall@apache.org>2011-11-21 10:54:11 +0000
committerKeith Wall <kwall@apache.org>2011-11-21 10:54:11 +0000
commite37a9ec224b9598a31eaac3d2d2af4ea3309788e (patch)
tree59588ebf5f0de9c0021374b81d71badf840f2a25 /java
parenta790ee8ff09b9bfd13a733359ab59c1fcbb3173a (diff)
downloadqpid-python-e37a9ec224b9598a31eaac3d2d2af4ea3309788e.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/qpid@1204443 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java53
1 files changed, 0 insertions, 53 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java b/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java
index 83046b84a5..bf4dbcb19f 100644
--- a/java/systests/src/main/java/org/apache/qpid/server/queue/SortedQueueTest.java
+++ b/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();