@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() |
int |
getPort() |
org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType |
getPublisherConfirmType() |
Duration |
getRequestedHeartbeat() |
RabbitProperties.Ssl |
getSsl() |
RabbitProperties.Template |
getTemplate() |
String |
getUsername() |
String |
getVirtualHost() |
boolean |
isPublisherConfirms() |
boolean |
isPublisherReturns() |
void |
setAddresses(String addresses) |
void |
setConnectionTimeout(Duration connectionTimeout) |
void |
setHost(String host) |
void |
setPassword(String password) |
void |
setPort(int port) |
void |
setPublisherConfirms(boolean publisherConfirms)
Deprecated.
|
void |
setPublisherConfirmType(org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType publisherConfirmType) |
void |
setPublisherReturns(boolean publisherReturns) |
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 int getPort()
public int determinePort()
setAddresses(String)
,
getPort()
public void setPort(int 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)
@DeprecatedConfigurationProperty(reason="replaced to support additional confirm types", replacement="spring.rabbitmq.publisher-confirm-type") public boolean isPublisherConfirms()
@Deprecated public void setPublisherConfirms(boolean publisherConfirms)
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()
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.