@UriParams public class NatsConfiguration extends Object
Constructor and Description |
---|
NatsConfiguration() |
Modifier and Type | Method and Description |
---|---|
Properties |
createProperties() |
int |
getFlushTimeout() |
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
|
org.apache.camel.util.jsse.SSLContextParameters |
getSslContextParameters()
To configure security using SSLContextParameters
|
String |
getTopic()
The name of topic we want to use
|
boolean |
getVerbose()
Whether or not running in verbose mode
|
boolean |
isFlushConnection() |
boolean |
isSecure()
Set secure option indicating TLS is required
|
boolean |
isTlsDebug()
TLS Debug, it will add additional console output
|
void |
setFlushConnection(boolean flushConnection)
Define if we want to flush connection or not
|
void |
setFlushTimeout(int flushTimeout)
Set the flush timeout
|
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 |
setSecure(boolean secure) |
void |
setServers(String servers) |
void |
setSsl(boolean ssl) |
void |
setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters) |
void |
setTlsDebug(boolean tlsDebug) |
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 boolean isFlushConnection()
public void setFlushConnection(boolean flushConnection)
public int getFlushTimeout()
public void setFlushTimeout(int flushTimeout)
public boolean isSecure()
public void setSecure(boolean secure)
public boolean isTlsDebug()
public void setTlsDebug(boolean tlsDebug)
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
public Properties createProperties()
Apache Camel