#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.

bool	MuxReplies

Detailed Description

Async pull options.

Part of jsOptions.

Member Data Documentation

◆ MaxPending

int64_t jsOptionsPublishAsync::MaxPending

◆ AckHandler

jsPubAckHandler jsOptionsPublishAsync::AckHandler

◆ AckHandlerClosure

void* jsOptionsPublishAsync::AckHandlerClosure

◆ ErrHandler

jsPubAckErrHandler jsOptionsPublishAsync::ErrHandler

◆ ErrHandlerClosure

void* jsOptionsPublishAsync::ErrHandlerClosure

◆ StallWait

int64_t jsOptionsPublishAsync::StallWait

◆ MuxReplies

bool jsOptionsPublishAsync::MuxReplies

If true the replies to asynchronous publishes will be received by the connection's responses multiplexer (avoids creating an internal subscription per context). Works only if the connection has not been created with natsOptions_UseOldRequestStyle.

The documentation for this struct was generated from the following file:

nats.h

Public Attributes