activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r512224 - /activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
Date Tue, 27 Feb 2007 11:25:24 GMT
Author: jstrachan
Date: Tue Feb 27 03:25:17 2007
New Revision: 512224

URL: http://svn.apache.org/viewvc?view=rev&rev=512224
Log:
fix for AMQNET-21

Modified:
    activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs?view=diff&rev=512224&r1=512223&r2=512224
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
(original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
Tue Feb 27 03:25:17 2007
@@ -117,7 +117,7 @@
             // Exception Handling
             // ------------------
             // If an Exception occurs during the reading/marshalling, then the connection
-            // is effectively broken because psoition cannot be re-established to the next
+            // is effectively broken because position cannot be re-established to the next
             // message.  This is reported to the app via the exceptionHandler and the socket
             // is closed to prevent further communication attempts.
             //
@@ -133,7 +133,7 @@
                 }
                 catch(Exception ex)
                 {
-                    if( !closed.Value ) 
+                    if( !closed.Value )
                     {
                         this.exceptionHandler(this, ex);
                         // Close the socket as there's little that can be done with this
transport now.
@@ -144,9 +144,12 @@
 
                 try
                 {
-                    this.commandHandler(this, command);
+					if (command != null)
+					{
+						this.commandHandler(this, command);
+					}
                 }
-                catch ( Exception e) 
+                catch ( Exception e)
                 {
                     this.exceptionHandler(this, e);
                 }



Mime
View raw message