Constructor and Description |
---|
SendOptions() |
Modifier and Type | Method and Description |
---|---|
SendOptions |
channelCloseHandler(BiConsumer<SignalType,Channel> channelCloseHandler)
Set the channel closing logic.
|
SendOptions |
channelMono(Mono<? extends Channel> channelMono)
Set the channel mono to use to send messages.
|
SendOptions |
channelPool(ChannelPool channelPool)
Set the channel pool to use to send messages.
|
SendOptions |
exceptionHandler(BiConsumer<Sender.SendContext,Exception> exceptionHandler) |
BiConsumer<SignalType,Channel> |
getChannelCloseHandler()
Return the channel closing logic.
|
Mono<? extends Channel> |
getChannelMono()
Return the channel mono to use to send messages.
|
BiConsumer<Sender.SendContext,Exception> |
getExceptionHandler() |
Integer |
getMaxInFlight()
Returns the maximum number of in-flight records that are fetched
from the outbound record publisher while publisher confirms are pending.
|
Scheduler |
getScheduler()
The scheduler used for publishing send results.
|
boolean |
isTrackReturned()
Returns whether we should track returned (undeliverable) messages when publisher confirms are in use.
|
SendOptions |
maxInFlight(int maxInFlight)
Set the maximum number of in-flight records that are fetched
from the outbound record publisher while publisher confirms are pending.
|
SendOptions |
maxInFlight(int maxInFlight,
Scheduler scheduler)
Set the maximum number of in-flight records that are fetched
from the outbound record publisher while publisher confirms are pending.
|
SendOptions |
trackReturned(boolean trackReturned)
Set whether we should track returned (undeliverable) messages when publisher confirms are in use.
|
@Nullable public Integer getMaxInFlight()
public boolean isTrackReturned()
Sender.sendWithPublishConfirms(Publisher, SendOptions)
,
Mandatory flagpublic SendOptions trackReturned(boolean trackReturned)
Default is false.
trackReturned
- SendOptions
instanceSender.sendWithPublishConfirms(Publisher, SendOptions)
,
Mandatory flagpublic SendOptions maxInFlight(int maxInFlight)
The number of in-flight records is not limited by default.
maxInFlight
- SendOptions
instancepublic SendOptions maxInFlight(int maxInFlight, Scheduler scheduler)
Scheduler
maxInFlight
- scheduler
- SendOptions
instancepublic Scheduler getScheduler()
public BiConsumer<Sender.SendContext,Exception> getExceptionHandler()
public SendOptions exceptionHandler(BiConsumer<Sender.SendContext,Exception> exceptionHandler)
@Nullable public Mono<? extends Channel> getChannelMono()
public SendOptions channelMono(@Nullable Mono<? extends Channel> channelMono)
channelMono
- SendOptions
instance@Nullable public BiConsumer<SignalType,Channel> getChannelCloseHandler()
public SendOptions channelCloseHandler(@Nullable BiConsumer<SignalType,Channel> channelCloseHandler)
channelCloseHandler
- SendOptions
instancepublic SendOptions channelPool(ChannelPool channelPool)
It is developer's responsibility to close it if set.
channelPool
- SendOptions
instance