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 2013/10/09 18:14:22 UTC
svn commit: r1530698 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.cs
Author: tabish
Date: Wed Oct 9 16:14:22 2013
New Revision: 1530698
URL: http://svn.apache.org/r1530698
Log:
https://issues.apache.org/jira/browse/AMQNET-448
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Failover/FailoverTransport.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=1530698&r1=1530697&r2=1530698&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 Wed Oct 9 16:14:22 2013
@@ -467,13 +467,13 @@ namespace Apache.NMS.ActiveMQ.Transport.
connectedToPriority = false;
connected = false;
- if(this.Interrupted != null)
- {
- this.Interrupted(transport);
- }
-
if (reconnectOk)
{
+ if(this.Interrupted != null)
+ {
+ this.Interrupted(transport);
+ }
+
updated.Remove(failedConnectTransportURI);
reconnectTask.Wakeup();
}