A B C D F G M N P R S T

A

accept(Message) - Method in class com.sproutsocial.nsq.BackoffHandler

accept(byte[]) - Method in interface com.sproutsocial.nsq.MessageDataHandler

accept(Message) - Method in interface com.sproutsocial.nsq.MessageHandler

B

BackoffHandler - Class in com.sproutsocial.nsq

BackoffHandler(MessageHandler, int, int) - Constructor for class com.sproutsocial.nsq.BackoffHandler

BackoffHandler(MessageHandler) - Constructor for class com.sproutsocial.nsq.BackoffHandler

C

Client - Class in com.sproutsocial.nsq

Client() - Constructor for class com.sproutsocial.nsq.Client

com.sproutsocial.nsq - package com.sproutsocial.nsq

Config - Class in com.sproutsocial.nsq

Configuration sent to nsqd with the IDENTIFY command http://nsq.io/clients/tcp_protocol_spec.html#identify to negotiate the features to use on a connection.

Config() - Constructor for class com.sproutsocial.nsq.Config

connectionClosed(PubConnection) - Method in class com.sproutsocial.nsq.Publisher

D

DirectSubscriber - Class in com.sproutsocial.nsq

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

DirectSubscriber(int, String...) - Constructor for class com.sproutsocial.nsq.DirectSubscriber

F

failed(String, String, Message) - Method in interface com.sproutsocial.nsq.FailedMessageHandler

FailedMessageHandler - Interface in com.sproutsocial.nsq

finish() - Method in interface com.sproutsocial.nsq.Message

G

getAttempts() - Method in interface com.sproutsocial.nsq.Message

getAuthSecret() - Method in class com.sproutsocial.nsq.Client

getClientId() - Method in class com.sproutsocial.nsq.Config

getConnectionCount() - Method in class com.sproutsocial.nsq.Subscriber

getData() - Method in interface com.sproutsocial.nsq.Message

getDefaultClient() - Static method in class com.sproutsocial.nsq.Client

getDefaultMaxInFlight() - Method in class com.sproutsocial.nsq.Subscriber

getDeflate() - Method in class com.sproutsocial.nsq.Config

getDeflateLevel() - Method in class com.sproutsocial.nsq.Config

getExecutor() - Method in class com.sproutsocial.nsq.Client

getExecutorQueueSize() - Method in class com.sproutsocial.nsq.Subscriber

getFailedMessageHandler() - Method in class com.sproutsocial.nsq.Subscriber

getFailoverDurationSecs() - Method in class com.sproutsocial.nsq.Publisher

getFeatureNegotiation() - Method in class com.sproutsocial.nsq.Config

getHeartbeatInterval() - Method in class com.sproutsocial.nsq.Config

getHostname() - Method in class com.sproutsocial.nsq.Config

getId() - Method in interface com.sproutsocial.nsq.Message

getLookupIntervalSecs() - Method in class com.sproutsocial.nsq.Subscriber

getMaxAttempts() - Method in class com.sproutsocial.nsq.Subscriber

getMaxFlushDelayMillis() - Method in class com.sproutsocial.nsq.Subscriber

getMsgTimeout() - Method in class com.sproutsocial.nsq.Config

getOutputBufferSize() - Method in class com.sproutsocial.nsq.Config

getOutputBufferTimeout() - Method in class com.sproutsocial.nsq.Config

getSampleRate() - Method in class com.sproutsocial.nsq.Config

getSnappy() - Method in class com.sproutsocial.nsq.Config

getSSLSocketFactory() - Method in class com.sproutsocial.nsq.Client

getTimestamp() - Method in interface com.sproutsocial.nsq.Message

getTlsV1() - Method in class com.sproutsocial.nsq.Config

getTopic() - Method in interface com.sproutsocial.nsq.Message

getUserAgent() - Method in class com.sproutsocial.nsq.Config

M

Message - Interface in com.sproutsocial.nsq

MessageDataHandler - Interface in com.sproutsocial.nsq

MessageHandler - Interface in com.sproutsocial.nsq

N

NSQException - Exception in com.sproutsocial.nsq

NSQException(String) - Constructor for exception com.sproutsocial.nsq.NSQException

NSQException(String, Throwable) - Constructor for exception com.sproutsocial.nsq.NSQException

P

publish(String, byte[]) - Method in class com.sproutsocial.nsq.Publisher

publish(String, List<byte[]>) - Method in class com.sproutsocial.nsq.Publisher

publishBuffered(String, byte[]) - Method in class com.sproutsocial.nsq.Publisher

publishDeferred(String, byte[], long, TimeUnit) - Method in class com.sproutsocial.nsq.Publisher

Publisher - Class in com.sproutsocial.nsq

Publisher(Client, String, String) - Constructor for class com.sproutsocial.nsq.Publisher

Publisher(String, String) - Constructor for class com.sproutsocial.nsq.Publisher

Publisher(String) - Constructor for class com.sproutsocial.nsq.Publisher

R

requeue() - Method in interface com.sproutsocial.nsq.Message

S

setAuthSecret(byte[]) - Method in class com.sproutsocial.nsq.Client

setAuthSecret(String) - Method in class com.sproutsocial.nsq.Client

setBatchConfig(String, int, int) - Method in class com.sproutsocial.nsq.Publisher

setClientId(String) - Method in class com.sproutsocial.nsq.Config

setDefaultMaxInFlight(int) - Method in class com.sproutsocial.nsq.Subscriber

the maxInFlight to use for new subscriptions

setDeflate(Boolean) - Method in class com.sproutsocial.nsq.Config

setDeflateLevel(Integer) - Method in class com.sproutsocial.nsq.Config

setExecutor(ExecutorService) - Method in class com.sproutsocial.nsq.Client

setFailedMessageHandler(FailedMessageHandler) - Method in class com.sproutsocial.nsq.Subscriber

setFailoverDurationSecs(int) - Method in class com.sproutsocial.nsq.Publisher

setFeatureNegotiation(Boolean) - Method in class com.sproutsocial.nsq.Config

setHeartbeatInterval(Integer) - Method in class com.sproutsocial.nsq.Config

setHostname(String) - Method in class com.sproutsocial.nsq.Config

setMaxAttempts(int) - Method in class com.sproutsocial.nsq.Subscriber

setMaxFlushDelayMillis(int) - Method in class com.sproutsocial.nsq.Subscriber

setMaxInFlight(String, String, int) - Method in class com.sproutsocial.nsq.Subscriber

setMsgTimeout(Integer) - Method in class com.sproutsocial.nsq.Config

setOutputBufferSize(Integer) - Method in class com.sproutsocial.nsq.Config

setOutputBufferTimeout(Integer) - Method in class com.sproutsocial.nsq.Config

setSampleRate(Integer) - Method in class com.sproutsocial.nsq.Config

setSnappy(Boolean) - Method in class com.sproutsocial.nsq.Config

setSSLSocketFactory(SSLSocketFactory) - Method in class com.sproutsocial.nsq.Client

setTlsV1(Boolean) - Method in class com.sproutsocial.nsq.Config

setUserAgent(String) - Method in class com.sproutsocial.nsq.Config

stop() - Method in class com.sproutsocial.nsq.Client

stop(int) - Method in class com.sproutsocial.nsq.Client

Stops all subscribers, waits for in-flight messages to be finished or requeued, stops the executor that handles messages, then stops all publishers.

stop() - Method in class com.sproutsocial.nsq.Publisher

stop() - Method in class com.sproutsocial.nsq.Subscriber

stopSubscribers(int) - Method in class com.sproutsocial.nsq.Client

Stops all subscribers, waits for in-flight messages to be finished or requeued, then closes subscriber connections.

subscribe(String, String, MessageHandler) - Method in class com.sproutsocial.nsq.Subscriber

subscribe(String, String, MessageDataHandler) - Method in class com.sproutsocial.nsq.Subscriber

subscribe(String, String, int, MessageHandler) - Method in class com.sproutsocial.nsq.Subscriber

Subscribe to a topic.

Subscriber - Class in com.sproutsocial.nsq

Subscriber(Client, int, int, String...) - Constructor for class com.sproutsocial.nsq.Subscriber

Subscriber(int, String...) - Constructor for class com.sproutsocial.nsq.Subscriber

Subscriber(String...) - Constructor for class com.sproutsocial.nsq.Subscriber

T

toString() - Method in class com.sproutsocial.nsq.Config

touch() - Method in interface com.sproutsocial.nsq.Message

A B C D F G M N P R S T