public class RabbitResourceHolder extends ResourceHolderSupport
メモ: これは SPI クラスであり、アプリケーションでの使用は意図されていません。
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 に設定します。デフォルトは真です。 |
clear, getDeadline, getTimeToLiveInMillis, getTimeToLiveInSeconds, hasTimeout, isOpen, isRollbackOnly, isSynchronizedWithTransaction, isVoid, released, requested, reset, resetRollbackOnly, setRollbackOnly, setSynchronizedWithTransaction, setTimeoutInMillis, setTimeoutInSeconds, unboundcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic RabbitResourceHolder()
public RabbitResourceHolder(com.rabbitmq.client.Channel channel,
boolean releaseAfterCompletion)channel - 追加するチャンネル releaseAfterCompletion - 完了後にチャネルを解放する必要がある場合は true。public boolean isReleaseAfterCompletion()
public void setRequeueOnRollback(boolean requeueOnRollback)
requeueOnRollback - 再キューイングに真 public final void addConnection(Connection connection)
public final void addChannel(com.rabbitmq.client.Channel channel)
public final void addChannel(com.rabbitmq.client.Channel channel,
@Nullable
Connection connection)public boolean containsChannel(com.rabbitmq.client.Channel channel)
@Nullable public Connection getConnection()
@Nullable public com.rabbitmq.client.Channel getChannel()
public void commitAll()
throws AmqpExceptionpublic void closeAll()
public void addDeliveryTag(com.rabbitmq.client.Channel channel,
long deliveryTag)public void rollbackAll()