インターフェースの使用
org.springframework.amqp.rabbit.connection.ConnectionFactory
ConnectionFactory を使用するパッケージ
パッケージ
説明
Spring Rabbit のトップレベルクラスを提供します。
Rabbit XML 名前空間をサポートするクラスを提供します。
接続に関連するクラスを提供します。
Spring Rabbit のコアクラスを提供します。
メッセージリスナーコンテナーのクラスを提供します。
Spring AMQP アプリケーションをテストするためのクラス。
Spring Rabbit のトランザクションをサポートするクラスを提供します。
org.springframework.amqp.rabbit 内の ConnectionFactory 使用
型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit のコンストラクター修飾子コンストラクター説明AsyncRabbitTemplate(ConnectionFactory connectionFactory, @Nullable StringSE exchange, StringSE routingKey) 提供された引数を使用してインスタンスを構築します。AsyncRabbitTemplate(ConnectionFactory connectionFactory, @Nullable StringSE exchange, StringSE routingKey, StringSE replyQueue, @Nullable StringSE replyAddress) 提供された引数を使用してインスタンスを構築します。AsyncRabbitTemplate(ConnectionFactory connectionFactory, StringSE exchange, StringSE routingKey, StringSE replyQueue) 提供された引数を使用してインスタンスを構築します。org.springframework.amqp.rabbit.config 内の ConnectionFactory 使用
型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.config のメソッド修飾子と型メソッド説明voidAbstractRabbitListenerContainerFactory.setConnectionFactory(ConnectionFactory connectionFactory) voidListenerContainerFactoryBean.setConnectionFactory(ConnectionFactory connectionFactory) org.springframework.amqp.rabbit.connection 内の ConnectionFactory 使用
修飾子と型クラス説明classclassルックアップキーに基づいてAbstractRoutingConnectionFactory.createConnection()呼び出しをさまざまなターゲット ConnectionFactories のいずれかにルーティングする抽象ConnectionFactory実装。class(キャッシュモードがCachingConnectionFactory.CacheMode.CHANNEL(デフォルト) の場合、すべてのCachingConnectionFactory.createConnection()呼び出しから同じ接続を返し、Connection.close()への呼び出しを無視してChannelをキャッシュするConnectionFactory実装。classキューが配置されているノードを決定し、そのノードに直接接続するファクトリを返すRoutingConnectionFactory。classApache Pool2GenericObjectPool(トランザクションチャネル用に 1 つ、非トランザクションチャネル用に 1 つ) を使用してチャネルをキャッシュする非常にシンプルな接続ファクトリ。classこのConnectionFactoryのインスタンスのキーによって、スレッドにバインドされたリソースから現在のConnectionFactoryのlookupKeyを取得するAbstractRoutingConnectionFactory実装。classスレッドごとにチャネルをキャッシュする非常に単純な接続ファクトリ。修飾子と型メソッド説明protected ConnectionFactoryLocalizedQueueConnectionFactory.createConnectionFactory(StringSE address, StringSE node) アドレス専用の接続ファクトリを作成します。protected ConnectionFactoryAbstractRoutingConnectionFactory.determineTargetConnectionFactory()現在のターゲットConnectionFactoryを取得します。RabbitAccessor.getConnectionFactory()@Nullable ConnectionFactoryAbstractConnectionFactory.getPublisherConnectionFactory()default @Nullable ConnectionFactoryConnectionFactory.getPublisherConnectionFactory()パブリッシャー用に個別の接続ファクトリを返します (実装されている場合)。@Nullable ConnectionFactoryAbstractRoutingConnectionFactory.getTargetConnectionFactory(ObjectSE key) LocalizedQueueConnectionFactory.getTargetConnectionFactory(ObjectSE key) @Nullable ConnectionFactoryRoutingConnectionFactory.getTargetConnectionFactory(ObjectSE key) 指定されたルックアップキーにバインドされたConnectionFactoryを返します。存在しない場合は null を返します。@Nullable ConnectionFactoryファクトリを検索または作成します。default @Nullable ConnectionFactoryNodeLocator.locate(StringSE[] adminUris, MapSE<StringSE, StringSE> nodeToAddress, StringSE vhost, StringSE username, StringSE password, StringSE queue, FactoryFinder factoryFunction) キューのリーダーノードの接続ファクトリを返します。protected ConnectionFactoryAbstractRoutingConnectionFactory.removeTargetConnectionFactory(ObjectSE key) 指定された検索キーに関連付けられたConnectionFactoryを削除して返します。型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.connection のメソッド修飾子と型メソッド説明protected voidAbstractRoutingConnectionFactory.addTargetConnectionFactory(ObjectSE key, ConnectionFactory connectionFactory) 指定されたConnectionFactoryを追加し、指定されたルックアップキーに関連付けます。static @Nullable RabbitResourceHolderConnectionFactoryUtils.bindResourceToTransaction(RabbitResourceHolder resourceHolder, ConnectionFactory connectionFactory, boolean synched) static ConnectionConnectionFactoryUtils.createConnection(ConnectionFactory connectionFactory, boolean publisherConnectionIfPossible) この接続ファクトリおよび / またはそのパブリッシャーファクトリとの接続を作成します。static @Nullable com.rabbitmq.client.ChannelConsumerChannelRegistry.getConsumerChannel(ConnectionFactory connectionFactory) registerConsumerChannel を参照してください。static intRabbitUtils.getMaxFrame(ConnectionFactory connectionFactory) ネゴシエートされた frame_max を返します。static RabbitResourceHolderConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactory connectionFactory, boolean synchedLocalTransactionAllowed) 現在のトランザクションと同期されている RabbitMQ チャネルを取得します (存在する場合)。static RabbitResourceHolderConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactory connectionFactory, boolean synchedLocalTransactionAllowed, boolean publisherConnectionIfPossible) 現在のトランザクションと同期されている RabbitMQ チャネルを取得します (存在する場合)。static booleanConnectionFactoryUtils.isChannelTransactional(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory) 指定された RabbitMQ チャネルがトランザクション対応であるかどうか、つまり、Spring のトランザクション機能によって現在のスレッドにバインドされているかどうかを判断します。ConnectionNameStrategy.obtainNewConnectionName(ConnectionFactory connectionFactory) SimplePropertyValueConnectionNameStrategy.obtainNewConnectionName(ConnectionFactory connectionFactory) static voidConsumerChannelRegistry.registerConsumerChannel(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory) リスナーコンテナーが RabbitTransactionManager を使用するように構成されている場合、コンシューマーのチャネルはここに登録され、トランザクションが実際に開始されたときにバインドされたリソースとして使用されます。static voidConnectionFactoryUtils.registerDeliveryTag(ConnectionFactory connectionFactory, com.rabbitmq.client.Channel channel, LongSE tag) voidRabbitAccessor.setConnectionFactory(ConnectionFactory connectionFactory) RabbitMQConnectionsの取得に使用する ConnectionFactory を設定します。voidAbstractRoutingConnectionFactory.setDefaultTargetConnectionFactory(ConnectionFactory defaultTargetConnectionFactory) デフォルトのターゲットConnectionFactoryを指定します（存在する場合）。型 ConnectionFactory の型引数を持つ org.springframework.amqp.rabbit.connection のメソッドパラメーター修飾子と型メソッド説明voidAbstractRoutingConnectionFactory.setTargetConnectionFactories(MapSE<ObjectSE, ConnectionFactory> targetConnectionFactories) 検索キーをキーとして、ターゲット ConnectionFactories のマップを指定します。型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.connection のコンストラクター修飾子コンストラクター説明ConnectionFactoryContextWrapper(ConnectionFactory connectionFactory) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, StringSE[] addresses, StringSE[] adminUris, StringSE[] nodes, StringSE vhost, StringSE username, StringSE password, boolean useSSL, @Nullable Resource sslPropertiesLocation) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, StringSE[] addresses, StringSE[] adminUris, StringSE[] nodes, StringSE vhost, StringSE username, StringSE password, boolean useSSL, StringSE keyStore, StringSE trustStore, StringSE keyStorePassPhrase, StringSE trustStorePassPhrase) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, MapSE<StringSE, StringSE> nodeToAddress, StringSE[] adminUris, StringSE vhost, StringSE username, StringSE password, boolean useSSL, StringSE keyStore, StringSE trustStore, StringSE keyStorePassPhrase, StringSE trustStorePassPhrase) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, MapSE<StringSE, StringSE> nodeToAddress, StringSE[] adminUris, StringSE vhost, StringSE username, StringSE password, boolean useSSL, Resource sslPropertiesLocation) org.springframework.amqp.rabbit.core 内の ConnectionFactory 使用
修飾子と型メソッド説明final @Nullable ConnectionFactoryRabbitGatewaySupport.getConnectionFactory()RabbitOperations.getConnectionFactory()これらの操作の接続ファクトリを返します。型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明protected RabbitTemplateRabbitGatewaySupport.createRabbitTemplate(ConnectionFactory connectionFactory) 指定された ConnectionFactory の RabbitTemplate を作成します。final voidRabbitGatewaySupport.setConnectionFactory(ConnectionFactory connectionFactory) ゲートウェイが使用する Rabbit 接続ファクトリを設定します。final voidRabbitTemplate.setConnectionFactory(ConnectionFactory connectionFactory) 型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.core のコンストラクター修飾子コンストラクター説明BatchingRabbitTemplate(ConnectionFactory connectionFactory, BatchingStrategy batchingStrategy, TaskScheduler scheduler) 指定されたパラメーターを使用してインスタンスを作成します。BrokerEventListener(ConnectionFactory connectionFactory, StringSE... eventKeys) 提供された接続ファクトリとイベントキーを使用してインスタンスを構築します。RabbitAdmin(ConnectionFactory connectionFactory) 提供されたConnectionFactoryを使用してインスタンスを構築します。RabbitTemplate(ConnectionFactory connectionFactory) デフォルトの戦略と設定で rabbit テンプレートを作成します。org.springframework.amqp.rabbit.listener 内の ConnectionFactory 使用
型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.listener のコンストラクター修飾子コンストラクター説明BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, @Nullable MapSE<StringSE, ObjectSE> consumerArgs, boolean noLocal, boolean exclusive, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, @Nullable MapSE<StringSE, ObjectSE> consumerArgs, boolean exclusive, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, @Nullable MapSE<StringSE, ObjectSE> consumerArgs, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, StringSE... queues) コンシューマーを作成します。DirectMessageListenerContainer(ConnectionFactory connectionFactory) 提供された接続ファクトリでインスタンスを作成します。DirectReplyToMessageListenerContainer(ConnectionFactory connectionFactory) SimpleMessageListenerContainer(ConnectionFactory connectionFactory) 接続ファクトリからリスナーコンテナーを作成します (必須)。org.springframework.amqp.rabbit.test 内の ConnectionFactory 使用
型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.test のコンストラクターorg.springframework.amqp.rabbit.transaction 内の ConnectionFactory 使用
型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.transaction のメソッド修飾子と型メソッド説明voidRabbitTransactionManager.setConnectionFactory(ConnectionFactory connectionFactory) 型 ConnectionFactory のパラメーターを持つ org.springframework.amqp.rabbit.transaction のコンストラクター修飾子コンストラクター説明RabbitTransactionManager(ConnectionFactory connectionFactory) ConnectionFactory を指定して、新しい RabbitTransactionManager を作成します。