クラス RabbitUtils

メソッドの詳細

• closeConnection

  public static void closeConnection(@Nullable Connection connection)

  指定された RabbitMQ 接続を閉じ、スローされた例外を無視します。これは、手動の RabbitMQ コードの典型的な finally ブロックに役立ちます。

  パラメーター:

  connection - 閉じる RabbitMQ 接続 (null の場合があります)

• closeChannel

  public static void closeChannel(@Nullable com.rabbitmq.client.Channel channel)

  指定された RabbitMQ チャネルを閉じ、スローされた例外を無視します。これは、手動の RabbitMQ コードの典型的な finally ブロックに役立ちます。

  パラメーター:

  channel - 閉じる RabbitMQ チャネル (null の場合があります)

• commitIfNecessary

  public static void commitIfNecessary(com.rabbitmq.client.Channel channel)

  JTA トランザクション内にない場合は、チャネルをコミットします。

  パラメーター:

  channel - コミットする RabbitMQ チャネル

• rollbackIfNecessary

  public static void rollbackIfNecessary(com.rabbitmq.client.Channel channel)

• closeMessageConsumer

  public static void closeMessageConsumer(com.rabbitmq.client.Channel channel, CollectionSE<StringSE> consumerTags, boolean transactional)

• cancel

  public static void cancel(com.rabbitmq.client.Channel channel, StringSE consumerTag)

• declareTransactional

  public static void declareTransactional(com.rabbitmq.client.Channel channel)

  チャネルがトランザクションで使用されることをそのブローカーに宣言し、発生した例外を変換します。

  パラメーター:

  channel - 使用するチャネル

• setPhysicalCloseRequired

  public static void setPhysicalCloseRequired(com.rabbitmq.client.Channel channel, boolean b)

  チャネルを物理的に閉じなければならないことを示す ThreadLocal を設定します。

  パラメーター:

  channel - チャンネル。

  b - チャネルを閉じる必要がある場合 (プロキシの場合) は true。

• isPhysicalCloseRequired

  public static boolean isPhysicalCloseRequired()

  チャネルを物理的に閉じる必要があることを示す ThreadLocal を取得および削除します。

  戻り値:

  チャネルを物理的に閉じる必要がある場合は true

• clearPhysicalCloseRequired

  public static void clearPhysicalCloseRequired()

  physicalCloseRequired フラグをクリアします。

• isNormalShutdown

  public static boolean isNormalShutdown(com.rabbitmq.client.ShutdownSignalException sig)

  ShutdownSignalException の理由が AMQP.Connection.Close で、応答コードが AMQP.REPLY_SUCCESS (200) で、テキストが "OK" の場合、true を返します。

  パラメーター:

  sig - 例外。

  戻り値:

  通常の接続クローズの場合は true。

• isNormalChannelClose

  public static boolean isNormalChannelClose(com.rabbitmq.client.ShutdownSignalException sig)

  ShutdownSignalException の理由が AMQP.Channel.Close で、応答コードが AMQP.REPLY_SUCCESS (200) で、テキストが "OK" の場合、true を返します。

  パラメーター:

  sig - 例外。

  戻り値:

  通常のチャネルクローズの場合は true。

• isPassiveDeclarationChannelClose

  public static boolean isPassiveDeclarationChannelClose(com.rabbitmq.client.ShutdownSignalException sig)

  ShutdownSignalException の理由が AMQP.Channel.Close であり、失敗した操作が exchangeDeclare または queueDeclare の場合は true を返します。

  パラメーター:

  sig - 例外。

  戻り値:

  失敗が条件を満たしている場合は true。

• isExclusiveUseChannelClose

  public static boolean isExclusiveUseChannelClose(com.rabbitmq.client.ShutdownSignalException sig)

  ShutdownSignalException の理由が AMQP.Channel.Close であり、失敗した操作が basicConsumer であり、失敗テキストに "exclusive" が含まれている場合は true を返します。

  パラメーター:

  sig - 例外。

  戻り値:

  排他キューが原因で宣言が失敗した場合は true。

• isMismatchedQueueArgs

  public static boolean isMismatchedQueueArgs(ExceptionSE e)

  原因ツリーに ShutdownSignalException があり、その理由が "PRECONDITION_FAILED" であり、実行された操作が queueDeclare であった場合は true を返します。これは、キューに一致しないプロパティ (自動削除など) または引数 (x-message-ttl など) がある場合に発生する可能性があります。

  パラメーター:

  e - 例外。

  戻り値:

  キュー宣言の前提条件が失敗したために例外が発生した場合は true。

  導入:

  1.6

• isExchangeDeclarationFailure

  public static boolean isExchangeDeclarationFailure(ExceptionSE e)

  原因ツリーに ShutdownSignalException があり、その理由が "COMMAND_INVALID" であり、実行された操作が exchangeDeclare であった場合は true を返します。たとえば、ブローカーまたはそのプラグインでサポートされていない交換を宣言しようとした場合などです。

  パラメーター:

  e - 例外。

  戻り値:

  交換宣言の失敗が原因で例外が発生した場合は true。

  導入:

  1.6

• getMaxFrame

  public static int getMaxFrame(ConnectionFactory connectionFactory)

  ネゴシエートされた frame_max を返します。

  パラメーター:

  connectionFactory - 接続ファクトリ。

  戻り値:

  サイズを決定できない場合は -1。

• stringToSaslConfig

  public static com.rabbitmq.client.SaslConfig stringToSaslConfig(StringSE saslConfig, com.rabbitmq.client.ConnectionFactory connectionFactory)

  String 値を SaslConfig に変換します。有効な文字列値:

  • DefaultSaslConfig.PLAIN
  • DefaultSaslConfig.EXTERNAL
  • JDKSaslConfig
  • CRDemoSaslConfig

  パラメーター:

  saslConfig - 文字列値。

  connectionFactory - 名前、pw、ホストを取得する接続ファクトリ。

  戻り値:

  saslConfig。

• exclusiveAccesssRefused

  public static boolean exclusiveAccesssRefused(ExceptionSE exception)

  例外が排他的コンシューマーに対して拒否されたアクセスによるものであるかどうかを判断します。

  パラメーター:

  exception - 例外。

  戻り値:

  アクセスが拒否された場合は true。

  導入:

  3.1