reactor.rabbitmq

Interface ChannelPool

All Superinterfaces:

AutoCloseable

public interface ChannelPool
extends AutoCloseable

Contract to obtain a Channel and close when sending messages.

Implementations would typically make it possible to re-use Channels across different calls to Sender#send* methods.

Since:

1.1.0

See Also:

SendOptions, Sender.send(Publisher), Sender.send(Publisher, SendOptions), Sender.sendWithPublishConfirms(Publisher), Sender.send(Publisher, SendOptions)

Method Summary

Modifier and Type	Method and Description
void	close() Close the pool when it is no longer necessary.
BiConsumer<SignalType,Channel>	getChannelCloseHandler() The closing logic when the Channel is disposed.
Mono<? extends Channel>	getChannelMono() The Channel to use for sending a flux of messages.

Method Detail

getChannelMono

Mono<? extends Channel> getChannelMono()

The Channel to use for sending a flux of messages.

Returns:

the channel mono to use

getChannelCloseHandler

BiConsumer<SignalType,Channel> getChannelCloseHandler()

The closing logic when the Channel is disposed.

Returns:

the closing logic to use

close

void close()

Close the pool when it is no longer necessary.

Specified by:

close in interface AutoCloseable