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 2014/09/30 00:30:43 UTC
git commit: Add some tests for property set intercepters
Repository: qpid-jms
Updated Branches:
refs/heads/master d9803914a -> 4f8e3da13
Add some tests for property set intercepters
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/4f8e3da1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/4f8e3da1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/4f8e3da1
Branch: refs/heads/master
Commit: 4f8e3da138cb895e3d33533665794858bb73bab7
Parents: d980391
Author: Timothy Bish <ta...@gmail.com>
Authored: Mon Sep 29 18:30:35 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Mon Sep 29 18:30:35 2014 -0400
----------------------------------------------------------------------
.../JmsMessagePropertyIntercepterTest.java | 119 +++++++++++++++++++
1 file changed, 119 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/4f8e3da1/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessagePropertyIntercepterTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessagePropertyIntercepterTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessagePropertyIntercepterTest.java
index 63252c6..d3937a7 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessagePropertyIntercepterTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessagePropertyIntercepterTest.java
@@ -37,6 +37,8 @@ import static org.junit.Assert.assertTrue;
import javax.jms.JMSException;
+import org.apache.qpid.jms.JmsDestination;
+import org.apache.qpid.jms.JmsQueue;
import org.apache.qpid.jms.message.facade.JmsMessageFacade;
import org.junit.Test;
import org.mockito.Mockito;
@@ -57,6 +59,14 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getDestination();
}
+ @Test
+ public void testSetJMSDestination() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsDestination queue = new JmsQueue("TestDestination");
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DESTINATION, "TestDestination");
+ Mockito.verify(message).setDestination(queue);
+ }
+
//---------- JMSReplyTo --------------------------------------------------//
@Test
@@ -71,6 +81,14 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getReplyTo();
}
+ @Test
+ public void testSetJMSReplyTo() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsDestination queue = new JmsQueue("TestDestination");
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_REPLYTO, "TestDestination");
+ Mockito.verify(message).setReplyTo(queue);
+ }
+
//---------- JMSType -----------------------------------------------------//
@Test
@@ -85,6 +103,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getType();
}
+ @Test
+ public void testSetJMSType() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_TYPE, "SomeType");
+ Mockito.verify(message).setType("SomeType");
+ }
+
//---------- JMSDeliveryMode ---------------------------------------------//
@Test
@@ -99,6 +124,29 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).isPersistent();
}
+ @Test
+ public void testSetJMSDeliveryMode() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, "PERSISTENT");
+ Mockito.verify(message).setPersistent(true);
+ Mockito.reset(message);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, "NON_PERSISTENT");
+ Mockito.verify(message).setPersistent(false);
+ Mockito.reset(message);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, 2);
+ Mockito.verify(message).setPersistent(true);
+ Mockito.reset(message);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, 1);
+ Mockito.verify(message).setPersistent(false);
+ Mockito.reset(message);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, true);
+ Mockito.verify(message).setPersistent(true);
+ Mockito.reset(message);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, false);
+ Mockito.verify(message).setPersistent(false);
+ Mockito.reset(message);
+ }
+
//---------- JMSPriority ---------------------------------------------//
@Test
@@ -114,6 +162,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getPriority();
}
+ @Test
+ public void testSetJMSPriority() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_PRIORITY, 9);
+ Mockito.verify(message).setPriority((byte) 9);
+ }
+
//---------- JMSMessageID ---------------------------------------------//
@Test
@@ -128,6 +183,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getMessageId();
}
+ @Test
+ public void testSetJMSMessageId() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_MESSAGEID, "ID:123456-789");
+ Mockito.verify(message).setMessageId("ID:123456-789");
+ }
+
//---------- JMSTimestamp ---------------------------------------------//
@Test
@@ -143,6 +205,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getTimestamp();
}
+ @Test
+ public void testSetJMSTimeStamp() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_TIMESTAMP, 65536L);
+ Mockito.verify(message).setTimestamp(65536L);
+ }
+
//---------- JMSCorrelationID ---------------------------------------------//
@Test
@@ -157,6 +226,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getCorrelationId();
}
+ @Test
+ public void testSetJMSCorrelationId() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_CORRELATIONID, "ID:123456-789");
+ Mockito.verify(message).setCorrelationId("ID:123456-789");
+ }
+
//---------- JMSExpiration ---------------------------------------------//
@Test
@@ -172,6 +248,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getExpiration();
}
+ @Test
+ public void testSetJMSExpiration() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_EXPIRATION, 65536L);
+ Mockito.verify(message).setExpiration(65536L);
+ }
+
//---------- JMSRedelivered ---------------------------------------------//
@Test
@@ -186,6 +269,15 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).isRedelivered();
}
+ @Test
+ public void testSetJMSRedelivered() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_REDELIVERED, true);
+ Mockito.verify(message).setRedelivered(true);
+ JmsMessagePropertyIntercepter.setProperty(message, JMS_REDELIVERED, false);
+ Mockito.verify(message).setRedelivered(false);
+ }
+
//---------- JMSXGroupID ---------------------------------------------//
@Test
@@ -200,6 +292,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getGroupId();
}
+ @Test
+ public void testSetJMSXGroupId() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMSX_GROUPID, "MyGroupID");
+ Mockito.verify(message).setGroupId("MyGroupID");
+ }
+
//---------- JMSXGroupSeq ---------------------------------------------//
@Test
@@ -214,6 +313,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getGroupSequence();
}
+ @Test
+ public void testSetJMSXGroupSeq() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMSX_GROUPSEQ, 65536);
+ Mockito.verify(message).setGroupSequence(65536);
+ }
+
//---------- JMSXDeliveryCount ---------------------------------------------//
@Test
@@ -228,6 +334,13 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getRedeliveryCounter();
}
+ @Test
+ public void testSetJMSXDeliveryCount() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMSX_DELIVERY_COUNT, 32768);
+ Mockito.verify(message).setRedeliveryCounter(32767);
+ }
+
//---------- JMSXUserID ---------------------------------------------//
@Test
@@ -242,4 +355,10 @@ public class JmsMessagePropertyIntercepterTest {
Mockito.verify(message).getUserId();
}
+ @Test
+ public void testSetJMSXUserId() throws JMSException {
+ JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class);
+ JmsMessagePropertyIntercepter.setProperty(message, JMSX_USERID, "Administrator");
+ Mockito.verify(message).setUserId("Administrator");
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org