@override void publish(Stream<NEW_EVENT> newEvent, EventBus bus) { bus.publishFromStream(newEvent, key.toString()); }