com.sproutsocial.nsq

Class Publisher

java.lang.Object

com.sproutsocial.nsq.Publisher

@ThreadSafe
public class Publisher
extends Object

Constructor Summary

Constructors

Constructor and Description
Publisher(Client client, String nsqd, String failoverNsqd)
Publisher(String nsqd)
Publisher(String nsqd, String failoverNsqd)

Method Summary

Modifier and Type	Method and Description
void	connectionClosed(com.sproutsocial.nsq.PubConnection closedCon)
Client	getClient()
Config	getConfig()
int	getFailoverDurationSecs()
void	publish(String topic, byte[] data)
void	publish(String topic, List<byte[]> dataList)
void	publishBuffered(String topic, byte[] data)
void	publishDeferred(String topic, byte[] data, long delay, TimeUnit unit)
void	setBatchConfig(String topic, int maxSizeBytes, int maxDelayMillis)
void	setConfig(Config config)
void	setFailoverDurationSecs(int failoverDurationSecs)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

Publisher

public Publisher(Client client,
                 String nsqd,
                 String failoverNsqd)

Publisher

public Publisher(String nsqd,
                 String failoverNsqd)

Publisher

public Publisher(String nsqd)

Method Detail

connectionClosed

public void connectionClosed(com.sproutsocial.nsq.PubConnection closedCon)

publish

public void publish(String topic,
                    byte[] data)

publishDeferred

public void publishDeferred(String topic,
                            byte[] data,
                            long delay,
                            TimeUnit unit)

publish

public void publish(String topic,
                    List<byte[]> dataList)

publishBuffered

public void publishBuffered(String topic,
                            byte[] data)

setBatchConfig

public void setBatchConfig(String topic,
                           int maxSizeBytes,
                           int maxDelayMillis)

stop

public void stop()

getFailoverDurationSecs

public int getFailoverDurationSecs()

setFailoverDurationSecs

public void setFailoverDurationSecs(int failoverDurationSecs)

getClient

public final Client getClient()

getConfig

public Config getConfig()

setConfig

public void setConfig(Config config)