Author: rgreig
Date: Wed Feb 28 07:43:24 2007
New Revision: 512814
URL: http://svn.apache.org/viewvc?view=rev&rev=512814
Log:
(Patch submitted by Tomas Restrepo) QPID-385.
Client was confusing connection failure with failover. Patch fixes.
Modified:
incubator/qpid/trunk/qpid/dotnet/ (props changed)
incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/AMQProtocolListener.cs
incubator/qpid/trunk/qpid/dotnet/TopicListener/ (props changed)
incubator/qpid/trunk/qpid/dotnet/TopicPublisher/ (props changed)
Propchange: incubator/qpid/trunk/qpid/dotnet/
------------------------------------------------------------------------------
--- svn:ignore (original)
+++ svn:ignore Wed Feb 28 07:43:24 2007
@@ -2,3 +2,6 @@
build
dotnet.userprefs
_ReSharper.Qpid.NET
+Qpid.NET.resharper
+Qpid.NET.resharper.user
+Qpid.NET.suo
Modified:
incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/AMQProtocolListener.cs
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/AMQProtocolListener.cs?view=diff&rev=512814&r1=512813&r2=512814
==============================================================================
---
incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/AMQProtocolListener.cs
(original)
+++
incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/AMQProtocolListener.cs
Wed Feb 28 07:43:24 2007
@@ -148,7 +148,7 @@
{
if (_failoverState == FailoverState.NOT_STARTED)
{
- if (!(cause is AMQUndeliveredException))
+ if (cause is AMQConnectionClosedException)
{
WhenClosed();
}
@@ -195,7 +195,7 @@
if (_failoverState == FailoverState.NOT_STARTED)
{
_failoverState = FailoverState.IN_PROGRESS;
- startFailoverThread();
+ StartFailoverThread();
}
else
{
@@ -273,10 +273,10 @@
_failoverHandler.setHost(host);
_failoverHandler.setPort(port);
// see javadoc for FailoverHandler to see rationale for separate
thread
- startFailoverThread();
+ StartFailoverThread();
}
- private void startFailoverThread()
+ private void StartFailoverThread()
{
Thread failoverThread = new Thread(new
ThreadStart(_failoverHandler.Run));
failoverThread.Name = "Failover";
Propchange: incubator/qpid/trunk/qpid/dotnet/TopicListener/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Wed Feb 28 07:43:24 2007
@@ -0,0 +1,2 @@
+bin
+obj
Propchange: incubator/qpid/trunk/qpid/dotnet/TopicPublisher/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Wed Feb 28 07:43:24 2007
@@ -0,0 +1,2 @@
+bin
+obj
