Package org.apache.camel.component.nsq
Class NsqConfiguration
- java.lang.Object
-
- org.apache.camel.component.nsq.NsqConfiguration
-
@UriParams public class NsqConfiguration extends Object
-
-
Constructor Summary
Constructors Constructor Description NsqConfiguration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 usecom.github.brainlag.nsq.lookup.NSQLookup
getCustomNSQLookup()
long
getLookupInterval()
The lookup retry intervalint
getLookupServerPort()
The port of the nsqdlookupd serverlong
getMessageTimeout()
The NSQ message timeout for a consumer.int
getPoolSize()
Consumer pool sizeint
getPort()
The port of the nsqd serverlong
getRequeueInterval()
The requeue intervalSet<com.github.brainlag.nsq.ServerAddress>
getServerAddresses()
String
getServers()
org.apache.camel.support.jsse.SSLContextParameters
getSslContextParameters()
To configure security using SSLContextParametersString
getTopic()
The name of topic we want to useString
getUserAgent()
boolean
isSecure()
Set secure option indicating TLS is requiredvoid
setAutoFinish(Boolean autoFinish)
void
setChannel(String channel)
void
setCustomNSQLookup(com.github.brainlag.nsq.lookup.NSQLookup customNSQLookup)
Set a custom NSQLookup implementationvoid
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.support.jsse.SSLContextParameters sslContextParameters)
void
setTopic(String topic)
void
setUserAgent(String userAgent)
-
-
-
Method Detail
-
getServers
public String getServers()
-
setServers
public void setServers(String servers)
-
getServerAddresses
public Set<com.github.brainlag.nsq.ServerAddress> getServerAddresses()
-
getTopic
public String getTopic()
The name of topic we want to use
-
setTopic
public void setTopic(String topic)
-
getChannel
public String getChannel()
The name of channel we want to use
-
setChannel
public void setChannel(String channel)
-
getPoolSize
public int getPoolSize()
Consumer pool size
-
setPoolSize
public void setPoolSize(int poolSize)
-
getLookupServerPort
public int getLookupServerPort()
The port of the nsqdlookupd server
-
setLookupServerPort
public void setLookupServerPort(int lookupServerPort)
-
getPort
public int getPort()
The port of the nsqd server
-
setPort
public void setPort(int port)
-
getLookupInterval
public long getLookupInterval()
The lookup retry interval
-
setLookupInterval
public void setLookupInterval(long lookupInterval)
-
getRequeueInterval
public long getRequeueInterval()
The requeue interval
-
setRequeueInterval
public void setRequeueInterval(long requeueInterval)
-
getAutoFinish
public Boolean getAutoFinish()
Automatically finish the NSQ message when it is retrieved from the quese and before the Exchange is processed.
-
setAutoFinish
public void setAutoFinish(Boolean autoFinish)
-
getMessageTimeout
public long getMessageTimeout()
The NSQ message timeout for a consumer.
-
setMessageTimeout
public void setMessageTimeout(long messageTimeout)
-
getUserAgent
public String getUserAgent()
-
setUserAgent
public void setUserAgent(String userAgent)
-
isSecure
public boolean isSecure()
Set secure option indicating TLS is required
-
setSecure
public void setSecure(boolean secure)
-
getSslContextParameters
public org.apache.camel.support.jsse.SSLContextParameters getSslContextParameters()
To configure security using SSLContextParameters
-
setSslContextParameters
public void setSslContextParameters(org.apache.camel.support.jsse.SSLContextParameters sslContextParameters)
-
getCustomNSQLookup
public com.github.brainlag.nsq.lookup.NSQLookup getCustomNSQLookup()
-
setCustomNSQLookup
public void setCustomNSQLookup(com.github.brainlag.nsq.lookup.NSQLookup customNSQLookup)
Set a custom NSQLookup implementation
-
-