+ public void activate()
+ {
+ log.info("{} is being activated", service.getChatRoomId());
+ this.sink = createSink();
+ active = true;
+ }
+
+ public void deactivate()
+ {
+ log.info("{} is being deactivated", service.getChatRoomId());
+ active = false;
+ sink.emitComplete(Sinks.EmitFailureHandler.FAIL_FAST);
+ }
+