Uses of Interface
org.springframework.amqp.rabbit.connection.ConnectionFactory
Packages that use ConnectionFactory
Package
Description
Provides top-level classes for Spring Rabbit.
Provides classes supporting the Rabbit XML namespace.
Provides classes related to connections.
Provides core classes for Spring Rabbit.
Provides classes for message listener containers.
Classes for testing Spring AMQP applications.
Provides classes supporting transactions in Spring Rabbit.
-
Uses of ConnectionFactory in org.springframework.amqp.rabbit
Methods in org.springframework.amqp.rabbit that return ConnectionFactoryConstructors in org.springframework.amqp.rabbit with parameters of type ConnectionFactoryModifierConstructorDescriptionAsyncRabbitTemplate(ConnectionFactory connectionFactory, String exchange, String routingKey) Construct an instance using the provided arguments.AsyncRabbitTemplate(ConnectionFactory connectionFactory, String exchange, String routingKey, String replyQueue) Construct an instance using the provided arguments.AsyncRabbitTemplate(ConnectionFactory connectionFactory, String exchange, String routingKey, String replyQueue, String replyAddress) Construct an instance using the provided arguments. -
Uses of ConnectionFactory in org.springframework.amqp.rabbit.config
Methods in org.springframework.amqp.rabbit.config with parameters of type ConnectionFactoryModifier and TypeMethodDescriptionvoidAbstractRabbitListenerContainerFactory.setConnectionFactory(ConnectionFactory connectionFactory) voidListenerContainerFactoryBean.setConnectionFactory(ConnectionFactory connectionFactory) -
Uses of ConnectionFactory in org.springframework.amqp.rabbit.connection
Classes in org.springframework.amqp.rabbit.connection that implement ConnectionFactoryModifier and TypeClassDescriptionclassclassAbstractConnectionFactoryimplementation that routesAbstractRoutingConnectionFactory.createConnection()calls to one of various target ConnectionFactories based on a lookup key.classAConnectionFactoryimplementation that (when the cache mode isCachingConnectionFactory.CacheMode.CHANNEL(default) returns the same Connection from allCachingConnectionFactory.createConnection()calls, and ignores calls toConnection.close()and cachesChannel.classARoutingConnectionFactorythat determines the node on which a queue is located and returns a factory that connects directly to that node.classA very simple connection factory that caches channels using Apache Pool2GenericObjectPools (one for transactional and one for non-transactional channels).classAnAbstractRoutingConnectionFactoryimplementation which gets alookupKeyfor currentConnectionFactoryfrom thread-bound resource by key of the instance of thisConnectionFactory.classA very simple connection factory that caches a channel per thread.Methods in org.springframework.amqp.rabbit.connection that return ConnectionFactoryModifier and TypeMethodDescriptionprotected ConnectionFactoryLocalizedQueueConnectionFactory.createConnectionFactory(String address, String node) Create a dedicated connection factory for the address.protected ConnectionFactoryAbstractRoutingConnectionFactory.determineTargetConnectionFactory()Retrieve the current targetConnectionFactory.RabbitAccessor.getConnectionFactory()AbstractConnectionFactory.getPublisherConnectionFactory()default ConnectionFactoryConnectionFactory.getPublisherConnectionFactory()Return a separate connection factory for publishers (if implemented).AbstractRoutingConnectionFactory.getTargetConnectionFactory(Object key) LocalizedQueueConnectionFactory.getTargetConnectionFactory(Object key) RoutingConnectionFactory.getTargetConnectionFactory(Object key) Returns theConnectionFactorybound to given lookup key, or null if one does not exist.protected ConnectionFactoryAbstractRoutingConnectionFactory.removeTargetConnectionFactory(Object key) Removes theConnectionFactoryassociated with the given lookup key and returns it.Methods in org.springframework.amqp.rabbit.connection with parameters of type ConnectionFactoryModifier and TypeMethodDescriptionprotected voidAbstractRoutingConnectionFactory.addTargetConnectionFactory(Object key, ConnectionFactory connectionFactory) Adds the givenConnectionFactoryand associates it with the given lookup key.static RabbitResourceHolderConnectionFactoryUtils.bindResourceToTransaction(RabbitResourceHolder resourceHolder, ConnectionFactory connectionFactory, boolean synched) static ConnectionConnectionFactoryUtils.createConnection(ConnectionFactory connectionFactory, boolean publisherConnectionIfPossible) Create a connection with this connection factory and/or its publisher factory.static com.rabbitmq.client.ChannelConsumerChannelRegistry.getConsumerChannel(ConnectionFactory connectionFactory) See registerConsumerChannel.static intRabbitUtils.getMaxFrame(ConnectionFactory connectionFactory) Return the negotiated frame_max.static RabbitResourceHolderConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactory connectionFactory, boolean synchedLocalTransactionAllowed) Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.static RabbitResourceHolderConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactory connectionFactory, boolean synchedLocalTransactionAllowed, boolean publisherConnectionIfPossible) Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.static booleanConnectionFactoryUtils.isChannelTransactional(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory) Determine whether the given RabbitMQ Channel is transactional, that is, bound to the current thread by Spring's transaction facilities.ConnectionNameStrategy.obtainNewConnectionName(ConnectionFactory connectionFactory) SimplePropertyValueConnectionNameStrategy.obtainNewConnectionName(ConnectionFactory connectionFactory) static voidConsumerChannelRegistry.registerConsumerChannel(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory) If a listener container is configured to use a RabbitTransactionManager, the consumer's channel is registered here so that it is used as the bound resource when the transaction actually starts.static voidConnectionFactoryUtils.registerDeliveryTag(ConnectionFactory connectionFactory, com.rabbitmq.client.Channel channel, Long tag) voidRabbitAccessor.setConnectionFactory(ConnectionFactory connectionFactory) Set the ConnectionFactory to use for obtaining RabbitMQConnections.voidAbstractRoutingConnectionFactory.setDefaultTargetConnectionFactory(ConnectionFactory defaultTargetConnectionFactory) Specify the default targetConnectionFactory, if any.Method parameters in org.springframework.amqp.rabbit.connection with type arguments of type ConnectionFactoryModifier and TypeMethodDescriptionvoidAbstractRoutingConnectionFactory.setTargetConnectionFactories(Map<Object, ConnectionFactory> targetConnectionFactories) Specify the map of target ConnectionFactories, with the lookup key as key.Constructors in org.springframework.amqp.rabbit.connection with parameters of type ConnectionFactoryModifierConstructorDescriptionConnectionFactoryContextWrapper(ConnectionFactory connectionFactory) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, String[] addresses, String[] adminUris, String[] nodes, String vhost, String username, String password, boolean useSSL, String keyStore, String trustStore, String keyStorePassPhrase, String trustStorePassPhrase) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, String[] addresses, String[] adminUris, String[] nodes, String vhost, String username, String password, boolean useSSL, Resource sslPropertiesLocation) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, Map<String, String> nodeToAddress, String[] adminUris, String vhost, String username, String password, boolean useSSL, String keyStore, String trustStore, String keyStorePassPhrase, String trustStorePassPhrase) LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, Map<String, String> nodeToAddress, String[] adminUris, String vhost, String username, String password, boolean useSSL, Resource sslPropertiesLocation) -
Uses of ConnectionFactory in org.springframework.amqp.rabbit.core
Methods in org.springframework.amqp.rabbit.core that return ConnectionFactoryModifier and TypeMethodDescriptionfinal ConnectionFactoryRabbitGatewaySupport.getConnectionFactory()RabbitOperations.getConnectionFactory()Return the connection factory for this operations.Methods in org.springframework.amqp.rabbit.core with parameters of type ConnectionFactoryModifier and TypeMethodDescriptionprotected RabbitTemplateRabbitGatewaySupport.createRabbitTemplate(ConnectionFactory connectionFactory) Create a RabbitTemplate for the given ConnectionFactory.final voidRabbitGatewaySupport.setConnectionFactory(ConnectionFactory connectionFactory) Set the Rabbit connection factory to be used by the gateway.final voidRabbitTemplate.setConnectionFactory(ConnectionFactory connectionFactory) Constructors in org.springframework.amqp.rabbit.core with parameters of type ConnectionFactoryModifierConstructorDescriptionBatchingRabbitTemplate(ConnectionFactory connectionFactory, BatchingStrategy batchingStrategy, TaskScheduler scheduler) Create an instance with the supplied parameters.BrokerEventListener(ConnectionFactory connectionFactory, String... eventKeys) Construct an instance using the supplied connection factory and event keys.RabbitAdmin(ConnectionFactory connectionFactory) Construct an instance using the providedConnectionFactory.RabbitTemplate(ConnectionFactory connectionFactory) Create a rabbit template with default strategies and settings. -
Uses of ConnectionFactory in org.springframework.amqp.rabbit.listener
Methods in org.springframework.amqp.rabbit.listener that return ConnectionFactoryConstructors in org.springframework.amqp.rabbit.listener with parameters of type ConnectionFactoryModifierConstructorDescriptionBlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, String... queues) Create a consumer.BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, Map<String, Object> consumerArgs, boolean noLocal, boolean exclusive, String... queues) Create a consumer.BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, Map<String, Object> consumerArgs, boolean exclusive, String... queues) Create a consumer.BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, Map<String, Object> consumerArgs, String... queues) Create a consumer.BlockingQueueConsumer(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, String... queues) Create a consumer.DirectMessageListenerContainer(ConnectionFactory connectionFactory) Create an instance with the provided connection factory.DirectReplyToMessageListenerContainer(ConnectionFactory connectionFactory) SimpleMessageListenerContainer(ConnectionFactory connectionFactory) Create a listener container from the connection factory (mandatory). -
Uses of ConnectionFactory in org.springframework.amqp.rabbit.test
Constructors in org.springframework.amqp.rabbit.test with parameters of type ConnectionFactory -
Uses of ConnectionFactory in org.springframework.amqp.rabbit.transaction
Methods in org.springframework.amqp.rabbit.transaction that return ConnectionFactoryMethods in org.springframework.amqp.rabbit.transaction with parameters of type ConnectionFactoryModifier and TypeMethodDescriptionvoidRabbitTransactionManager.setConnectionFactory(ConnectionFactory connectionFactory) Constructors in org.springframework.amqp.rabbit.transaction with parameters of type ConnectionFactoryModifierConstructorDescriptionRabbitTransactionManager(ConnectionFactory connectionFactory) Create a new RabbitTransactionManager, given a ConnectionFactory.