Inheritance diagram for NATS.Client.IConnection:

Public Member Functions
void	Publish (string subject, byte[] data)

void	Publish (string subject, MsgHeader headers, byte[] data)

void	Publish (string subject, byte[] data, int offset, int count)

void	Publish (string subject, MsgHeader headers, byte[] data, int offset, int count)

void	Publish (string subject, string reply, byte[] data)

void	Publish (string subject, string reply, MsgHeader headers, byte[] data)

void	Publish (string subject, string reply, byte[] data, int offset, int count)

void	Publish (string subject, string reply, MsgHeader headers, byte[] data, int offset, int count)

void	Publish (Msg msg)

Msg	Request (string subject, byte[] data, int timeout)

Msg	Request (string subject, MsgHeader headers, byte[] data, int timeout)

Msg	Request (string subject, byte[] data, int offset, int count, int timeout)

Msg	Request (string subject, MsgHeader headers, byte[] data, int offset, int count, int timeout)

Msg	Request (string subject, byte[] data)

Msg	Request (string subject, MsgHeader headers, byte[] data)

Msg	Request (string subject, byte[] data, int offset, int count)

Msg	Request (string subject, MsgHeader headers, byte[] data, int offset, int count)

Msg	Request (Msg message)

Msg	Request (Msg message, int timeout)

Task< Msg >	RequestAsync (string subject, byte[] data, int timeout)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data, int timeout)

Task< Msg >	RequestAsync (string subject, byte[] data, int offset, int count, int timeout)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data, int offset, int count, int timeout)

Task< Msg >	RequestAsync (string subject, byte[] data)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data)

Task< Msg >	RequestAsync (string subject, byte[] data, int offset, int count)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data, int offset, int count)

Task< Msg >	RequestAsync (string subject, byte[] data, int timeout, CancellationToken token)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data, int timeout, CancellationToken token)

Task< Msg >	RequestAsync (string subject, byte[] data, CancellationToken token)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data, CancellationToken token)

Task< Msg >	RequestAsync (string subject, byte[] data, int offset, int count, CancellationToken token)

Task< Msg >	RequestAsync (string subject, MsgHeader headers, byte[] data, int offset, int count, CancellationToken token)

Task< Msg >	RequestAsync (Msg message)

Task< Msg >	RequestAsync (Msg message, int timeout)

Task< Msg >	RequestAsync (Msg message, CancellationToken token)

Task< Msg >	RequestAsync (Msg message, int timeout, CancellationToken token)

string	NewInbox ()

ISyncSubscription	SubscribeSync (string subject)

IAsyncSubscription	SubscribeAsync (string subject)

IAsyncSubscription	SubscribeAsync (string subject, EventHandler< MsgHandlerEventArgs > handler)

ISyncSubscription	SubscribeSync (string subject, string queue)

IAsyncSubscription	SubscribeAsync (string subject, string queue)

IAsyncSubscription	SubscribeAsync (string subject, string queue, EventHandler< MsgHandlerEventArgs > handler)

void	Flush (int timeout)

TimeSpan	RTT ()

void	Flush ()

void	FlushBuffer ()

void	Close ()

bool	IsClosed ()

bool	IsReconnecting ()

void	ResetStats ()

Task	DrainAsync ()

Task	DrainAsync (int timeout)

void	Drain ()

void	Drain (int timeout)

bool	IsDraining ()

IStreamContext	GetStreamContext (string streamName)

IStreamContext	GetStreamContext (string streamName, JetStreamOptions options)

IConsumerContext	GetConsumerContext (string streamName, string consumerName)

IConsumerContext	GetConsumerContext (string streamName, string consumerName, JetStreamOptions options)

IJetStream	CreateJetStreamContext (JetStreamOptions options=null)

IJetStreamManagement	CreateJetStreamManagementContext (JetStreamOptions options=null)

IKeyValue	CreateKeyValueContext (string bucketName, KeyValueOptions options=null)

IKeyValueManagement	CreateKeyValueManagementContext (KeyValueOptions options=null)

IObjectStore	CreateObjectStoreContext (string bucketName, ObjectStoreOptions options=null)

IObjectStoreManagement	CreateObjectStoreManagementContext (ObjectStoreOptions options=null)

Properties
Options	Opts `[get]`

IPAddress	ClientIP `[get]`

int	ClientID `[get]`

string	ConnectedUrl `[get]`

string	ConnectedId `[get]`

ServerInfo	ServerInfo `[get]`

string[]	Servers `[get]`

string[]	DiscoveredServers `[get]`

Exception	LastError `[get]`

ConnState	State `[get]`

IStatistics	Stats `[get]`

long	MaxPayload `[get]`

int	SubscriptionCount `[get]`

Detailed Description

Represents a connection to the NATS server.

Member Function Documentation

◆ Close()

void NATS.Client.IConnection.Close ( )

Closes the IConnection and all associated subscriptions.

See also: IsClosed, State

Implemented in NATS.Client.Connection.

◆ CreateJetStreamContext()

IJetStream NATS.Client.IConnection.CreateJetStreamContext ( JetStreamOptions options = null )

Gets a context for publishing and subscribing to subjects backed by Jetstream streams and consumers.

Parameters

options Optional JetStream options.

Returns

Implemented in NATS.Client.Connection.

◆ CreateJetStreamManagementContext()

IJetStreamManagement NATS.Client.IConnection.CreateJetStreamManagementContext ( JetStreamOptions options = null )

Gets a context for administrating JetStream.

Parameters

options Optional JetStream options.

Returns: an IJetStreamManagement instance

Implemented in NATS.Client.Connection.

◆ CreateKeyValueContext()

IKeyValue NATS.Client.IConnection.CreateKeyValueContext	(	string	bucketName,
		KeyValueOptions	options = `null`
	)

Gets a context for a Key Value bucket

Parameters

bucketName	The name of the bucket
options	Optional KeyValueOptions.

Returns

Implemented in NATS.Client.Connection.

◆ CreateKeyValueManagementContext()

IKeyValueManagement NATS.Client.IConnection.CreateKeyValueManagementContext ( KeyValueOptions options = null )

Gets a context for administrating Key Value buckets

Parameters

options Optional KeyValueOptions.

Returns

Implemented in NATS.Client.Connection.

◆ CreateObjectStoreContext()

IObjectStore NATS.Client.IConnection.CreateObjectStoreContext	(	string	bucketName,
		ObjectStoreOptions	options = `null`
	)

Gets a context for a Object Store OBJECT STORE IMPLEMENTATION IS EXPERIMENTAL AND SUBJECT TO CHANGE.

Parameters

bucketName	The name of the bucket
options	Optional ObjectStoreOptions.

Returns

Implemented in NATS.Client.Connection.

◆ CreateObjectStoreManagementContext()

IObjectStoreManagement NATS.Client.IConnection.CreateObjectStoreManagementContext ( ObjectStoreOptions options = null )

Gets a context for administrating Object Stores OBJECT STORE IMPLEMENTATION IS EXPERIMENTAL AND SUBJECT TO CHANGE.

Parameters

options Optional ObjectStoreOptions.

Returns

Implemented in NATS.Client.Connection.

◆ Drain() [1/2]

void NATS.Client.IConnection.Drain ( )

Drains a connection for graceful shutdown.

Drain will put a connection into a drain state. All subscriptions will immediately be put into a drain state. Upon completion, the publishers will be drained and can not publish any additional messages. Upon draining of the publishers, the connection will be closed. Use the Options.ClosedEventHandler option to know when the connection has moved from draining to closed.

See also: Close()

Implemented in NATS.Client.Connection.

◆ Drain() [2/2]

void NATS.Client.IConnection.Drain ( int timeout )

Drains a connection for graceful shutdown.

Drain will put a connection into a drain state. All subscriptions will immediately be put into a drain state. Upon completion, the publishers will be drained and can not publish any additional messages. Upon draining of the publishers, the connection will be closed. Use the Options.ClosedEventHandler option to know when the connection has moved from draining to closed.

See also: Close()

Parameters

timeout The duration to wait before draining.

Implemented in NATS.Client.Connection.

◆ DrainAsync() [1/2]

Task NATS.Client.IConnection.DrainAsync ( )

Drains a connection for graceful shutdown.

Drain will put a connection into a drain state. All subscriptions will immediately be put into a drain state. Upon completion, the publishers will be drained and can not publish any additional messages. Upon draining of the publishers, the connection will be closed. Use the Options.ClosedEventHandler option to know when the connection has moved from draining to closed.

See also: Close()

Returns: A task that represents the asynchronous drain operation.

Implemented in NATS.Client.Connection.

◆ DrainAsync() [2/2]

Task NATS.Client.IConnection.DrainAsync ( int timeout )

Drains a connection for graceful shutdown.

Drain will put a connection into a drain state. All subscriptions will immediately be put into a drain state. Upon completion, the publishers will be drained and can not publish any additional messages. Upon draining of the publishers, the connection will be closed. Use the Options.ClosedEventHandler option to know when the connection has moved from draining to closed.

See also: Close()

Parameters

timeout The duration to wait for the drain to complete.

Returns: A task that represents the asynchronous drain operation.

Implemented in NATS.Client.Connection.

◆ Flush()

void NATS.Client.IConnection.Flush ( int timeout )

Performs a round trip to the server and returns when it receives the internal reply, or throws a NATSTimeoutException exception if the NATS Server does not reply in time.

Parameters

timeout The number of milliseconds to wait.

Implemented in NATS.Client.Connection.

◆ FlushBuffer()

void NATS.Client.IConnection.FlushBuffer ( )

Immediately flushes the underlying connection buffer if the connection is valid.

Exceptions

NATSConnectionClosedException	The Connection is closed.
NATSException	There was an unexpected exception performing an internal NATS call while executing the request. See Exception.InnerException for more details.

Implemented in NATS.Client.Connection.

◆ GetConsumerContext() [1/2]

IConsumerContext NATS.Client.IConnection.GetConsumerContext	(	string	streamName,
		string	consumerName
	)

Get a consumer context for a specific named stream and specific named consumer. Verifies that the stream and consumer exist.

Parameters

streamName	the name of the stream
consumerName	the name of the consumer

Returns: an IConsumerContext instance

Implemented in NATS.Client.Connection.

◆ GetConsumerContext() [2/2]

IConsumerContext NATS.Client.IConnection.GetConsumerContext	(	string	streamName,
		string	consumerName,
		JetStreamOptions	options
	)

Get a consumer context for a specific named stream and specific named consumer. Verifies that the stream and consumer exist.

Parameters

streamName	the name of the stream
consumerName	the name of the consumer
options	JetStream options.

Returns: an IConsumerContext instance

Implemented in NATS.Client.Connection.

◆ GetStreamContext() [1/2]

IStreamContext NATS.Client.IConnection.GetStreamContext ( string streamName )

Get a stream context for a specific stream.

Parameters

streamName the stream for the context

Returns

a StreamContext instance.

an IStreamContext instance

Implemented in NATS.Client.Connection.

◆ GetStreamContext() [2/2]

IStreamContext NATS.Client.IConnection.GetStreamContext	(	string	streamName,
		JetStreamOptions	options
	)

Gets a stream context.

Parameters

streamName	the stream for the context
options	JetStream options.

Returns: an IStreamContext instance

Implemented in NATS.Client.Connection.

◆ IsClosed()

bool NATS.Client.IConnection.IsClosed ( )

Returns a value indicating whether or not the IConnection instance is closed.

Returns: true if and only if the IConnection is closed, otherwise false.

See also: Close, State

Implemented in NATS.Client.Connection.

◆ IsDraining()

bool NATS.Client.IConnection.IsDraining ( )

Returns a value indicating whether or not the IConnection connection is draining.

Returns: true if and only if the IConnection is closed, otherwise false.

See also: Close, State

Implemented in NATS.Client.Connection.

◆ IsReconnecting()

bool NATS.Client.IConnection.IsReconnecting ( )

Returns a value indicating whether or not the IConnection is currently reconnecting.

Returns: true if and only if the IConnection is reconnecting, otherwise false.

See also: State

Implemented in NATS.Client.Connection.

◆ NewInbox()

string NATS.Client.IConnection.NewInbox ( )

Creates an inbox string which can be used for directed replies from subscribers.

The returned inboxes are guaranteed to be unique, but can be shared and subscribed to by others.

Returns: A unique inbox string.

Implemented in NATS.Client.Connection.

◆ Publish() [1/9]

void NATS.Client.IConnection.Publish ( Msg msg )

Publishes a Msg instance, which includes the subject, an optional reply, and an optional data field.

Parameters

msg	A Msg instance containing the subject, optional reply, and data to publish to the NATS server.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Publish() [2/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		byte[]	data
	)

Publishes data to the given subject .

NATS implements a publish-subscribe message distribution model. NATS publish subscribe is a one-to-many communication. A publisher sends a message on a subject. Any active subscriber listening on that subject receives the message. Subscribers can register interest in wildcard subjects.

In the basic NATS platform, if a subscriber is not listening on the subject (no subject match), or is not active when the message is sent, the message is not received. NATS is a fire-and-forget messaging system. If you need higher levels of service, you can either use NATS Streaming, or build the additional reliability into your client(s) yourself.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the data to publish to the connected NATS server.

Exceptions

NATSReconnectBufferException is thrown when publishing while reconnecting and the internal reconnect buffer has been disabled or exceeded.

See also: Options.ReconnectBufferSize

Implemented in NATS.Client.Connection.

◆ Publish() [3/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		byte[]	data,
		int	offset,
		int	count
	)

Publishes a sequence of bytes from data to the given subject .

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Publish() [4/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		MsgHeader	headers,
		byte[]	data
	)

Publishes data to the given subject .

NATS implements a publish-subscribe message distribution model. NATS publish subscribe is a one-to-many communication. A publisher sends a message on a subject. Any active subscriber listening on that subject receives the message. Subscribers can register interest in wildcard subjects.

In the basic NATS platform, if a subscriber is not listening on the subject (no subject match), or is not active when the message is sent, the message is not received. NATS is a fire-and-forget messaging system. If you need higher levels of service, you can either use NATS Streaming, or build the additional reliability into your client(s) yourself.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the data to publish to the connected NATS server.

Exceptions

NATSReconnectBufferException is thrown when publishing while reconnecting and the internal reconnect buffer has been disabled or exceeded.

See also: Options.ReconnectBufferSize

Implemented in NATS.Client.Connection.

◆ Publish() [5/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count
	)

Publishes a sequence of bytes from data to the given subject .

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Publish() [6/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		string	reply,
		byte[]	data
	)

Publishes data to the given subject .

Parameters

subject	The subject to publish data to over the current connection.
reply	An optional reply subject.
data	An array of type Byte that contains the data to publish to the connected NATS server.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Publish() [7/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		string	reply,
		byte[]	data,
		int	offset,
		int	count
	)

Publishes a sequence of bytes from data to the given subject .

Parameters

subject	The subject to publish data to over the current connection.
reply	An optional reply subject.
data	An array of type Byte that contains the data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Publish() [8/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		string	reply,
		MsgHeader	headers,
		byte[]	data
	)

Publishes data to the given subject .

Parameters

subject	The subject to publish data to over the current connection.
reply	An optional reply subject.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the data to publish to the connected NATS server.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Publish() [9/9]

void NATS.Client.IConnection.Publish	(	string	subject,
		string	reply,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count
	)

Publishes a sequence of bytes from data to the given subject .

Parameters

subject	The subject to publish data to over the current connection.
reply	An optional reply subject.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

See also: IConnection.Publish(string, byte[])

Implemented in NATS.Client.Connection.

◆ Request() [1/10]

Msg NATS.Client.IConnection.Request ( Msg message )

Sends a request message and returns the response Msg.

NATS supports two flavors of request-reply messaging: point-to-point or one-to-many. Point-to-point involves the fastest or first to respond. In a one-to-many exchange, you set a limit on the number of responses the requestor may receive and instead must use a subscription (ISubscription.AutoUnsubscribe(int)). In a request-response exchange, publish request operation publishes a message with a reply subject expecting a response on that reply subject.

Request(Msg) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

=

Parameters

message A Msg that contains the request data to publish to the connected NATS server. Any reply subject will be overridden.

Returns: A Msg with the response from the NATS server.

Implemented in NATS.Client.Connection.

◆ Request() [2/10]

Msg NATS.Client.IConnection.Request	(	Msg	message,
		int	timeout
	)

Sends a request message and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

Request(Msg, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

message	A NATS Msg that contains the request data to publish to the connected NATS server. The reply subject will be overridden.
timeout	The number of milliseconds to wait.

Returns: A Msg with the response from the NATS server.

See also: IConnection.Request(Msg)

Implemented in NATS.Client.Connection.

◆ Request() [3/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		byte[]	data
	)

Sends a request payload and returns the response Msg.

NATS supports two flavors of request-reply messaging: point-to-point or one-to-many. Point-to-point involves the fastest or first to respond. In a one-to-many exchange, you set a limit on the number of responses the requestor may receive and instead must use a subscription (ISubscription.AutoUnsubscribe(int)). In a request-response exchange, publish request operation publishes a message with a reply subject expecting a response on that reply subject.

Request(string, byte[]) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.

Returns: A Msg with the response from the NATS server.

Implemented in NATS.Client.Connection.

◆ Request() [4/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		byte[]	data,
		int	offset,
		int	count
	)

Sends a sequence of bytes as the request payload and returns the response Msg.

NATS supports two flavors of request-reply messaging: point-to-point or one-to-many. Point-to-point involves the fastest or first to respond. In a one-to-many exchange, you set a limit on the number of responses the requestor may receive and instead must use a subscription (ISubscription.AutoUnsubscribe(int)). In a request-response exchange, publish request operation publishes a message with a reply subject expecting a response on that reply subject.

Request(string, byte[], int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

Returns: A Msg with the response from the NATS server.

Implemented in NATS.Client.Connection.

◆ Request() [5/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		byte[]	data,
		int	offset,
		int	count,
		int	timeout
	)

Sends a sequence of bytes as the request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

Request(string, byte[], int, int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.
timeout	The number of milliseconds to wait.

Returns: A Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ Request() [6/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		byte[]	data,
		int	timeout
	)

Sends a request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

Request(string, byte[]) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
timeout	The number of milliseconds to wait.

Returns: A Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ Request() [7/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		MsgHeader	headers,
		byte[]	data
	)

Sends a request payload and returns the response Msg.

NATS supports two flavors of request-reply messaging: point-to-point or one-to-many. Point-to-point involves the fastest or first to respond. In a one-to-many exchange, you set a limit on the number of responses the requestor may receive and instead must use a subscription (ISubscription.AutoUnsubscribe(int)). In a request-response exchange, publish request operation publishes a message with a reply subject expecting a response on that reply subject.

Request(string, byte[]) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.

Returns: A Msg with the response from the NATS server.

Implemented in NATS.Client.Connection.

◆ Request() [8/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count
	)

Sends a sequence of bytes as the request payload and returns the response Msg.

NATS supports two flavors of request-reply messaging: point-to-point or one-to-many. Point-to-point involves the fastest or first to respond. In a one-to-many exchange, you set a limit on the number of responses the requestor may receive and instead must use a subscription (ISubscription.AutoUnsubscribe(int)). In a request-response exchange, publish request operation publishes a message with a reply subject expecting a response on that reply subject.

Request(string, byte[], int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

Returns: A Msg with the response from the NATS server.

Implemented in NATS.Client.Connection.

◆ Request() [9/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count,
		int	timeout
	)

Sends a sequence of bytes as the request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

Request(string, byte[], int, int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.
timeout	The number of milliseconds to wait.

Returns: A Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ Request() [10/10]

Msg NATS.Client.IConnection.Request	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	timeout
	)

Sends a request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

Request(string, byte[]) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
timeout	The number of milliseconds to wait.

Returns: A Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [1/18]

Task< Msg > NATS.Client.IConnection.RequestAsync ( Msg message )

Asynchronously sends a request message and returns the response Msg.

RequestAsync(Msg) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

message A NATS Msg that contains the request data to publish to the connected NATS server. The reply subject will be overridden.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(Msg)

Implemented in NATS.Client.Connection.

◆ RequestAsync() [2/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	Msg	message,
		CancellationToken	token
	)

Asynchronously sends a request message and returns the response Msg, while monitoring for cancellation requests.

RequestAsync(Msg, CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

message	A NATS Msg that contains the request data to publish to the connected NATS server. The reply subject will be overridden.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(Msg)

Implemented in NATS.Client.Connection.

◆ RequestAsync() [3/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	Msg	message,
		int	timeout
	)

Asynchronously sends a request message and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

RequestAsync(Msg, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

message	A NATS message Msg that contains the request data to publish to the connected NATS server. The reply subject will be overridden.
timeout	The number of milliseconds to wait.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(Msg, int)

Implemented in NATS.Client.Connection.

◆ RequestAsync() [4/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	Msg	message,
		int	timeout,
		CancellationToken	token
	)

Asynchronously sends a request message and returns the response Msg, or throws NATSTimeoutException if the timeout expires, while monitoring for cancellation requests.

RequestAsync(Msg, int, CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

message	A NATS Msg that contains the request data to publish to the connected NATS server. The reply subject will be overridden.
timeout	The number of milliseconds to wait.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(Msg, int)

Implemented in NATS.Client.Connection.

◆ RequestAsync() [5/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data
	)

Asynchronously sends a request payload and returns the response Msg.

RequestAsync(string, byte[]) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [6/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data,
		CancellationToken	token
	)

Asynchronously sends a request payload and returns the response Msg, while monitoring for cancellation requests.

RequestAsync(string, byte[], CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [7/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data,
		int	offset,
		int	count
	)

Asynchronously sends a sequence of bytes as the request payload and returns the response Msg.

RequestAsync(string, byte[], int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [8/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data,
		int	offset,
		int	count,
		CancellationToken	token
	)

Asynchronously sends a sequence of bytes as the request payload and returns the response Msg, while monitoring for cancellation requests.

RequestAsync(string, byte[], int, int, CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [9/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data,
		int	offset,
		int	count,
		int	timeout
	)

Asynchronously sends a sequence of bytes as the request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

RequestAsync(string, byte[], int, int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.
timeout	The number of milliseconds to wait.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [10/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data,
		int	timeout
	)

Asynchronously sends a request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

RequestAsync(string, byte[], int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
timeout	The number of milliseconds to wait.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [11/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		byte[]	data,
		int	timeout,
		CancellationToken	token
	)

Asynchronously sends a request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires, while monitoring for cancellation requests.

RequestAsync(string, byte[], int, CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
timeout	The number of milliseconds to wait.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [12/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data
	)

Asynchronously sends a request payload and returns the response Msg.

RequestAsync(string, byte[]) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [13/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		CancellationToken	token
	)

Asynchronously sends a request payload and returns the response Msg, while monitoring for cancellation requests.

RequestAsync(string, byte[], CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [14/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count
	)

Asynchronously sends a sequence of bytes as the request payload and returns the response Msg.

RequestAsync(string, byte[], int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [15/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count,
		CancellationToken	token
	)

Asynchronously sends a sequence of bytes as the request payload and returns the response Msg, while monitoring for cancellation requests.

RequestAsync(string, byte[], int, int, CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [16/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	offset,
		int	count,
		int	timeout
	)

Asynchronously sends a sequence of bytes as the request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

RequestAsync(string, byte[], int, int, int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
offset	The zero-based byte offset in data at which to begin publishing bytes to the subject.
count	The number of bytes to be published to the subject.
timeout	The number of milliseconds to wait.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [17/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	timeout
	)

Asynchronously sends a request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires.

RequestAsync(string, byte[], int) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
timeout	The number of milliseconds to wait.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ RequestAsync() [18/18]

Task< Msg > NATS.Client.IConnection.RequestAsync	(	string	subject,
		MsgHeader	headers,
		byte[]	data,
		int	timeout,
		CancellationToken	token
	)

Asynchronously sends a request payload and returns the response Msg, or throws NATSTimeoutException if the timeout expires, while monitoring for cancellation requests.

RequestAsync(string, byte[], int, CancellationToken) will create an unique inbox for this request, sharing a single subscription for all replies to this Connection instance. However, if Options.UseOldRequestStyle is set, each request will have its own underlying subscription. The old behavior is not recommended as it may cause unnecessary overhead on connected NATS servers.

Parameters

subject	The subject to publish data to over the current connection.
headers	Optional headers to publish with the message.
data	An array of type Byte that contains the request data to publish to the connected NATS server.
timeout	The number of milliseconds to wait.
token	The token to monitor for cancellation requests.

Returns: A task that represents the asynchronous read operation. The value of the Task<TResult>.Result parameter contains a Msg with the response from the NATS server.

See also: IConnection.Request(string, byte[])

Implemented in NATS.Client.Connection.

◆ ResetStats()

void NATS.Client.IConnection.ResetStats ( )

Resets the associated statistics for the IConnection.

See also: Stats

Implemented in NATS.Client.Connection.

◆ RTT()

TimeSpan NATS.Client.IConnection.RTT ( )

Calculates the round trip time between this client and the server.

Returns: A timespan representing the elapsed time.

Implemented in NATS.Client.Connection.

◆ SubscribeAsync() [1/4]

IAsyncSubscription NATS.Client.IConnection.SubscribeAsync ( string subject )

Expresses interest in the given subject to the NATS Server.

The IAsyncSubscription returned will not start receiving messages until IAsyncSubscription.Start is called.

Parameters

subject The subject on which to listen for messages. The subject can have wildcards (partial: *, full: >).

Returns: An IAsyncSubscription to use to read any messages received from the NATS Server on the given subject .

See also: ISubscription.Subject

Implemented in NATS.Client.Connection.

◆ SubscribeAsync() [2/4]

IAsyncSubscription NATS.Client.IConnection.SubscribeAsync	(	string	subject,
		EventHandler< MsgHandlerEventArgs >	handler
	)

Expresses interest in the given subject to the NATS Server, and begins delivering messages to the given event handler.

The IAsyncSubscription returned will start delivering messages to the event handler as soon as they are received. The caller does not have to invoke IAsyncSubscription.Start.

Parameters

subject	The subject on which to listen for messages. The subject can have wildcards (partial: `*`, full: `>`).
handler	The EventHandler<TEventArgs> invoked when messages are received on the returned IAsyncSubscription.

Returns: An IAsyncSubscription to use to read any messages received from the NATS Server on the given subject .

See also: ISubscription.Subject

Implemented in NATS.Client.Connection.

◆ SubscribeAsync() [3/4]

IAsyncSubscription NATS.Client.IConnection.SubscribeAsync	(	string	subject,
		string	queue
	)

Creates an asynchronous queue subscriber on the given subject .

All subscribers with the same queue name will form the queue group and only one member of the group will be selected to receive any given message.

The IAsyncSubscription returned will not start receiving messages until IAsyncSubscription.Start is called.

Parameters

subject	The subject on which to listen for messages. The subject can have wildcards (partial: `*`, full: `>`).
queue	The name of the queue group in which to participate.

Returns: An IAsyncSubscription to use to read any messages received from the NATS Server on the given subject .

See also: ISubscription.Subject, ISubscription.Queue

Implemented in NATS.Client.Connection.

◆ SubscribeAsync() [4/4]

IAsyncSubscription NATS.Client.IConnection.SubscribeAsync	(	string	subject,
		string	queue,
		EventHandler< MsgHandlerEventArgs >	handler
	)

Creates an asynchronous queue subscriber on the given subject , and begins delivering messages to the given event handler.

All subscribers with the same queue name will form the queue group and only one member of the group will be selected to receive any given message.

The IAsyncSubscription returned will start delivering messages to the event handler as soon as they are received. The caller does not have to invoke IAsyncSubscription.Start.

Parameters

subject	The subject on which to listen for messages. The subject can have wildcards (partial: `*`, full: `>`).
queue	The name of the queue group in which to participate.
handler	The EventHandler<MsgHandlerEventArgs> invoked when messages are received on the returned IAsyncSubscription.

Returns: An IAsyncSubscription to use to read any messages received from the NATS Server on the given subject .

See also: ISubscription.Subject, ISubscription.Queue

Implemented in NATS.Client.Connection.

◆ SubscribeSync() [1/2]

ISyncSubscription NATS.Client.IConnection.SubscribeSync ( string subject )

Expresses interest in the given subject to the NATS Server.

Parameters

subject The subject on which to listen for messages. The subject can have wildcards (partial: *, full: >).

Returns: An ISyncSubscription to use to read any messages received from the NATS Server on the given subject .

See also: ISubscription.Subject

Implemented in NATS.Client.Connection.

◆ SubscribeSync() [2/2]

ISyncSubscription NATS.Client.IConnection.SubscribeSync	(	string	subject,
		string	queue
	)

Creates a synchronous queue subscriber on the given subject .

All subscribers with the same queue name will form the queue group and only one member of the group will be selected to receive any given message synchronously.

Parameters

subject	The subject on which to listen for messages.
queue	The name of the queue group in which to participate.

Returns: An ISyncSubscription to use to read any messages received from the NATS Server on the given subject , as part of the given queue group.

See also: ISubscription.Subject, ISubscription.Queue

Implemented in NATS.Client.Connection.

Property Documentation

◆ ClientID

int NATS.Client.IConnection.ClientID

get

Gets the ID of client as known by the NATS server, otherwise null.

May not be supported in all versions of the server. If the client is connected to an older server or is in the process of connecting, 0 will be returned.

Implemented in NATS.Client.Connection.

◆ ClientIP

IPAddress NATS.Client.IConnection.ClientIP

get

Gets the IP of client as known by the NATS server, otherwise null.

Supported in the NATS server version 2.1.6 and above. If the client is connected to an older server or is in the process of connecting, null will be returned.

Implemented in NATS.Client.Connection.

◆ DiscoveredServers

string [] NATS.Client.IConnection.DiscoveredServers

get

Gets an array of server URLs that were discovered after this instance connected.

If authentication is enabled, Options.User or Options.Token must be used when connecting with these URLs.

Implemented in NATS.Client.Connection.

◆ MaxPayload

long NATS.Client.IConnection.MaxPayload

get

Gets the maximum size in bytes of any payload sent to the connected NATS Server.

See also: Publish(Msg), Publish(string, byte[]), Publish(string, string, byte[]), Request(string, byte[]), Request(string, byte[], int), RequestAsync(string, byte[]), RequestAsync(string, byte[], CancellationToken), RequestAsync(string, byte[], int), RequestAsync(string, byte[], int, CancellationToken)

Implemented in NATS.Client.Connection.

◆ Servers

string [] NATS.Client.IConnection.Servers

get

Gets an array of known server URLs for this instance.

Servers also includes any additional servers discovered after a connection has been established. If authentication is enabled, Options.User or Options.Token must be used when connecting with these URLs.

Implemented in NATS.Client.Connection.

◆ State

ConnState NATS.Client.IConnection.State

get

Gets the current state of the IConnection.

See also: ConnState

Implemented in NATS.Client.Connection.

◆ Stats

IStatistics NATS.Client.IConnection.Stats

get

Gets the statistics tracked for the IConnection.

See also: ResetStats

Implemented in NATS.Client.Connection.

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

IConnection.cs

Public Member Functions

Properties

Detailed Description

Member Function Documentation

◆ Close()

◆ CreateJetStreamContext()

◆ CreateJetStreamManagementContext()

◆ CreateKeyValueContext()

◆ CreateKeyValueManagementContext()

◆ CreateObjectStoreContext()

◆ CreateObjectStoreManagementContext()

◆ Drain() [1/2]

◆ Drain() [2/2]

◆ DrainAsync() [1/2]

◆ DrainAsync() [2/2]

◆ Flush()

◆ FlushBuffer()

◆ GetConsumerContext() [1/2]

◆ GetConsumerContext() [2/2]

◆ GetStreamContext() [1/2]

◆ GetStreamContext() [2/2]

◆ IsClosed()

◆ IsDraining()

◆ IsReconnecting()

◆ NewInbox()

◆ Publish() [1/9]

◆ Publish() [2/9]

◆ Publish() [3/9]

◆ Publish() [4/9]

◆ Publish() [5/9]

◆ Publish() [6/9]

◆ Publish() [7/9]

◆ Publish() [8/9]

◆ Publish() [9/9]

◆ Request() [1/10]

◆ Request() [2/10]

◆ Request() [3/10]

◆ Request() [4/10]

◆ Request() [5/10]

◆ Request() [6/10]

◆ Request() [7/10]

◆ Request() [8/10]

◆ Request() [9/10]

◆ Request() [10/10]

◆ RequestAsync() [1/18]

◆ RequestAsync() [2/18]

◆ RequestAsync() [3/18]

◆ RequestAsync() [4/18]

◆ RequestAsync() [5/18]

◆ RequestAsync() [6/18]

◆ RequestAsync() [7/18]

◆ RequestAsync() [8/18]

◆ RequestAsync() [9/18]

◆ RequestAsync() [10/18]

◆ RequestAsync() [11/18]

◆ RequestAsync() [12/18]

◆ RequestAsync() [13/18]

◆ RequestAsync() [14/18]

◆ RequestAsync() [15/18]

◆ RequestAsync() [16/18]

◆ RequestAsync() [17/18]

◆ RequestAsync() [18/18]

◆ ResetStats()

◆ RTT()

◆ SubscribeAsync() [1/4]

◆ SubscribeAsync() [2/4]

◆ SubscribeAsync() [3/4]

◆ SubscribeAsync() [4/4]

◆ SubscribeSync() [1/2]

◆ SubscribeSync() [2/2]

Property Documentation

◆ ClientID

◆ ClientIP

◆ DiscoveredServers

◆ MaxPayload

◆ Servers

◆ State

◆ Stats