class RabbitMQTerminationSubscriber implements TerminationSubscriber, Startable, Closeable {

    @Override
    public Publisher<Event> listenEvents() {
        return listener
            .share();
    }

    @Inject  RabbitMQTerminationSubscriber(Sender sender, ReceiverProvider receiverProvider, JsonEventSerializer serializer);

}