class SagaMessageStream implements MessageStream {

    @Override
    public void add(@Nonnull final Object message) {
        checkNotNull(message, "Message to handle must not be null.");
        addMessage(message, EMPTY_HEADERS);
    }

    @Inject public  SagaMessageStream(
            final HandlerInvoker invoker,
            final SagaEnvironment environment,
            final Executor executor);

}