activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1033967 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport: Failover/FailoverTransport.cs InactivityMonitor.cs ResponseCorrelator.cs
Date Thu, 11 Nov 2010 15:44:16 GMT
Author: tabish
Date: Thu Nov 11 15:44:16 2010
New Revision: 1033967

URL: http://svn.apache.org/viewvc?rev=1033967&view=rev
Log:
Replaces the Command is X calls with the lighter weight IsXXX that are generated into the
Commands themselves.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/ResponseCorrelator.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.cs?rev=1033967&r1=1033966&r2=1033967&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.cs
Thu Nov 11 15:44:16 2010
@@ -538,7 +538,7 @@ namespace Apache.NMS.ActiveMQ.Transport.
 						return;
 					}
 
-					if(command is RemoveInfo)
+					if(command.IsRemoveInfo)
 					{
 						// Simulate response to RemoveInfo command
 						OnCommand(this, new Response() { CorrelationId = command.CommandId });

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs?rev=1033967&r1=1033966&r2=1033967&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
Thu Nov 11 15:44:16 2010
@@ -201,7 +201,7 @@ namespace Apache.NMS.ActiveMQ.Transport
             inRead.Value = true;
             try
             {
-                if(command is KeepAliveInfo)
+                if(command.IsKeepAliveInfo)
                 {
                     KeepAliveInfo info = command as KeepAliveInfo;
                     if(info.ResponseRequired)
@@ -217,7 +217,7 @@ namespace Apache.NMS.ActiveMQ.Transport
                         }
                     }
                 }
-                else if(command is WireFormatInfo)
+                else if(command.IsWireFormatInfo)
                 {
                     lock(monitor)
                     {
@@ -255,7 +255,7 @@ namespace Apache.NMS.ActiveMQ.Transport
                     {
                         throw new IOException("Channel was inactive for too long: " + next.RemoteAddress.ToString());
                     }
-                    if(command is WireFormatInfo)
+                    if(command.IsWireFormatInfo)
                     {
                         lock(monitor)
                         {

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/ResponseCorrelator.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/ResponseCorrelator.cs?rev=1033967&r1=1033966&r2=1033967&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/ResponseCorrelator.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/ResponseCorrelator.cs
Thu Nov 11 15:44:16 2010
@@ -112,7 +112,7 @@ namespace Apache.NMS.ActiveMQ.Transport
 
         protected override void OnCommand(ITransport sender, Command command)
         {
-            if(command is Response)
+            if(command.IsResponse)
             {
                 Response response = (Response) command;
                 int correlationId = response.CorrelationId;



Mime
View raw message