public class BoundRabbitChannelAdvice extends ObjectSE implements HandleMessageAdvice
RabbitOperations 操作を同じチャネルで実行するようにするアドバイス。このコンポーネントとすべてのダウンストリームコンポーネントで同じ RabbitOperations を使用する必要があります。通常、複数のメッセージが送信されるスプリッターまたはその他のメカニズムで使用されます。オプションで、チャネルがそのように構成されているかどうかをパブリッシャーが確認するのを待ちます。| コンストラクターと説明 |
|---|
BoundRabbitChannelAdvice(RabbitOperations operations) 確認を待たないインスタンスを作成します。 |
BoundRabbitChannelAdvice(RabbitOperations operations, java.time.Duration waitForConfirmsTimeout) パブリッシャーの確認を待機するインスタンスを構築します (構成されていて、waitForConfirmsTimeout が null でない場合)。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ObjectSE | invoke(MethodInvocation invocation) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic BoundRabbitChannelAdvice(RabbitOperations operations)
operations - 操作。public BoundRabbitChannelAdvice(RabbitOperations operations, @Nullable java.time.Duration waitForConfirmsTimeout)
operations - 操作。waitForConfirmsTimeout - タイムアウト。public ObjectSE invoke(MethodInvocation invocation) throws ThrowableSE
MethodInterceptor の invoke ThrowableSE