Interface AbstractServerTransport.Scheduler

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Interface Description
      static class  AbstractServerTransport.Scheduler.None
      A scheduler that does not perform any operation but remembers the /meta/connect cycle.
    • Method Summary

      All Methods Instance Methods Default Methods 
      Modifier and Type Method Description
      default void cancel()
      Invoked when the transport wants to cancel scheduled operations that will trigger when the /meta/connect timeout fires.
      default void cancel​(java.lang.Throwable cause)
      Invoked when the transport wants to cancel with the given cause scheduled operations that will trigger when the /meta/connect timeout fires.
      default void destroy()
      Invoked when the transport wants to abort communication.
      default ServerMessage.Mutable getMessage()  
      default long getMetaConnectCycle()  
      default void schedule()
      Invoked when the transport wants to send queued messages, and possibly a /meta/connect reply.
    • Method Detail

      • getMessage

        default ServerMessage.Mutable getMessage()
        Returns:
        the message associated with this scheduler.
      • getMetaConnectCycle

        default long getMetaConnectCycle()
        Returns:
        the cycle number for suspended /meta/connects.
      • schedule

        default void schedule()
        Invoked when the transport wants to send queued messages, and possibly a /meta/connect reply.
      • cancel

        default void cancel()
        Invoked when the transport wants to cancel scheduled operations that will trigger when the /meta/connect timeout fires.
      • cancel

        default void cancel​(java.lang.Throwable cause)
        Invoked when the transport wants to cancel with the given cause scheduled operations that will trigger when the /meta/connect timeout fires.
      • destroy

        default void destroy()
        Invoked when the transport wants to abort communication.