Merge from development repository.

[controller.git] / opendaylight / sal / yang-prototype / sal / sal-broker-impl / src / main / java / org / opendaylight / controller / sal / core / impl / ConsumerSessionImpl.java

diff --git a/opendaylight/sal/yang-prototype/sal/sal-broker-impl/src/main/java/org/opendaylight/controller/sal/core/impl/ConsumerSessionImpl.java b/opendaylight/sal/yang-prototype/sal/sal-broker-impl/src/main/java/org/opendaylight/controller/sal/core/impl/ConsumerSessionImpl.java
index 608c24b7b5aabe719511116e9f354cbe4afed885..032dd22e3cf3efa03dbb371295d9f5f5d47c292a 100644 (file)
--- a/opendaylight/sal/yang-prototype/sal/sal-broker-impl/src/main/java/org/opendaylight/controller/sal/core/impl/ConsumerSessionImpl.java
+++ b/opendaylight/sal/yang-prototype/sal/sal-broker-impl/src/main/java/org/opendaylight/controller/sal/core/impl/ConsumerSessionImpl.java
@@ -26,6 +26,7 @@ public class ConsumerSessionImpl implements ConsumerSession {
     private final Consumer consumer;\r
 \r
     private Map<Class<? extends BrokerService>, BrokerService> instantiatedServices = new HashMap<Class<? extends BrokerService>, BrokerService>();\r
+    private boolean closed = false;\r
 \r
     public Consumer getConsumer() {\r
         return consumer;\r
@@ -59,11 +60,16 @@ public class ConsumerSessionImpl implements ConsumerSession {
     @Override\r
     public void close() {\r
         Collection<BrokerService> toStop = instantiatedServices.values();\r
+        this.closed  = true;\r
         for (BrokerService brokerService : toStop) {\r
             brokerService.closeSession();\r
         }\r
         broker.consumerSessionClosed(this);\r
     }\r
 \r
-}\r
-
+    @Override\r
+    public boolean isClosed() {\r
+        return closed;\r
+    }\r
+\r
+}