+ public void activate()
+ {
+ if (active)
+ {
+ log.info("{} is already active!", service.getChatRoomId());
+ return;
+ }
+
+ log.info("{} is being activated", service.getChatRoomId());
+ this.sink = createSink();
+ active = true;
+ }
+
+ public void deactivate()