Interface OutboundQueueHandler
- 
- All Known Subinterfaces:
- OutboundQueueProvider
 - All Known Implementing Classes:
- OutboundQueueProviderImpl
 
 @Beta public interface OutboundQueueHandlerHandler of the outbound queue. The queue has a maximum depth assigned when the handler is registered.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description @NonNull BarrierInputcreateBarrierRequest(@NonNull Long xid)Create a newbarriermessage.voidonConnectionQueueChanged(OutboundQueue queue)Invoked whenever the underlying queue is refreshed.
 
- 
- 
- 
Method Detail- 
createBarrierRequest@NonNull BarrierInput createBarrierRequest(@NonNull Long xid) Create a newbarriermessage. This callback is invoked when the queue is being flushed to the switch. The barrier ensures that any outstanding requests are detected as either completed or failed.- Parameters:
- xid- XID for the barrier message
- Returns:
- New barrier message.
 
 - 
onConnectionQueueChangedvoid onConnectionQueueChanged(OutboundQueue queue) Invoked whenever the underlying queue is refreshed. Implementations should ensure they are talking to the latest queue- Parameters:
- queue- New queue instance, null indicates a shutdown, e.g. the queue is no longer available.
 
 
- 
 
-