@UriParams public class NatsConfiguration extends Object
Constructor and Description |
---|
NatsConfiguration() |
Modifier and Type | Method and Description |
---|---|
Properties |
createProperties() |
String |
getMaxMessages()
Stop receiving messages from a topic we are subscribing to after maxMessages
|
int |
getMaxReconnectAttempts()
Max reconnection attempts
|
boolean |
getNoRandomizeServers()
Whether or not randomizing the order of servers for the connection attempts
|
boolean |
getPedantic()
Whether or not running in pedantic mode (this affects performace)
|
int |
getPingInterval()
Ping interval to be aware if connection is still alive (in milliseconds)
|
int |
getPoolSize()
Consumer pool size
|
String |
getQueueName()
The Queue name if we are using nats for a queue configuration
|
boolean |
getReconnect()
Whether or not using reconnection feature
|
int |
getReconnectTimeWait()
Waiting time before attempts reconnection (in milliseconds)
|
String |
getReplySubject()
the subject to which subscribers should send response
|
String |
getServers()
URLs to one or more NAT servers.
|
boolean |
getSsl()
Whether or not using SSL
|
String |
getTopic()
The name of topic we want to use
|
boolean |
getVerbose()
Whether or not running in verbose mode
|
void |
setMaxMessages(String maxMessages) |
void |
setMaxReconnectAttempts(int maxReconnectAttempts) |
void |
setNoRandomizeServers(boolean noRandomizeServers) |
void |
setPedantic(boolean pedantic) |
void |
setPingInterval(int pingInterval) |
void |
setPoolSize(int poolSize) |
void |
setQueueName(String queueName) |
void |
setReconnect(boolean reconnect) |
void |
setReconnectTimeWait(int reconnectTimeWait) |
void |
setReplySubject(String replySubject) |
void |
setServers(String servers) |
void |
setSsl(boolean ssl) |
void |
setTopic(String topic) |
void |
setVerbose(boolean verbose) |
public String getServers()
public void setServers(String servers)
public String getTopic()
public void setTopic(String topic)
public boolean getReconnect()
public void setReconnect(boolean reconnect)
public boolean getPedantic()
public void setPedantic(boolean pedantic)
public boolean getVerbose()
public void setVerbose(boolean verbose)
public boolean getSsl()
public void setSsl(boolean ssl)
public int getReconnectTimeWait()
public void setReconnectTimeWait(int reconnectTimeWait)
public int getMaxReconnectAttempts()
public void setMaxReconnectAttempts(int maxReconnectAttempts)
public int getPingInterval()
public void setPingInterval(int pingInterval)
public String getReplySubject()
public void setReplySubject(String replySubject)
public boolean getNoRandomizeServers()
public void setNoRandomizeServers(boolean noRandomizeServers)
public String getQueueName()
public void setQueueName(String queueName)
public String getMaxMessages()
public void setMaxMessages(String maxMessages)
public int getPoolSize()
public void setPoolSize(int poolSize)
public Properties createProperties()
Apache Camel