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/10/15 17:50:49 UTC

[3/3] git commit: start testing the message transformation bits.

start testing the message transformation bits.

Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/a088d998
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/a088d998
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/a088d998

Branch: refs/heads/master
Commit: a088d99805ef6ede9eb321009324ad3441d2c6ab
Parents: a757bab
Author: Timothy Bish <ta...@gmail.com>
Authored: Wed Oct 15 11:45:48 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Wed Oct 15 11:45:48 2014 -0400

----------------------------------------------------------------------
 .../message/JmsMessageTransformationTest.java   | 35 ++++++++++++++++++++
 1 file changed, 35 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/a088d998/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
index 84c294f..8dc485b 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
@@ -19,6 +19,7 @@ package org.apache.qpid.jms.message;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNotSame;
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertSame;
 import static org.junit.Assert.assertTrue;
@@ -34,6 +35,7 @@ import javax.jms.Topic;
 import org.apache.qpid.jms.JmsConnection;
 import org.apache.qpid.jms.JmsDestination;
 import org.apache.qpid.jms.JmsTopic;
+import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFacade;
 import org.junit.Test;
 import org.mockito.Mockito;
 
@@ -49,6 +51,39 @@ public class JmsMessageTransformationTest {
         new JmsMessageTransformation();
     }
 
+    //---------- Test Message Transformation ---------------------------------//
+
+    @Test
+    public void testTransformJmsMessageCopies() throws JMSException {
+        JmsMessage source = new JmsMessage(new JmsDefaultMessageFacade());
+
+        source.setJMSMessageID("ID:CONNECTION:1:1");
+
+        JmsMessage copy = JmsMessageTransformation.transformMessage(createMockJmsConnection(), source);
+        assertNotNull(copy.getJMSMessageID());
+        assertEquals(source, copy);
+        assertNotSame(source, copy);
+    }
+
+    //---------- Test Generic Property Copy ----------------------------------//
+
+    @Test
+    public void testJMSMessagePropertiesAreCopied() throws JMSException {
+        JmsMessage source = new JmsMessage(new JmsDefaultMessageFacade());
+        JmsMessage target = new JmsMessage(new JmsDefaultMessageFacade());
+
+        source.setJMSType("text/test");
+
+        source.setBooleanProperty("boolValue", true);
+        source.setStringProperty("stringValue", "foo");
+
+        JmsMessageTransformation.copyProperties(createMockJmsConnection(), source, target);
+
+        assertEquals(true, target.getBooleanProperty("boolValue"));
+        assertEquals("foo", target.getStringProperty("stringValue"));
+        assertEquals("text/test", target.getJMSType());
+    }
+
     //---------- Test Destination Transformation -----------------------------//
 
     @Test


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org