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 2017/03/06 23:29:59 UTC

[35/50] [abbrv] activemq-nms-stomp git commit: Fix compile for .NET-CF 2.0. Fixes https://issues.apache.org/jira/browse/AMQNET-394

Fix compile for .NET-CF 2.0.  Fixes https://issues.apache.org/jira/browse/AMQNET-394


Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/commit/e15675c1
Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/tree/e15675c1
Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/diff/e15675c1

Branch: refs/heads/1.5.x
Commit: e15675c137961695510abb87cd6ce259e09b94ed
Parents: fd6ddc4
Author: Jim Gomes <jg...@apache.org>
Authored: Mon Aug 20 18:13:06 2012 +0000
Committer: Jim Gomes <jg...@apache.org>
Committed: Mon Aug 20 18:13:06 2012 +0000

----------------------------------------------------------------------
 src/main/csharp/Connection.cs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/e15675c1/src/main/csharp/Connection.cs
----------------------------------------------------------------------
diff --git a/src/main/csharp/Connection.cs b/src/main/csharp/Connection.cs
index ba3ccd3..45e03ec 100755
--- a/src/main/csharp/Connection.cs
+++ b/src/main/csharp/Connection.cs
@@ -682,8 +682,10 @@ namespace Apache.NMS.Stomp
                 }
             }
 
-            Tracer.Error("No such consumer active: " + dispatch.ConsumerId);
-            transport.Oneway(new RemoveInfo() { ObjectId = dispatch.ConsumerId });
+            Tracer.Error("No such consumer active: {0}.  Removing...", dispatch.ConsumerId);
+            RemoveInfo info  = new RemoveInfo();
+            info.ObjectId = dispatch.ConsumerId;
+            transport.Oneway(info);
         }
 
         protected void OnTransportException(ITransport sender, Exception exception)