Interface OutboundQueueHandler

  • All Known Subinterfaces:
    All Known Implementing Classes:

    public interface OutboundQueueHandler
    Handler of the outbound queue. The queue has a maximum depth assigned when the handler is registered.
    • Method Detail

      • createBarrierRequest

        @NonNull BarrierInput createBarrierRequest​(@NonNull Long xid)
        Create a new barrier message. 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.
        xid - XID for the barrier message
        New barrier message.
      • onConnectionQueueChanged

        void onConnectionQueueChanged​(OutboundQueue queue)
        Invoked whenever the underlying queue is refreshed. Implementations should ensure they are talking to the latest queue
        queue - New queue instance, null indicates a shutdown, e.g. the queue is no longer available.