A
B
C
D
E
F
G
I
K
L
M
N
P
R
S
T
U
V
C
- ChannelStats - class in com.abusix.knsq.http.model
- ClientConfig - class in com.abusix.knsq.config
- This class is used for configuring the clients for nsq.
- ClientStats - class in com.abusix.knsq.http.model
- closeQuietly(java.io.Closeable,org.slf4j.Logger) - function in com.abusix.knsq.common.UtilKt
- Close this Closeable without throwing any kind of an IOException, if it occurs.
- com.abusix.knsq.common - package com.abusix.knsq.common
- com.abusix.knsq.config - package com.abusix.knsq.config
- com.abusix.knsq.http - package com.abusix.knsq.http
- com.abusix.knsq.http.model - package com.abusix.knsq.http.model
- com.abusix.knsq.protocol - package com.abusix.knsq.protocol
- com.abusix.knsq.publish - package com.abusix.knsq.publish
- com.abusix.knsq.subscribe - package com.abusix.knsq.subscribe
- connect() - function in com.abusix.knsq.publish.Publisher
- Trigger the connection establishing routine, if the connection is not already established.
- ConnectionConfig - class in com.abusix.knsq.config
- The configuration object that holds the config status for a single com.abusix.knsq.connection.Connection.
- createChannel(java.lang.String,java.lang.String) - function in com.abusix.knsq.http.NSQDHTTPClient
- Create a channel for an existing topic.
- createChannel(java.lang.String,java.lang.String) - function in com.abusix.knsq.http.NSQLookupDHTTPClient
- Creates a channel in the registry of nsqlookupd.
- createTopic(java.lang.String) - function in com.abusix.knsq.http.NSQDHTTPClient
- Creates a topic.
- createTopic(java.lang.String) - function in com.abusix.knsq.http.NSQLookupDHTTPClient
- Creates a topic in the registry of nsqlookupd.