NATS C Client with JetStream and Streaming support
3.10.0
The nats.io C Client, Supported by Synadia Communications Inc.
|
#include <nats.h>
Public Attributes | |
int64_t | MaxPending |
Maximum outstanding asynchronous publishes that can be inflight at one time. | |
jsPubAckHandler | AckHandler |
Callback invoked for each asynchronous published message. | |
void * | AckHandlerClosure |
Closure (or user data) passed to jsPubAckHandler callback. | |
jsPubAckErrHandler | ErrHandler |
Callback invoked when error encountered publishing a given message. | |
void * | ErrHandlerClosure |
Closure (or user data) passed to jsPubAckErrHandler callback. | |
int64_t | StallWait |
Amount of time (in milliseconds) to wait in a PublishAsync call when there is MaxPending inflight messages, default is 200 ms. | |
Async pull options.
Part of jsOptions.
int64_t jsOptionsPublishAsync::MaxPending |
jsPubAckHandler jsOptionsPublishAsync::AckHandler |
void* jsOptionsPublishAsync::AckHandlerClosure |
jsPubAckErrHandler jsOptionsPublishAsync::ErrHandler |
void* jsOptionsPublishAsync::ErrHandlerClosure |
int64_t jsOptionsPublishAsync::StallWait |