com.sproutsocial.nsq

Class Subscriber

java.lang.Object

com.sproutsocial.nsq.Subscriber

Direct Known Subclasses:

DirectSubscriber

@ThreadSafe
public class Subscriber
extends Object

Constructor Summary

Constructors

Constructor and Description
Subscriber(Client client, int lookupIntervalSecs, int maxLookupFailuresBeforeError, String... lookupHosts)
Subscriber(int lookupIntervalSecs, String... lookupHosts)
Subscriber(String... lookupHosts)

Method Summary

Modifier and Type	Method and Description
Client	getClient()
Config	getConfig()
int	getConnectionCount()
int	getDefaultMaxInFlight()
Integer	getExecutorQueueSize()
FailedMessageHandler	getFailedMessageHandler()
int	getLookupIntervalSecs()
int	getMaxAttempts()
int	getMaxFlushDelayMillis()
void	setConfig(Config config)
void	setDefaultMaxInFlight(int defaultMaxInFlight) the maxInFlight to use for new subscriptions
void	setFailedMessageHandler(FailedMessageHandler failedMessageHandler)
void	setMaxAttempts(int maxAttempts)
void	setMaxFlushDelayMillis(int maxFlushDelayMillis)
void	setMaxInFlight(String topic, String channel, int maxInFlight)
void	stop()
void	subscribe(String topic, String channel, int maxInFlight, MessageHandler handler) Subscribe to a topic.
void	subscribe(String topic, String channel, MessageDataHandler handler)
void	subscribe(String topic, String channel, MessageHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

Subscriber

public Subscriber(Client client,
                  int lookupIntervalSecs,
                  int maxLookupFailuresBeforeError,
                  String... lookupHosts)

Subscriber

public Subscriber(int lookupIntervalSecs,
                  String... lookupHosts)

Subscriber

public Subscriber(String... lookupHosts)

Method Detail

subscribe

public void subscribe(String topic,
                      String channel,
                      MessageHandler handler)

subscribe

public void subscribe(String topic,
                      String channel,
                      MessageDataHandler handler)

subscribe

public void subscribe(String topic,
                      String channel,
                      int maxInFlight,
                      MessageHandler handler)

Subscribe to a topic. If the configured executor is multi-threaded and maxInFlight > 1 (the defaults) then the MessageHandler must be thread safe.

setMaxInFlight

public void setMaxInFlight(String topic,
                           String channel,
                           int maxInFlight)

stop

public void stop()

getDefaultMaxInFlight

public int getDefaultMaxInFlight()

setDefaultMaxInFlight

public void setDefaultMaxInFlight(int defaultMaxInFlight)

the maxInFlight to use for new subscriptions

getMaxFlushDelayMillis

public int getMaxFlushDelayMillis()

setMaxFlushDelayMillis

public void setMaxFlushDelayMillis(int maxFlushDelayMillis)

getMaxAttempts

public int getMaxAttempts()

setMaxAttempts

public void setMaxAttempts(int maxAttempts)

getFailedMessageHandler

public FailedMessageHandler getFailedMessageHandler()

setFailedMessageHandler

public void setFailedMessageHandler(FailedMessageHandler failedMessageHandler)

getLookupIntervalSecs

public int getLookupIntervalSecs()

getExecutorQueueSize

public Integer getExecutorQueueSize()

getConnectionCount

public int getConnectionCount()

getClient

public final Client getClient()

getConfig

public Config getConfig()

setConfig

public void setConfig(Config config)