You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2010/01/05 21:26:03 UTC
svn commit: r896201 -
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
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);
}