svn commit: r889374 - in /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol: StompHelper.cs StompWireFormat.cs

[tabish]

Author: tabish
Date: Thu Dec 10 19:12:51 2009
New Revision: 889374

URL: http://svn.apache.org/viewvc?rev=889374&view=rev
Log:
Fix issue with MessageAck

Modified:
    
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompHelper.cs
    
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/StompHelper.cs
URL: 
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompHelper.cs?rev=889374&r1=889373&r2=889374&view=diff
==============================================================================
--- 
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompHelper.cs
 (original)
+++ 
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompHelper.cs
 Thu Dec 10 19:12:51 2009
@@ -255,6 +255,7 @@
                 }
             }
             answer.ProducerId = ToProducerId(text);
+
             return answer;
         }
 

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=889374&r1=889373&r2=889374&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
 Thu Dec 10 19:12:51 2009
@@ -103,14 +103,11 @@
         }
 
         public Object Unmarshal(BinaryReader dataIn)
-        {
-            Tracer.Debug("StompWireFormat - Command Read in Progress...");
-            
+        {            
             StompFrame frame = new StompFrame();
             frame.FromStream(dataIn);
             
             Object answer = CreateCommand(frame);
-            Tracer.Debug("StompWireFormat - Command received: " + answer);
             return answer;
         }
 
@@ -152,7 +149,7 @@
             {
                 string text = frame.RemoveProperty("receipt-id");
 
-                Tracer.Debug("StompWireFormat - Received ERROR command: 
CorrelationId = " + text);
+                Tracer.Debug("StompWireFormat - Received ERROR command:");
                 
                 if(text != null && text.StartsWith("ignore:"))
                 {
@@ -419,7 +416,7 @@
 
         protected virtual void WriteMessageAck(MessageAck command, 
BinaryWriter dataOut)
         {
-            StompFrame frame = new StompFrame("SEND");
+            StompFrame frame = new StompFrame("ACK");
             if(command.ResponseRequired)
             {
                 frame.SetProperty("receipt", "ignore:" + command.CommandId);