public class RabbitConnectionFactoryBean
extends org.springframework.beans.factory.config.AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory>
| Constructor and Description |
|---|
RabbitConnectionFactoryBean() |
| Modifier and Type | Method and Description |
|---|---|
protected com.rabbitmq.client.ConnectionFactory |
createInstance() |
java.lang.Class<?> |
getObjectType() |
void |
setClientProperties(java.util.Map<java.lang.String,java.lang.Object> clientProperties) |
void |
setConnectionTimeout(int connectionTimeout) |
void |
setExceptionHandler(com.rabbitmq.client.ExceptionHandler exceptionHandler) |
void |
setHost(java.lang.String host) |
void |
setPassword(java.lang.String password) |
void |
setPort(int port) |
void |
setRequestedChannelMax(int requestedChannelMax) |
void |
setRequestedFrameMax(int requestedFrameMax) |
void |
setRequestedHeartbeat(int requestedHeartbeat) |
void |
setSaslConfig(com.rabbitmq.client.SaslConfig saslConfig) |
void |
setSharedExecutor(java.util.concurrent.ExecutorService executor) |
void |
setSocketConfigurator(com.rabbitmq.client.SocketConfigurator socketConfigurator) |
void |
setSocketFactory(javax.net.SocketFactory factory) |
void |
setSslPropertiesLocation(org.springframework.core.io.Resource sslPropertiesLocation)
When
setUseSSL(boolean) is true, the SSL properties to use (optional). |
void |
setThreadFactory(java.util.concurrent.ThreadFactory threadFactory) |
void |
setUri(java.lang.String uriString) |
void |
setUri(java.net.URI uri) |
void |
setUsername(java.lang.String username) |
void |
setUseSSL(boolean useSSL)
Whether or not the factory should be configured to use SSL.
|
void |
setVirtualHost(java.lang.String virtualHost) |
public void setUseSSL(boolean useSSL)
useSSL - true to use SSL.public void setSslPropertiesLocation(org.springframework.core.io.Resource sslPropertiesLocation)
setUseSSL(boolean) is true, the SSL properties to use (optional).
Resource referencing a properties file with the following properties:
sslPropertiesLocation - the Resource to the ssl propertiespublic void setHost(java.lang.String host)
host - the host.ConnectionFactory.setHost(java.lang.String)public void setPort(int port)
port - the port.ConnectionFactory.setPort(int)public void setUsername(java.lang.String username)
username - the user name.ConnectionFactory.setUsername(java.lang.String)public void setPassword(java.lang.String password)
password - the password.ConnectionFactory.setPassword(java.lang.String)public void setVirtualHost(java.lang.String virtualHost)
virtualHost - the virtual host.ConnectionFactory.setVirtualHost(java.lang.String)public void setUri(java.net.URI uri)
throws java.net.URISyntaxException,
java.security.NoSuchAlgorithmException,
java.security.KeyManagementException
uri - the uri.java.net.URISyntaxException - invalid syntax.java.security.NoSuchAlgorithmException - no such algorithm.java.security.KeyManagementException - key management.ConnectionFactory.setUri(java.net.URI)public void setUri(java.lang.String uriString)
throws java.net.URISyntaxException,
java.security.NoSuchAlgorithmException,
java.security.KeyManagementException
uriString - the uri.java.net.URISyntaxException - invalid syntax.java.security.NoSuchAlgorithmException - no such algorithm.java.security.KeyManagementException - key management.ConnectionFactory.setUri(java.lang.String)public void setRequestedChannelMax(int requestedChannelMax)
requestedChannelMax - the max requested channels.ConnectionFactory.setRequestedChannelMax(int)public void setRequestedFrameMax(int requestedFrameMax)
requestedFrameMax - the requested max frames.ConnectionFactory.setRequestedFrameMax(int)public void setConnectionTimeout(int connectionTimeout)
connectionTimeout - the connection timeout.ConnectionFactory.setConnectionTimeout(int)public void setRequestedHeartbeat(int requestedHeartbeat)
requestedHeartbeat - the requested heartbeat.ConnectionFactory.setRequestedHeartbeat(int)public void setClientProperties(java.util.Map<java.lang.String,java.lang.Object> clientProperties)
clientProperties - the client properties.ConnectionFactory.setClientProperties(java.util.Map)public void setSaslConfig(com.rabbitmq.client.SaslConfig saslConfig)
saslConfig - the sasl config.ConnectionFactory.setSaslConfig(com.rabbitmq.client.SaslConfig)public void setSocketFactory(javax.net.SocketFactory factory)
factory - the socket factory.ConnectionFactory.setSocketFactory(javax.net.SocketFactory)public void setSocketConfigurator(com.rabbitmq.client.SocketConfigurator socketConfigurator)
socketConfigurator - the socket configurator.ConnectionFactory.setSocketConfigurator(com.rabbitmq.client.SocketConfigurator)public void setSharedExecutor(java.util.concurrent.ExecutorService executor)
executor - the executor serviceConnectionFactory.setSharedExecutor(java.util.concurrent.ExecutorService)public void setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)
threadFactory - the thread factory.ConnectionFactory.setThreadFactory(java.util.concurrent.ThreadFactory)public void setExceptionHandler(com.rabbitmq.client.ExceptionHandler exceptionHandler)
exceptionHandler - the exception handler.ConnectionFactory.setExceptionHandler(com.rabbitmq.client.ExceptionHandler)public java.lang.Class<?> getObjectType()
getObjectType in interface org.springframework.beans.factory.FactoryBean<com.rabbitmq.client.ConnectionFactory>getObjectType in class org.springframework.beans.factory.config.AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory>protected com.rabbitmq.client.ConnectionFactory createInstance()
throws java.lang.Exception
createInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory>java.lang.Exception