Queues up messages internally until it can successfully call basicPublish.
Notifies the caller using a robust ID (not delivery tag) when the message is confirmed by rabbit.
This is a layer above the RabbitMQClient that provides a lot of standard implementation when guaranteed at least once delivery is required.
If confirmations are not required do not use this publisher as it does have overhead.
Like stop(Handler) but returns a Future of the asynchronous result
Undo the effects of calling stop(Handler) so that publish may be called again.
It is harmless to call restart() when stop(Handler) has not been called, however if restart() is called
whilst stop(Handler) is being processed the stop(Handler) will never complete.
Get the ReadStream that contains the message IDs for confirmed messages.
The message IDs in this ReadStream are taken from the message properties,
if these message IDs are not set then this ReadStream will contain nulls and using this publisher will be pointless.
the ReadStream that contains the message IDs for confirmed messages.