Class RabbitProperties
java.lang.Object
org.springframework.boot.autoconfigure.amqp.RabbitProperties
Configuration properties for Rabbit.
- Since:
- 1.0.0
- Author:
- Greg Turnquist, Dave Syer, Stephane Nicoll, Andy Wilkinson, Josh Thornhill, Gary Russell, Artsiom Yudovin, Franjo Zilic, EddĂș MelĂ©ndez, Rafael Carvalho, Scott Frederick, Lasse Wulff
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
static class
static class
static enum
static class
Configuration properties forDirectMessageListenerContainer
.static class
static class
static class
static class
Configuration properties forSimpleMessageListenerContainer
.class
static final class
static class
static class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionReturns the comma-separated addresses or a single address (host:port
) created from the configured host and port if no addresses have been set.Returns the host from the first address, or the configured host if no addresses have been set.If addresses have been set and the first address has a password it is returned.int
Returns the port from the first address, or the configured port if no addresses have been set.If addresses have been set and the first address has a username it is returned.If addresses have been set and the first address has a virtual host it is returned.org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode
getCache()
getHost()
getPort()
org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType
int
getSsl()
boolean
void
setAddresses
(String addresses) void
setAddressShuffleMode
(org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode addressShuffleMode) void
setChannelRpcTimeout
(Duration channelRpcTimeout) void
setConnectionTimeout
(Duration connectionTimeout) void
void
setMaxInboundMessageBodySize
(DataSize maxInboundMessageBodySize) void
setPassword
(String password) void
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)
-
Constructor Details
-
RabbitProperties
public RabbitProperties()
-
-
Method Details
-
getHost
-
determineHost
Returns the host from the first address, or the configured host if no addresses have been set.- Returns:
- the host
- See Also:
-
setHost
-
getPort
-
determinePort
public int determinePort()Returns the port from the first address, or the configured port if no addresses have been set.- Returns:
- the port
- See Also:
-
setPort
-
getAddresses
-
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.- Returns:
- the addresses
-
setAddresses
-
getUsername
-
determineUsername
If addresses have been set and the first address has a username it is returned. Otherwise returns the result of callinggetUsername()
.- Returns:
- the username
- See Also:
-
setUsername
-
getPassword
-
determinePassword
If addresses have been set and the first address has a password it is returned. Otherwise returns the result of callinggetPassword()
.- Returns:
- the password or
null
- See Also:
-
setPassword
-
getSsl
-
getVirtualHost
-
determineVirtualHost
If addresses have been set and the first address has a virtual host it is returned. Otherwise returns the result of callinggetVirtualHost()
.- Returns:
- the virtual host or
null
- See Also:
-
setVirtualHost
-
getAddressShuffleMode
public org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode getAddressShuffleMode() -
setAddressShuffleMode
public void setAddressShuffleMode(org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode addressShuffleMode) -
getRequestedHeartbeat
-
setRequestedHeartbeat
-
getRequestedChannelMax
public int getRequestedChannelMax() -
setRequestedChannelMax
public void setRequestedChannelMax(int requestedChannelMax) -
isPublisherReturns
public boolean isPublisherReturns() -
setPublisherReturns
public void setPublisherReturns(boolean publisherReturns) -
getConnectionTimeout
-
setPublisherConfirmType
public void setPublisherConfirmType(org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType publisherConfirmType) -
getPublisherConfirmType
public org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType getPublisherConfirmType() -
setConnectionTimeout
-
getChannelRpcTimeout
-
setChannelRpcTimeout
-
getMaxInboundMessageBodySize
-
setMaxInboundMessageBodySize
-
getCache
-
getListener
-
getTemplate
-
getStream
-