@UriParams public class NsqConfiguration extends Object
Constructor and Description |
---|
NsqConfiguration() |
Modifier and Type | Method and Description |
---|---|
Boolean |
getAutoFinish()
Automatically finish the NSQ message when it is retrieved from the quese and before the Exchange is processed.
|
String |
getChannel()
The name of channel we want to use
|
long |
getLookupInterval()
The lookup retry interval
|
int |
getLookupServerPort()
The port of the nsqdlookupd server
|
long |
getMessageTimeout()
The NSQ message timeout for a consumer.
|
int |
getPoolSize()
Consumer pool size
|
int |
getPort()
The port of the nsqd server
|
long |
getRequeueInterval()
The requeue interval
|
Set<com.github.brainlag.nsq.ServerAddress> |
getServerAddresses() |
String |
getServers() |
org.apache.camel.util.jsse.SSLContextParameters |
getSslContextParameters()
To configure security using SSLContextParameters
|
String |
getTopic()
The name of topic we want to use
|
String |
getUserAgent() |
boolean |
isSecure()
Set secure option indicating TLS is required
|
void |
setAutoFinish(Boolean autoFinish) |
void |
setChannel(String channel) |
void |
setLookupInterval(long lookupInterval) |
void |
setLookupServerPort(int lookupServerPort) |
void |
setMessageTimeout(long messageTimeout) |
void |
setPoolSize(int poolSize) |
void |
setPort(int port) |
void |
setRequeueInterval(long requeueInterval) |
void |
setSecure(boolean secure) |
void |
setServers(String servers) |
void |
setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters) |
void |
setTopic(String topic) |
void |
setUserAgent(String userAgent) |
public String getServers()
public void setServers(String servers)
public Set<com.github.brainlag.nsq.ServerAddress> getServerAddresses()
public String getTopic()
public void setTopic(String topic)
public String getChannel()
public void setChannel(String channel)
public int getPoolSize()
public void setPoolSize(int poolSize)
public int getLookupServerPort()
public void setLookupServerPort(int lookupServerPort)
public int getPort()
public void setPort(int port)
public long getLookupInterval()
public void setLookupInterval(long lookupInterval)
public long getRequeueInterval()
public void setRequeueInterval(long requeueInterval)
public Boolean getAutoFinish()
public void setAutoFinish(Boolean autoFinish)
public long getMessageTimeout()
public void setMessageTimeout(long messageTimeout)
public String getUserAgent()
public void setUserAgent(String userAgent)
public boolean isSecure()
public void setSecure(boolean secure)
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
Apache Camel