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
@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
+}