Click or drag to resize

IAsyncSubscriptionTMessage Interface

Implements an ISyncSubscription for typed messages.

Namespace:  NATS.Client
Assembly:  Neon.Nats (in Neon.Nats.dll) Version: 2.2.0
Syntax
public interface IAsyncSubscription<TMessage> : IAsyncSubscription, 
	ISubscription, IDisposable
where TMessage : class, new(), IRoundtripData

Type Parameters

TMessage
The message type.

The IAsyncSubscriptionTMessage type exposes the following members.

Properties
  NameDescription
Public propertyConnection
Gets the Connection associated with this instance.
(Inherited from ISubscription.)
Public propertyDelivered
Gets the number of delivered messages for this instance.
(Inherited from ISubscription.)
Public propertyDropped
Gets the number of known dropped messages for this instance.
(Inherited from ISubscription.)
Public propertyIsValid
Gets a value indicating whether or not the ISubscription is still valid.
(Inherited from ISubscription.)
Public propertyMaxPendingBytes
Gets the maximum number of pending bytes seen so far by this instance.
(Inherited from ISubscription.)
Public propertyMaxPendingMessages
Gets the maximum number of messages seen so far by this instance.
(Inherited from ISubscription.)
Public propertyPendingByteLimit
Gets or sets the maximum allowed count of pending bytes.
(Inherited from ISubscription.)
Public propertyPendingBytes
Gets the number of bytes not yet processed on this instance.
(Inherited from ISubscription.)
Public propertyPendingMessageLimit
Gets or sets the maximum allowed count of pending messages.
(Inherited from ISubscription.)
Public propertyPendingMessages
Gets the number of messages not yet processed on this instance.
(Inherited from ISubscription.)
Public propertyQueue
Gets the optional queue group name.
(Inherited from ISubscription.)
Public propertyQueuedMessageCount
Gets the number of messages remaining in the delivery queue.
(Inherited from ISubscription.)
Public propertySubject
Gets the subject for this subscription.
(Inherited from ISubscription.)
Top
Methods
  NameDescription
Public methodAutoUnsubscribe
Issues an automatic call to Unsubscribe when max messages have been received.
(Inherited from ISubscription.)
Public methodClearMaxPending
Clears the maximum pending bytes and messages statistics.
(Inherited from ISubscription.)
Public methodDispose
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
(Inherited from IDisposable.)
Public methodDrain
Drains a subscription for gracefully unsubscribing.
(Inherited from ISubscription.)
Public methodDrain(Int32)
Drains a subscription for gracefully unsubscribing.
(Inherited from ISubscription.)
Public methodDrainAsync
Drains a subscription for gracefully unsubscribing.
(Inherited from ISubscription.)
Public methodDrainAsync(Int32)
Drains a subscription for gracefully unsubscribing.
(Inherited from ISubscription.)
Public methodGetMaxPending
Returns the maximum number of pending bytes and messages during the life of the Subscription.
(Inherited from ISubscription.)
Public methodGetPending
Returns the pending byte and message counts.
(Inherited from ISubscription.)
Public methodSetPendingLimits
Sets the limits for pending messages and bytes for this instance.
(Inherited from ISubscription.)
Public methodStart
Starts delivering received messages to listeners on MessageHandler from a separate thread.
(Inherited from IAsyncSubscription.)
Public methodUnsubscribe
Removes interest in the Subject.
(Inherited from ISubscription.)
Top
Events
  NameDescription
Public eventMessageHandler
Occurs when the IAsyncSubscription receives a message from the underlying ISubscription.
(Inherited from IAsyncSubscription.)
Public eventRoundtripMessageHandler
Raised when a deserialized IRoundtripData message is received.
Top
See Also