BUG-54 : switched channel pipeline to be protocol specific.

[bgpcep.git] / framework / src / test / java / org / opendaylight / protocol / framework / SimpleSessionListener.java

diff --git a/framework/src/test/java/org/opendaylight/protocol/framework/SimpleSessionListener.java b/framework/src/test/java/org/opendaylight/protocol/framework/SimpleSessionListener.java
index 127279d8eea830b11b79cd57d8e9228c0b04d4e8..40a6509cf2577ab5f13ddb0bc82307593a9318be 100644 (file)
--- a/framework/src/test/java/org/opendaylight/protocol/framework/SimpleSessionListener.java
+++ b/framework/src/test/java/org/opendaylight/protocol/framework/SimpleSessionListener.java
@@ -31,13 +31,6 @@ public class SimpleSessionListener implements SessionListener<SimpleMessage, Sim
                this.messages.add(message);
        }
 
-       public synchronized void onConnectionFailed(final ProtocolSession<?> session, final Exception e) {
-               logger.debug("Connection Failed: {}", e.getMessage(), e);
-               this.failed = true;
-               this.notifyAll();
-               session.close();
-       }
-
        @Override
        public void onSessionUp(final SimpleSession session) {
                this.up = true;
@@ -45,12 +38,13 @@ public class SimpleSessionListener implements SessionListener<SimpleMessage, Sim
 
        @Override
        public void onSessionDown(final SimpleSession session, final Exception e) {
-               this.up = false;
+               this.failed = true;
+               this.notifyAll();
        }
 
        @Override
-       public void onSessionTerminated(final SimpleSession session,
-                       final TerminationReason reason) {
-               this.up = false;
+       public void onSessionTerminated(final SimpleSession session, final TerminationReason reason) {
+               this.failed = true;
+               this.notifyAll();
        }
 }