|
@@ -35,6 +35,7 @@ class FakeModuleCCSession:
|
|
|
# the message_queue is empty when receive is called, throw
|
|
|
# a SessionTimeout
|
|
|
self._timeout = 0
|
|
|
+ self._closed = False
|
|
|
|
|
|
def group_subscribe(self, group_name, instance_name = None):
|
|
|
if not group_name in self.subscriptions:
|
|
@@ -95,6 +96,7 @@ class FakeModuleCCSession:
|
|
|
def close(self):
|
|
|
# need to pass along somehow that this function has been called,
|
|
|
self._socket = "closed"
|
|
|
+ self._closed = True
|
|
|
|
|
|
def set_timeout(self, timeout):
|
|
|
self._timeout = timeout
|