クラス RabbitResourceHolder
- java.lang.ObjectSE
-
- org.springframework.transaction.support.ResourceHolderSupport
-
- org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- 実装されたすべてのインターフェース:
ResourceHolder
public class RabbitResourceHolder extends ResourceHolderSupport
RabbitMQ 接続とチャネルをラップする Rabbit リソースホルダー。RabbitTransactionManager は、指定された Rabbit ConnectionFactory に対して、このクラスのインスタンスをスレッドにバインドします。メモ: これは SPI クラスであり、アプリケーションでの使用は意図されていません。
- 作成者:
- Mark Fisher, Dave Syer, Gary Russell
- 関連事項:
RabbitTransactionManager
,RabbitTemplate
コンストラクターのサマリー
コンストラクター コンストラクター 説明 RabbitResourceHolder()
リソースを追加するために開いている新しい RabbitResourceHolder を作成します。RabbitResourceHolder(com.rabbitmq.client.Channel channel, boolean releaseAfterCompletion)
チャネルのインスタンスを構築します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 void
addChannel(com.rabbitmq.client.Channel channel)
void
addChannel(com.rabbitmq.client.Channel channel, Connection connection)
void
addConnection(Connection connection)
void
addDeliveryTag(com.rabbitmq.client.Channel channel, long deliveryTag)
void
closeAll()
void
commitAll()
boolean
containsChannel(com.rabbitmq.client.Channel channel)
com.rabbitmq.client.Channel
getChannel()
Connection
getConnection()
boolean
isReleaseAfterCompletion()
トランザクションの補完後にリソースを解放するかどうか。void
rollbackAll()
void
setRequeueOnRollback(boolean requeueOnRollback)
ロールバック時にメッセージを再キューイングするには true に設定します。デフォルトは真です。クラス org.springframework.transaction.support.ResourceHolderSupport から継承されたメソッド
clear, getDeadline, getTimeToLiveInMillis, getTimeToLiveInSeconds, hasTimeout, isOpen, isRollbackOnly, isSynchronizedWithTransaction, isVoid, released, requested, reset, resetRollbackOnly, setRollbackOnly, setSynchronizedWithTransaction, setTimeoutInMillis, setTimeoutInSeconds, unbound
コンストラクターの詳細
RabbitResourceHolder
public RabbitResourceHolder()
リソースを追加するために開いている新しい RabbitResourceHolder を作成します。
RabbitResourceHolder
public RabbitResourceHolder(com.rabbitmq.client.Channel channel, boolean releaseAfterCompletion)
チャネルのインスタンスを構築します。- パラメーター:
channel
- 追加するチャンネルreleaseAfterCompletion
- 完了後にチャネルを解放する必要がある場合は true。
メソッドの詳細
isReleaseAfterCompletion
public boolean isReleaseAfterCompletion()
トランザクションの補完後にリソースを解放するかどうか。デフォルトは真です。リスナーは引き続きチャネルを使用するため、リスナーコンテナーは false に設定されます。- 戻り値:
- リソースを解放する必要がある場合は true。
setRequeueOnRollback
public void setRequeueOnRollback(boolean requeueOnRollback)
ロールバック時にメッセージを再キューイングするには true に設定します。デフォルトは真です。- パラメーター:
requeueOnRollback
- 再キューイングに真- 導入:
- 1.7.1
addConnection
public final void addConnection(Connection connection)
addChannel
public final void addChannel(com.rabbitmq.client.Channel channel)
addChannel
public final void addChannel(com.rabbitmq.client.Channel channel, @Nullable Connection connection)
containsChannel
public boolean containsChannel(com.rabbitmq.client.Channel channel)
getConnection
@Nullable public Connection getConnection()
getChannel
@Nullable public com.rabbitmq.client.Channel getChannel()
commitAll
public void commitAll() throws AmqpException
closeAll
public void closeAll()
addDeliveryTag
public void addDeliveryTag(com.rabbitmq.client.Channel channel, long deliveryTag)
rollbackAll
public void rollbackAll()