activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r896201 - /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
Date Tue, 05 Jan 2010 20:26:03 GMT
Author: tabish
Date: Tue Jan  5 20:26:03 2010
New Revision: 896201

URL: http://svn.apache.org/viewvc?rev=896201&view=rev
Log:
Have the Unmarshaller remove any unused "receipt" headers left in messages we receive.

Modified:
    activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs

Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs?rev=896201&r1=896200&r2=896201&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
Tue Jan  5 20:26:03 2010
@@ -195,6 +195,10 @@
                 message = new TextMessage(encoder.GetString(frame.Content, 0, frame.Content.Length));
             }
 
+            // Remove any receipt header we might have attached if the outbound command was
+            // sent with response required set to true
+            frame.RemoveProperty("receipt");
+
             message.Type = frame.RemoveProperty("type");
             message.Destination = StompHelper.ToDestination(frame.RemoveProperty("destination"));
             message.ReplyTo = StompHelper.ToDestination(frame.RemoveProperty("reply-to"));
@@ -300,8 +304,10 @@
 			{
 				frame.SetProperty("JMSXGroupID", command.NMSXGroupID);
 				frame.SetProperty("NMSXGroupID", command.NMSXGroupID);
+                frame.SetProperty("JMSXGroupSeq", command.NMSXGroupSeq);
+                frame.SetProperty("NMSXGroupSeq", command.NMSXGroupSeq);
 			}
-			
+
             // Perform any Content Marshaling.
             command.BeforeMarshall(this);
             
@@ -319,7 +325,7 @@
             {
                 frame.SetProperty(key, map[key]);
             }
-            
+
             frame.ToStream(dataOut);
         }
 



Mime
View raw message