svn commit: r379451 - in /incubator/servicemix/trunk/servicemix-core/src: main/java/org/apache/servicemix/jbi/messaging/ExchangePacket.java test/java/org/apache/servicemix/jbi/messaging/MessageExchangeImplTest.java

[gn...@apache.org]

Author: gnodet
Date: Tue Feb 21 05:45:58 2006
New Revision: 379451

URL: http://svn.apache.org/viewcvs?rev=379451&view=rev
Log:
SM-323: operation not getting passed when a message goes through jmsflow

Modified:
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/ExchangePacket.java
    incubator/servicemix/trunk/servicemix-core/src/test/java/org/apache/servicemix/jbi/messaging/MessageExchangeImplTest.java

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/ExchangePacket.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/ExchangePacket.java?rev=379451&r1=379450&r2=379451&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/ExchangePacket.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/ExchangePacket.java Tue Feb 21 05:45:58 2006
@@ -366,6 +366,7 @@
         output.writeObject(sourceId);
         output.writeObject(serviceName);
         output.writeObject(interfaceName);
+        output.writeObject(operationName);
         output.writeObject(error);
         output.writeObject(properties);
         output.writeObject(in);
@@ -390,6 +391,7 @@
         sourceId = (ComponentNameSpace) input.readObject();
         serviceName = (QName) input.readObject();
         interfaceName = (QName) input.readObject();
+        operationName = (QName) input.readObject();
         error = (Exception) input.readObject();
         properties = (Map) input.readObject();
         in = (NormalizedMessage) input.readObject();

Modified: incubator/servicemix/trunk/servicemix-core/src/test/java/org/apache/servicemix/jbi/messaging/MessageExchangeImplTest.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/test/java/org/apache/servicemix/jbi/messaging/MessageExchangeImplTest.java?rev=379451&r1=379450&r2=379451&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/test/java/org/apache/servicemix/jbi/messaging/MessageExchangeImplTest.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/test/java/org/apache/servicemix/jbi/messaging/MessageExchangeImplTest.java Tue Feb 21 05:45:58 2006
@@ -24,6 +24,7 @@
 
 import javax.jbi.messaging.MessageExchange;
 import javax.jbi.messaging.NormalizedMessage;
+import javax.xml.namespace.QName;
 import javax.xml.transform.Source;
 import javax.xml.transform.stream.StreamSource;
 
@@ -40,6 +41,7 @@
 	
     protected void testSerializeDeserialize(Source src) throws Exception {
         MessageExchange me = new InOnlyImpl("exchangeId");
+        me.setOperation(new QName("uri", "op"));
         me.setProperty("myProp", "myValue");
         NormalizedMessage msg = me.createMessage();
         msg.setProperty("myMsgProp", "myMsgValue");
@@ -59,6 +61,7 @@
         assertNotNull(out);
         assertTrue(out instanceof MessageExchange);
         MessageExchange meOut = (MessageExchange) out;
+        assertEquals(new QName("uri", "op"), meOut.getOperation());
         assertEquals("myValue", meOut.getProperty("myProp"));
         NormalizedMessage msgOut = meOut.getMessage("in");
         assertNotNull(msgOut);