QPID-4027 Made modifications to reflect the changes made to interfaces.

Fixed bugs identified in testing.

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/address-refactor2@1354074 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 7 deletions

diff --git a/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java b/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
index 8df574a74d..79f87db4d5 100644
--- a/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
+++ b/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
@@ -34,7 +34,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
     private long _failoverTimeout = Long.getLong("qpid.failover-timeout", 1000);
     private ReceiverException _lastException;
     private long _connSerialNumber = 0;
-    
+
     public SenderFailoverDecorator(SessionInternal ssn, SenderInternal delegate)
     {
         super(ssn,delegate);
@@ -72,7 +72,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
             if (_state == SenderState.CLOSED)
             {
                 throw new MessagingException("Sender is already closed");
-            }   
+            }
             _state = SenderState.CLOSED;
             super.close();
         }
@@ -188,7 +188,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
             _delegate.recreate();
         }
     }
-    
+
     @Override
     public void eventOccured(ConnectionEvent event)
     {
@@ -206,7 +206,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
             case POST_FAILOVER:
                 try
                 {
-                    if (_state != SenderState.OPENED) 
+                    if (_state != SenderState.OPENED)
                     {
                         close();
                     }
@@ -218,7 +218,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
                 _connectionLock.notifyAll();
                 break;
             default:
-                break; //ignore the rest 
+                break; //ignore the rest
             }
         }
     }
@@ -246,7 +246,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
             }
         }
     }
-    
+
     protected void failover(TransportFailureException e, long serialNumber) throws SenderException
     {
         synchronized (_connectionLock)
@@ -260,7 +260,7 @@ public class SenderFailoverDecorator extends AbstractSenderDecorator implements
             waitForFailoverToComplete();
         }
     }
-    
+
     protected void checkPreConditions() throws SenderException
     {
         switch (_state)