Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add a negative validation test.

This commit is contained in:
Timothy Bish 2015-06-12 15:39:17 -04:00
parent d723d14acb
commit d74c087134
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpSendReceiveTest.java
View File

@ -19,6 +19,7 @@ package org.apache.activemq.transport.amqp.interop;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -86,23 +87,29 @@ public class AmqpSendReceiveTest extends AmqpClientTestSupport {
AmqpConnection connection = client.connect(); AmqpConnection connection = client.connect();
AmqpSession session = connection.createSession(); AmqpSession session = connection.createSession();
AmqpMessage message = new AmqpMessage(); AmqpMessage message1 = new AmqpMessage();
message1.setGroupId("abcdefg");
message1.setApplicationProperty("sn", 100);
message.setGroupId("abcdefg"); AmqpMessage message2 = new AmqpMessage();
message.setApplicationProperty("sn", 100); message2.setGroupId("hijklm");
message2.setApplicationProperty("sn", 200);
AmqpSender sender = session.createSender("queue://" + getTestName()); AmqpSender sender = session.createSender("queue://" + getTestName());
sender.send(message); sender.send(message1);
sender.send(message2);
sender.close(); sender.close();
AmqpReceiver receiver = session.createReceiver("queue://" + getTestName(), "sn = 100"); AmqpReceiver receiver = session.createReceiver("queue://" + getTestName(), "sn = 100");
receiver.flow(1); receiver.flow(2);
AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS); AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS);
assertNotNull(received); assertNotNull(received);
assertEquals(100, received.getApplicationProperty("sn")); assertEquals(100, received.getApplicationProperty("sn"));
assertEquals("abcdefg", received.getGroupId()); assertEquals("abcdefg", received.getGroupId());
received.accept(); received.accept();
assertNull(receiver.receive(1, TimeUnit.SECONDS));
receiver.close(); receiver.close();
} }