フィールドの詳細

• DEFAULT_CLOSE_TIMEOUT

  public static final int DEFAULT_CLOSE_TIMEOUT

  関連事項:

  定数フィールド値

• logger

  protected final Log logger

コンストラクターの詳細

• AbstractConnectionFactory

  public AbstractConnectionFactory​(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)

  パブリッシャー接続ファクトリなしで、指定されたターゲット ConnectionFactory の新しい AbstractConnectionFactory を作成します。

  パラメーター:

  rabbitConnectionFactory - ターゲット ConnectionFactory

メソッドの詳細

• setPublisherConnectionFactory

  public void setPublisherConnectionFactory​(@Nullable
                                            AbstractConnectionFactory publisherConnectionFactory)

  カスタムパブリッシャー接続ファクトリを設定します。型はこのファクトリと同じである必要はありません。

  パラメーター:

  publisherConnectionFactory - ファクトリ。

  導入:

  2.3.2

• doSetPublisherConnectionFactory

  protected final void doSetPublisherConnectionFactory​(@Nullable
                                                       AbstractConnectionFactory publisherConnectionFactory)

• setApplicationContext

  public void setApplicationContext​(ApplicationContext applicationContext)

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

• getApplicationContext

  protected ApplicationContext getApplicationContext()

• setApplicationEventPublisher

  public void setApplicationEventPublisher​(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

• getApplicationEventPublisher

  protected ApplicationEventPublisher getApplicationEventPublisher()

• onApplicationEvent

  public void onApplicationEvent​(ContextClosedEvent event)

  次で指定:

  インターフェース ApplicationListener<ContextClosedEvent> の onApplicationEvent 

• getContextStopped

  protected boolean getContextStopped()

• getRabbitConnectionFactory

  public com.rabbitmq.client.ConnectionFactory getRabbitConnectionFactory()

  基になる Rabbit 接続ファクトリへの参照を返します。

  戻り値:

  接続ファクトリ。

  導入:

  1.5.6

• getUsername

  public StringSE getUsername()

  基礎となる rabbit 接続ファクトリからユーザー名を返します。

  次で指定:

  インターフェース ConnectionFactory の getUsername 

  戻り値:

  ユーザー名。

  導入:

  1.6

• setUsername

  public void setUsername​(StringSE username)

• setPassword

  public void setPassword​(StringSE password)

• setHost

  public void setHost​(StringSE host)

• setConnectionThreadFactory

  public void setConnectionThreadFactory​(ThreadFactorySE threadFactory)

  基礎となる rabbit 接続ファクトリで ThreadFactorySE を設定します。

  パラメーター:

  threadFactory - スレッドファクトリ。

  導入:

  1.5.3

• setAddressResolver

  public void setAddressResolver​(com.rabbitmq.client.AddressResolver addressResolver)

  接続の作成時に使用する AddressResolver を設定します。setAddresses(String)、setHost(String)、setPort(int) をオーバーライドします。

  パラメーター:

  addressResolver - リゾルバー。

  導入:

  2.1.15

• setUri

  public void setUri​(URISE uri)

  パラメーター:

  uri - URI

  導入:

  1.5

  関連事項:

  ConnectionFactory.setUri(URI)

• setUri

  public void setUri​(StringSE uri)

  パラメーター:

  uri - URI

  導入:

  1.5

  関連事項:

  ConnectionFactory.setUri(String)

• getHost

  public StringSE getHost()

  次で指定:

  インターフェース ConnectionFactory の getHost 

• setVirtualHost

  public void setVirtualHost​(StringSE virtualHost)

• getVirtualHost

  public StringSE getVirtualHost()

  次で指定:

  インターフェース ConnectionFactory の getVirtualHost 

• setPort

  public void setPort​(int port)

• setRequestedHeartBeat

  public void setRequestedHeartBeat​(int requestedHeartBeat)

• setConnectionTimeout

  public void setConnectionTimeout​(int connectionTimeout)

• getPort

  public int getPort()

  次で指定:

  インターフェース ConnectionFactory の getPort 

• setAddresses

  public void setAddresses​(StringSE addresses)

  クラスタリングのアドレスを設定します。このプロパティは、空でない場合、ホスト + ポートのプロパティをオーバーライドします。

  パラメーター:

  addresses - "host[:port],..." 形式のアドレスのリスト

• getConnectionListener

  protected ConnectionListener getConnectionListener()

  接続を作成および閉じるときにサブクラスによって使用される複合接続リスナー。

  戻り値:

  接続リスナー

• getChannelListener

  protected ChannelListener getChannelListener()

  チャネルを作成および閉じるときにサブクラスによって使用される複合チャネルリスナー。

  戻り値:

  チャンネルリスナー

• setConnectionListeners

  public void setConnectionListeners​(ListSE<? extends ConnectionListener> listeners)

• addConnectionListener

  public void addConnectionListener​(ConnectionListener listener)

  次で指定:

  インターフェース ConnectionFactory の addConnectionListener 

• removeConnectionListener

  public boolean removeConnectionListener​(ConnectionListener listener)

  次で指定:

  インターフェース ConnectionFactory の removeConnectionListener 

• clearConnectionListeners

  public void clearConnectionListeners()

  次で指定:

  インターフェース ConnectionFactory の clearConnectionListeners 

• setChannelListeners

  public void setChannelListeners​(ListSE<? extends ChannelListener> listeners)

• setRecoveryListener

  public void setRecoveryListener​(com.rabbitmq.client.RecoveryListener recoveryListener)

  作成された各接続に追加される RecoveryListener を設定します。

  パラメーター:

  recoveryListener - リスナー。

  導入:

  2.0

• addChannelListener

  public void addChannelListener​(ChannelListener listener)

• setExecutor

  public void setExecutor​(ExecutorSE executor)

  接続の作成時に Rabbit ConnectionFactory が使用する Executor を提供します。<task:executor/> 要素で定義されているように、ExecutorService または Spring ThreadPoolTaskExecutor のいずれかになります。

  パラメーター:

  executor - エグゼキューター。

• getExecutorService

  @Nullable
  protected ExecutorServiceSE getExecutorService()

• setCloseTimeout

  public void setCloseTimeout​(int closeTimeout)

  ブローカーからの接続クローズ操作へのレスポンスを待機する時間 (ミリ秒)。デフォルト 30000 (30 秒)。

  パラメーター:

  closeTimeout - 設定する closeTimeout。

• getCloseTimeout

  public int getCloseTimeout()

• setConnectionNameStrategy

  public void setConnectionNameStrategy​(ConnectionNameStrategy connectionNameStrategy)

  ConnectionNameStrategy を指定して、ターゲットの RabbitMQ 接続の名前を作成します。beanName とカウンターがデフォルトで使用されます。

  パラメーター:

  connectionNameStrategy - 使用する ConnectionNameStrategy。

  導入:

  2.0

• setCloseExceptionLogger

  public void setCloseExceptionLogger​(ConditionalExceptionLogger closeExceptionLogger)

  クローズ例外をログに記録するための戦略を設定します。デフォルトでは、パッシブキューの宣言が失敗したためにチャネルが閉じられた場合、デバッグレベルでログに記録されます。通常のチャネルクローズ (200 OK) はログに記録されません。他のすべては ERROR レベルでログに記録されます (排他的なコンシューマー条件のためにアクセスが拒否された場合を除き、その場合は INFO レベルでログに記録されます)。

  パラメーター:

  closeExceptionLogger - ConditionalExceptionLogger

  導入:

  1.5

• getConnectionNameStrategy

  protected ConnectionNameStrategy getConnectionNameStrategy()

• setBeanName

  public void setBeanName​(StringSE name)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• getBeanName

  @Nullable
  protected StringSE getBeanName()

  コンポーネントの Bean 名を返すか、Bean でない場合は null を返します。

  戻り値:

  Bean 名または null。

  導入:

  1.7.9

• setShuffleAddresses

  @DeprecatedSE
  public void setShuffleAddresses​(boolean shuffleAddresses)

  使用すべきではありません。

  2.3 以来
  addresses が提供され、複数ある場合は、true に設定して新しい接続を開く前にリストをシャッフルし、ブローカーへの接続がランダムな順序で試行されるようにします。

  パラメーター:

  shuffleAddresses - リストをシャッフルする場合は true。

  導入:

  2.1.8

  関連事項:

  .SE

• setAddressShuffleMode

  public void setAddressShuffleMode​(AbstractConnectionFactory.AddressShuffleMode addressShuffleMode)

  アドレスをシャッフルするモードを設定します。

  パラメーター:

  addressShuffleMode - アドレスシャッフルモード。

  導入:

  2.3

  関連事項:

  Collections.shuffle(List)SE

• hasPublisherConnectionFactory

  public boolean hasPublisherConnectionFactory()

• getPublisherConnectionFactory

  public ConnectionFactory getPublisherConnectionFactory()

  インターフェースからコピーされた説明: ConnectionFactory
  パブリッシャー用に個別の接続ファクトリを返します (実装されている場合)。

  次で指定:

  インターフェース ConnectionFactory の getPublisherConnectionFactory 

  戻り値:

  パブリッシャー接続ファクトリ、または null。

• createBareConnection

  protected final Connection createBareConnection()

• getDefaultHostName

  protected final StringSE getDefaultHostName()

• shutdownCompleted

  public void shutdownCompleted​(com.rabbitmq.client.ShutdownSignalException cause)

  次で指定:

  インターフェース com.rabbitmq.client.ShutdownListener の shutdownCompleted 

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString