Repository: qpid-jms Updated Branches: refs/heads/master 4f8e3da13 -> 065000dd7
Adds additional tests for property get 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/065000dd Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/065000dd Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/065000dd Branch: refs/heads/master Commit: 065000dd70bfabba4c4654c92e6898de9ffeb46a Parents: 4f8e3da Author: Timothy Bish <tabish...@gmail.com> Authored: Mon Sep 29 18:51:44 2014 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Mon Sep 29 18:51:44 2014 -0400 ---------------------------------------------------------------------- .../JmsMessagePropertyIntercepterTest.java | 114 +++++++++++++++++++ 1 file changed, 114 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/065000dd/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 d3937a7..f469956 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 @@ -60,6 +60,14 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSDestinationWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + JmsDestination destination = new JmsQueue("TestDestination"); + Mockito.when(message.getDestination()).thenReturn(destination); + assertEquals(destination.getName(), JmsMessagePropertyIntercepter.getProperty(message, JMS_DESTINATION)); + } + + @Test public void testSetJMSDestination() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsDestination queue = new JmsQueue("TestDestination"); @@ -82,6 +90,14 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSReplyToWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + JmsDestination destination = new JmsQueue("TestDestination"); + Mockito.when(message.getReplyTo()).thenReturn(destination); + assertEquals(destination.getName(), JmsMessagePropertyIntercepter.getProperty(message, JMS_REPLYTO)); + } + + @Test public void testSetJMSReplyTo() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsDestination queue = new JmsQueue("TestDestination"); @@ -104,6 +120,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSTypeWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getType()).thenReturn("MsgType"); + assertEquals("MsgType", JmsMessagePropertyIntercepter.getProperty(message, JMS_TYPE)); + } + + @Test public void testSetJMSType() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_TYPE, "SomeType"); @@ -125,6 +148,20 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSDeliverModeSetDurable() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.isPersistent()).thenReturn(true); + assertEquals("PERSISTENT", JmsMessagePropertyIntercepter.getProperty(message, JMS_DELIVERY_MODE)); + } + + @Test + public void testGetJMSDeliverModeSetNonDurable() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.isPersistent()).thenReturn(false); + assertEquals("NON_PERSISTENT", JmsMessagePropertyIntercepter.getProperty(message, JMS_DELIVERY_MODE)); + } + + @Test public void testSetJMSDeliveryMode() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_DELIVERY_MODE, "PERSISTENT"); @@ -163,6 +200,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSPriorityWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getPriority()).thenReturn((byte) 9); + assertEquals(9, JmsMessagePropertyIntercepter.getProperty(message, JMS_PRIORITY)); + } + + @Test public void testSetJMSPriority() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_PRIORITY, 9); @@ -184,6 +228,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSMessageIdWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getMessageId()).thenReturn("MESSAGE_ID"); + assertEquals("MESSAGE_ID", JmsMessagePropertyIntercepter.getProperty(message, JMS_MESSAGEID)); + } + + @Test public void testSetJMSMessageId() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_MESSAGEID, "ID:123456-789"); @@ -206,6 +257,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSTimeStampWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getTimestamp()).thenReturn(900L); + assertEquals(900L, JmsMessagePropertyIntercepter.getProperty(message, JMS_TIMESTAMP)); + } + + @Test public void testSetJMSTimeStamp() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_TIMESTAMP, 65536L); @@ -227,6 +285,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSCorrelationIdWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getCorrelationId()).thenReturn("MESSAGE_ID"); + assertEquals("MESSAGE_ID", JmsMessagePropertyIntercepter.getProperty(message, JMS_CORRELATIONID)); + } + + @Test public void testSetJMSCorrelationId() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_CORRELATIONID, "ID:123456-789"); @@ -249,6 +314,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSExpirationWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getExpiration()).thenReturn(900L); + assertEquals(900L, JmsMessagePropertyIntercepter.getProperty(message, JMS_EXPIRATION)); + } + + @Test public void testSetJMSExpiration() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_EXPIRATION, 65536L); @@ -270,6 +342,20 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSRedeliveredWhenSetTrue() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.isRedelivered()).thenReturn(true); + assertEquals(true, JmsMessagePropertyIntercepter.getProperty(message, JMS_REDELIVERED)); + } + + @Test + public void testGetJMSRedeliveredWhenSetFalse() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.isRedelivered()).thenReturn(false); + assertEquals(false, JmsMessagePropertyIntercepter.getProperty(message, JMS_REDELIVERED)); + } + + @Test public void testSetJMSRedelivered() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMS_REDELIVERED, true); @@ -293,6 +379,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSXGroupIdWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getGroupId()).thenReturn("GROUP_ID"); + assertEquals("GROUP_ID", JmsMessagePropertyIntercepter.getProperty(message, JMSX_GROUPID)); + } + + @Test public void testSetJMSXGroupId() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMSX_GROUPID, "MyGroupID"); @@ -314,6 +407,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSXGroupSeqWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getGroupSequence()).thenReturn(95); + assertEquals(95, JmsMessagePropertyIntercepter.getProperty(message, JMSX_GROUPSEQ)); + } + + @Test public void testSetJMSXGroupSeq() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMSX_GROUPSEQ, 65536); @@ -335,6 +435,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSXDeliverCountWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getRedeliveryCounter()).thenReturn(2); + assertEquals(3, JmsMessagePropertyIntercepter.getProperty(message, JMSX_DELIVERY_COUNT)); + } + + @Test public void testSetJMSXDeliveryCount() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMSX_DELIVERY_COUNT, 32768); @@ -356,6 +463,13 @@ public class JmsMessagePropertyIntercepterTest { } @Test + public void testGetJMSXUserIdWhenSet() throws JMSException { + JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); + Mockito.when(message.getUserId()).thenReturn("Administrator"); + assertEquals("Administrator", JmsMessagePropertyIntercepter.getProperty(message, JMSX_USERID)); + } + + @Test public void testSetJMSXUserId() throws JMSException { JmsMessageFacade message = Mockito.mock(JmsMessageFacade.class); JmsMessagePropertyIntercepter.setProperty(message, JMSX_USERID, "Administrator"); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
