com.sproutsocial.nsq

Class DirectSubscriber

java.lang.Object

com.sproutsocial.nsq.Subscriber

com.sproutsocial.nsq.DirectSubscriber

public class DirectSubscriber
extends Subscriber

Subscribe from a given set of nsqd hosts instead of using the lookup service.

Constructor Summary

Constructors

Constructor and Description
DirectSubscriber(int checkHostsIntervalSecs, String... nsqdHosts)

Method Summary

Modifier and Type	Method and Description
Client	getClient()
Config	getConfig()
void	setConfig(Config config)

Methods inherited from class com.sproutsocial.nsq.Subscriber

getConnectionCount, getDefaultMaxInFlight, getExecutorQueueSize, getFailedMessageHandler, getLookupIntervalSecs, getMaxAttempts, getMaxFlushDelayMillis, setDefaultMaxInFlight, setFailedMessageHandler, setMaxAttempts, setMaxFlushDelayMillis, setMaxInFlight, stop, subscribe, subscribe, subscribe

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DirectSubscriber

public DirectSubscriber(int checkHostsIntervalSecs,
                        String... nsqdHosts)

Method Detail

getClient

public final Client getClient()

getConfig

public Config getConfig()

setConfig

public void setConfig(Config config)