クラス AbstractConnectionFactory

メソッドの詳細

• 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

  @Nullable 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],..." 形式のアドレスのリスト

• getAddresses

  @Nullable protected ListSE<com.rabbitmq.client.Address> getAddresses() throws IOExceptionSE

  例外:

  IOExceptionSE

• 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 だった 3.1 以降、DEBUG レベルでログに記録されます)。

  パラメーター:

  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

• setAddressShuffleMode

  public void setAddressShuffleMode(AbstractConnectionFactory.AddressShuffleMode addressShuffleMode)

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

  パラメーター:

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

  導入:

  2.3

  関連事項:

  • Collections.shuffle(List)SE

• hasPublisherConnectionFactory

  public boolean hasPublisherConnectionFactory()

• setConnectionCreatingBackOff

  public void setConnectionCreatingBackOff(@Nullable BackOff backOff)

  接続を作成するためのバックオフ戦略を設定します。この機能強化により、接続モジュール内でカスタム再試行ポリシーがサポートされます。これは、最大チャネル制限に達した場合に特に役立ちます。SimpleConnection.createChannel(boolean) メソッドは、このバックオフ戦略を利用して、このような制限例外を適切に処理します。

  パラメーター:

  backOff - 接続作成時に適用されるバックオフ戦略

  導入:

  3.1.3

• 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