@ConfigurationProperties(prefix="spring.rabbitmq") public class RabbitProperties extends Object
Modifier and Type | Class and Description |
---|---|
static class |
RabbitProperties.AmqpContainer |
static class |
RabbitProperties.Cache |
static class |
RabbitProperties.ContainerType |
static class |
RabbitProperties.DirectContainer
Configuration properties for
DirectMessageListenerContainer . |
static class |
RabbitProperties.Listener |
static class |
RabbitProperties.ListenerRetry |
static class |
RabbitProperties.Retry |
static class |
RabbitProperties.SimpleContainer
Configuration properties for
SimpleMessageListenerContainer . |
class |
RabbitProperties.Ssl |
static class |
RabbitProperties.Template |
Constructor and Description |
---|
RabbitProperties() |
Modifier and Type | Method and Description |
---|---|
String |
determineAddresses()
Returns the comma-separated addresses or a single address (
host:port )
created from the configured host and port if no addresses have been set. |
String |
determineHost()
Returns the host from the first address, or the configured host if no addresses
have been set.
|
String |
determinePassword()
If addresses have been set and the first address has a password it is returned.
|
int |
determinePort()
Returns the port from the first address, or the configured port if no addresses
have been set.
|
String |
determineUsername()
If addresses have been set and the first address has a username it is returned.
|
String |
determineVirtualHost()
If addresses have been set and the first address has a virtual host it is returned.
|
String |
getAddresses() |
RabbitProperties.Cache |
getCache() |
Duration |
getConnectionTimeout() |
String |
getHost() |
RabbitProperties.Listener |
getListener() |
String |
getPassword() |
Integer |
getPort() |
org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType |
getPublisherConfirmType() |
int |
getRequestedChannelMax() |
Duration |
getRequestedHeartbeat() |
RabbitProperties.Ssl |
getSsl() |
RabbitProperties.Template |
getTemplate() |
String |
getUsername() |
String |
getVirtualHost() |
boolean |
isPublisherReturns() |
void |
setAddresses(String addresses) |
void |
setConnectionTimeout(Duration connectionTimeout) |
void |
setHost(String host) |
void |
setPassword(String password) |
void |
setPort(Integer port) |
void |
setPublisherConfirmType(org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType publisherConfirmType) |
void |
setPublisherReturns(boolean publisherReturns) |
void |
setRequestedChannelMax(int requestedChannelMax) |
void |
setRequestedHeartbeat(Duration requestedHeartbeat) |
void |
setUsername(String username) |
void |
setVirtualHost(String virtualHost) |
public String getHost()
public String determineHost()
setAddresses(String)
,
getHost()
public void setHost(String host)
public Integer getPort()
public int determinePort()
setAddresses(String)
,
getPort()
public void setPort(Integer port)
public String getAddresses()
public String determineAddresses()
host:port
)
created from the configured host and port if no addresses have been set.public void setAddresses(String addresses)
public String getUsername()
public String determineUsername()
getUsername()
.setAddresses(String)
,
getUsername()
public void setUsername(String username)
public String getPassword()
public String determinePassword()
getPassword()
.null
setAddresses(String)
,
getPassword()
public void setPassword(String password)
public RabbitProperties.Ssl getSsl()
public String getVirtualHost()
public String determineVirtualHost()
getVirtualHost()
.null
setAddresses(String)
,
getVirtualHost()
public void setVirtualHost(String virtualHost)
public Duration getRequestedHeartbeat()
public void setRequestedHeartbeat(Duration requestedHeartbeat)
public int getRequestedChannelMax()
public void setRequestedChannelMax(int requestedChannelMax)
public boolean isPublisherReturns()
public void setPublisherReturns(boolean publisherReturns)
public Duration getConnectionTimeout()
public void setPublisherConfirmType(org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType publisherConfirmType)
public org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType getPublisherConfirmType()
public void setConnectionTimeout(Duration connectionTimeout)
public RabbitProperties.Cache getCache()
public RabbitProperties.Listener getListener()
public RabbitProperties.Template getTemplate()