This is an automated email from the ASF dual-hosted git repository.
robbie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-jms.git
The following commit(s) were added to refs/heads/master by this push:
new 0b83c0c NO-JIRA: remove some mostly-broker-tests which are covered
better from a client perspective in the client module aleady
0b83c0c is described below
commit 0b83c0c2a48e2dddfa5038529e153ee88037154d
Author: Robbie Gemmell <rob...@apache.org>
AuthorDate: Thu Jan 9 13:37:46 2020 +0000
NO-JIRA: remove some mostly-broker-tests which are covered better from a
client perspective in the client module aleady
---
.../qpid/jms/consumer/JmsZeroPrefetchTest.java | 96 ----------------------
1 file changed, 96 deletions(-)
diff --git
a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsZeroPrefetchTest.java
b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsZeroPrefetchTest.java
index 7c75446..3148d18 100644
---
a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsZeroPrefetchTest.java
+++
b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsZeroPrefetchTest.java
@@ -86,67 +86,6 @@ public class JmsZeroPrefetchTest extends AmqpTestSupport {
}
@Test(timeout = 60000)
- public void testReceiveTimesOutAndRemovesCredit() throws Exception {
- connection = createAmqpConnection();
- connection.start();
-
- Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- Queue queue = session.createQueue(getDestinationName());
- MessageConsumer consumer = session.createConsumer(queue);
- Message answer = consumer.receive(100);
- assertNull("Should have not received a message!", answer);
-
- MessageProducer producer = session.createProducer(queue);
- producer.send(session.createTextMessage("Hello World! 1"));
-
- final QueueViewMBean queueView = getProxyToQueue(getDestinationName());
-
- // Assert that we only pulled one message and that we didn't cause
- // the other message to be dispatched.
- assertTrue(Wait.waitFor(new Wait.Condition() {
-
- @Override
- public boolean isSatisfied() throws Exception {
- return queueView.getQueueSize() == 1;
- }
- }));
-
- assertEquals(0, queueView.getInFlightCount());
- }
-
- @Test(timeout = 60000)
- public void testReceiveNoWaitWaitForSever() throws Exception {
- connection = createAmqpConnection();
- connection.start();
-
- Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- Queue queue = session.createQueue(getDestinationName());
- MessageProducer producer = session.createProducer(queue);
- producer.send(session.createTextMessage("Hello World! 1"));
-
- MessageConsumer consumer = session.createConsumer(queue);
- Message answer = consumer.receiveNoWait();
- assertNotNull("Should have received a message!", answer);
-
- // Send another, it should not get dispatched.
- producer.send(session.createTextMessage("Hello World! 2"));
-
- final QueueViewMBean queueView = getProxyToQueue(getDestinationName());
-
- // Assert that we only pulled one message and that we didn't cause
- // the other message to be dispatched.
- assertTrue(Wait.waitFor(new Wait.Condition() {
-
- @Override
- public boolean isSatisfied() throws Exception {
- return queueView.getQueueSize() == 1;
- }
- }));
-
- assertEquals(0, queueView.getInFlightCount());
- }
-
- @Test(timeout = 60000)
public void testRepeatedPullAttempts() throws Exception {
connection = createAmqpConnection();
connection.start();
@@ -169,41 +108,6 @@ public class JmsZeroPrefetchTest extends AmqpTestSupport {
}
@Test(timeout = 60000)
- public void testPullConsumerOnlyRequestsOneMessage() throws Exception {
- connection = createAmqpConnection();
- connection.start();
-
- Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- Queue queue = session.createQueue(getDestinationName());
- MessageProducer producer = session.createProducer(queue);
- producer.send(session.createTextMessage("Hello World! 1"));
- producer.send(session.createTextMessage("Hello World! 2"));
-
- final QueueViewMBean queueView = getProxyToQueue(getDestinationName());
-
- // Check initial Queue State
- assertEquals(2, queueView.getQueueSize());
- assertEquals(0, queueView.getInFlightCount());
-
- // now lets receive it
- MessageConsumer consumer = session.createConsumer(queue);
- Message answer = consumer.receive(5000);
- assertNotNull("Should have received a message!", answer);
-
- // Assert that we only pulled one message and that we didn't cause
- // the other message to be dispatched.
- assertTrue(Wait.waitFor(new Wait.Condition() {
-
- @Override
- public boolean isSatisfied() throws Exception {
- return queueView.getQueueSize() == 1;
- }
- }));
-
- assertEquals(0, queueView.getInFlightCount());
- }
-
- @Test(timeout = 60000)
public void testTwoConsumers() throws Exception {
connection = createAmqpConnection();
connection.start();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
