クラス ListenerUtils

メソッドの詳細

• determineListenerType

  public static ListenerType determineListenerType(ObjectSE listener)

  リスナーの型を判別します。

  パラメーター:

  listener - リスナー。

  戻り値:

  ListenerType

• unrecoverableBackOff

  @DeprecatedSE(since="3.1", forRemoval=true) public static void unrecoverableBackOff(BackOff backOff, ThreadLocalSE<BackOffExecution> executions, ThreadLocalSE<LongSE> lastIntervals, MessageListenerContainer container) throws InterruptedExceptionSE

  非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

  unrecoverableBackOff(BackOff, Map, Map, MessageListenerContainer) を推奨。

  BackOff に従ってスリープします。BackOffExecution が前の backOff の BackOffExecution.STOP スリープを返したとき。

  パラメーター:

  backOff - BackOff を使用して新しい BackOffExecution を作成します。

  executions - このスレッドの BackOffExecution を含むスレッドローカル。

  lastIntervals - このスレッドの以前の BackOff 間隔を含むスレッドローカル。

  container - コンテナーまたは親コンテナー。

  例外:

  InterruptedExceptionSE - スレッドが中断された場合。

  導入:

  2.7

• unrecoverableBackOff

  public static void unrecoverableBackOff(BackOff backOff, MapSE<ThreadSE,BackOffExecution> executions, MapSE<ThreadSE,LongSE> lastIntervals, MessageListenerContainer container) throws InterruptedExceptionSE

  BackOff に従ってスリープします。BackOffExecution が前の backOff の BackOffExecution.STOP スリープを返したとき。

  パラメーター:

  backOff - BackOff を使用して新しい BackOffExecution を作成します。

  executions - このスレッドの BackOffExecution を含むスレッドローカル。

  lastIntervals - このスレッドの以前の BackOff 間隔を含むスレッドローカル。

  container - コンテナーまたは親コンテナー。

  例外:

  InterruptedExceptionSE - スレッドが中断された場合。

  導入:

  3.1

• stoppableSleep

  public static void stoppableSleep(MessageListenerContainer container, long interval) throws InterruptedExceptionSE

  コンテナーが実行を継続している限り、必要なタイムアウトの間スリープします。

  パラメーター:

  container - コンテナー。

  interval - タイムアウト。

  例外:

  InterruptedExceptionSE - スレッドが中断された場合。

  導入:

  2.7

• conditionalSleep

  public static void conditionalSleep(SupplierSE<BooleanSE> shouldSleepCondition, long interval) throws InterruptedExceptionSE

  shouldSleepCondition が true を指定している限り、必要なタイムアウトの間スリープします。

  パラメーター:

  shouldSleepCondition - to。

  interval - タイムアウト。

  例外:

  InterruptedExceptionSE - スレッドが中断された場合。

  導入:

  3.0.9

• createOffsetAndMetadata

  public static org.apache.kafka.clients.consumer.OffsetAndMetadata createOffsetAndMetadata(MessageListenerContainer container, long offset)

  指定されたコンテナーとオフセットを使用して新しい OffsetAndMetadata を作成します。

  パラメーター:

  container - コンテナー。

  offset - オフセット。

  戻り値:

  オフセットとメタデータ。

  導入:

  2.8.6