A
B
C
D
E
F
G
I
K
L
M
N
P
R
S
T
U
V
S
- setAuthSecret(kotlin.ByteArray) - function in com.abusix.knsq.config.ClientConfig
- The secret used for authorization, if the server requires it.
- setAutoFinish(java.lang.Boolean) - function in com.abusix.knsq.subscribe.BackoffHandler
- Whether or not messages processed in this BackoffHandler should be automatically finished after receiving them without an exception.
- setConnectTimeout(java.lang.Integer) - function in com.abusix.knsq.config.ClientConfig
- The timeout for establishing a connection.
- setHeartbeatInterval(java.lang.Long) - function in com.abusix.knsq.config.ConnectionConfig
- The interval for which nsqd expects and sends heartbeats, if no other messages were sent.
- setInitDelay(java.time.Duration) - function in com.abusix.knsq.subscribe.BackoffHandler
- The initial length of a low traffic period after the first failed received packet.
- setInitialMaxInFlight(java.lang.Integer) - function in com.abusix.knsq.subscribe.Subscriber
- setInitialMaxInFlight(java.lang.Integer) - function in com.abusix.knsq.subscribe.Subscriber
- setMaxDelay(java.time.Duration) - function in com.abusix.knsq.publish.Batcher
- The maximum delay before a message is guaranteed to be sent.
- setMaxDelay(java.time.Duration) - function in com.abusix.knsq.subscribe.BackoffHandler
- The maximum delay until the full traffic volume is tried again.
- setMaxInFlight(java.lang.Integer) - function in com.abusix.knsq.subscribe.Subscription
- setMaxMessageAttempts(java.lang.Integer) - function in com.abusix.knsq.subscribe.Subscriber
- setMaxMessageAttempts(java.lang.Integer) - function in com.abusix.knsq.subscribe.Subscriber
- setMaxSize(java.lang.Integer) - function in com.abusix.knsq.publish.Batcher
- The maximum size for a single message batch in bytes.
- setMaxUnflushedBytes(java.lang.Long) - function in com.abusix.knsq.subscribe.Subscriber
- setMaxUnflushedBytes(java.lang.Long) - function in com.abusix.knsq.subscribe.Subscriber
- setOnException(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.publish.Publisher
- A listener that can be used to obtain asynchronous exceptions.
- setOnException(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscription
- A listener for Exceptions that happened within this Subscriber or its Subscriptions.
- setOnFailedMessage(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscription
- A callback function for receiving failed messages.
- setOnLookupException(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- An exception listener that can be used to receive exceptions that were thrown while trying to contact the nsqlookupd server.
- setOnLookupException(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- An exception listener that can be used to receive exceptions that were thrown while trying to contact the nsqlookupd server.
- setOnMessage(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscription
- A listener for receiving messages.
- setOnNSQError(kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscription
- A listener for errors that were returned by nsqd within this Subscriber or its Subscriptions.
- setReadTimeout(java.lang.Integer) - function in com.abusix.knsq.config.ClientConfig
- The read timeout for connection sockets and for awaiting responses from nsq.
- setSslSocketFactory(javax.net.ssl.SSLSocketFactory) - function in com.abusix.knsq.config.ClientConfig
- Using this property, you can use custom SSL configurations, e.g.
- setStackTrace(kotlin.Array) - function in kotlin.Throwable
- stats() - function in com.abusix.knsq.http.NSQDHTTPClient
- Returns all internal statistics of this nsqd node.
- StatsResponse - class in com.abusix.knsq.http.model
- The response object that is returned by calling com.abusix.knsq.http.NSQDHTTPClient.stats.
- stop(java.time.Duration) - function in com.abusix.knsq.publish.Publisher
- Stops this publisher and its associated connection.
- stop(java.time.Duration) - function in com.abusix.knsq.subscribe.Subscriber
- Stops this subscriber and all of its associated connections.
- stop(java.time.Duration) - function in com.abusix.knsq.subscribe.Subscriber
- Stops this subscriber and all of its associated connections.
- stop() - function in com.abusix.knsq.subscribe.Subscription
- Stops this subscription and all of its associated connections.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,java.lang.Boolean) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,java.lang.Boolean) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- subscribe(java.lang.String,java.lang.String,kotlin.jvm.functions.Function1) - function in com.abusix.knsq.subscribe.Subscriber
- Subscribe to a topic using a certain channel.
- Subscriber - class in com.abusix.knsq.subscribe
- This class implements a high-level subscriber that connects to one or multiple nsqlookupd instances.
- Subscriber.Companion - class in com.abusix.knsq.subscribe.Subscriber
- Subscription - class in com.abusix.knsq.subscribe
- A class that represents a subscription for a specific topic and channel to multiple nsqd instances.