NATS .NET Client
1.1.4
The NATS.io .NET C# Client
|
Public Member Functions | |
void | Start () |
Public Member Functions inherited from NATS.Client.ISubscription | |
void | Unsubscribe () |
void | AutoUnsubscribe (int max) |
void | SetPendingLimits (long messageLimit, long bytesLimit) |
void | GetPending (out long pendingBytes, out long pendingMessages) |
void | GetMaxPending (out long maxPendingBytes, out long maxPendingMessages) |
void | ClearMaxPending () |
void | Drain () |
void | Drain (int timeout) |
Task | DrainAsync () |
Task | DrainAsync (int timeout) |
Events | |
EventHandler< MsgHandlerEventArgs > | MessageHandler |
Additional Inherited Members | |
Properties inherited from NATS.Client.ISubscription | |
long | Sid [get] |
string | Subject [get] |
string | Queue [get] |
Connection | Connection [get] |
bool | IsValid [get] |
int | QueuedMessageCount [get] |
long | PendingByteLimit [get, set] |
long | PendingMessageLimit [get, set] |
long | PendingBytes [get] |
long | PendingMessages [get] |
long | MaxPendingBytes [get] |
long | MaxPendingMessages [get] |
long | Delivered [get] |
long | Dropped [get] |
IAsyncSubscription asynchronously delivers messages to listeners of the MessageHandler event.
If the IAsyncSubscription is created without listening to the MessageHandler event, no messages will be received until Start() has been called.
void NATS.Client.IAsyncSubscription.Start | ( | ) |
Starts delivering received messages to listeners on MessageHandler from a separate thread.
If the IAsyncSubscription has already started delivering messages, this method is a no-op.
Implemented in NATS.Client.AsyncSubscription.