Interface AsyncProcessorAwaitManager.AwaitThread

Enclosing interface:
AsyncProcessorAwaitManager
public static interface AsyncProcessorAwaitManager.AwaitThread
Information about the thread and exchange that are inflight.

  • Method Summary

    Modifier and Type
    Method
    Description
    Thread
    getBlockedThread()
    The thread which is blocked waiting for other threads to signal the callback.
    Exchange
    getExchange()
    The exchange being processed by the other thread.
    @Nullable String
    getNodeId()
    The id of the node from the route where the exchange was processed when the thread was set to block.
    @Nullable String
    getRouteId()
    The id of the route where the exchange was processed when the thread was set to block.
    long
    getWaitDuration()
    Time in millis the thread has been blocked waiting for the signal.

  • Method Details

    • getBlockedThread

      Thread getBlockedThread()
      The thread which is blocked waiting for other threads to signal the callback.

    • getExchange

      Exchange getExchange()
      The exchange being processed by the other thread.

    • getWaitDuration

      long getWaitDuration()
      Time in millis the thread has been blocked waiting for the signal.

    • getRouteId

      @Nullable String getRouteId()
      The id of the route where the exchange was processed when the thread was set to block.

      Is null if message history is disabled.

    • getNodeId

      @Nullable String getNodeId()
      The id of the node from the route where the exchange was processed when the thread was set to block.

      Is null if message history is disabled.