Class NsqConfiguration


  • @UriParams
    public class NsqConfiguration
    extends Object
    • Constructor Detail

      • NsqConfiguration

        public NsqConfiguration()
    • 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