Click or drag to resize

SyncSubscriptionTMessage Class

Implements an ISyncSubscription for typed messages.
Inheritance Hierarchy
SystemObject
  NATS.ClientSyncSubscriptionTMessage

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

Type Parameters

TMessage
The message type.

The SyncSubscriptionTMessage type exposes the following members.

Properties
  NameDescription
Public propertyConnection
Gets the Connection associated with this instance.
Public propertyDelivered
Gets the number of delivered messages for this instance.
Public propertyDropped
Gets the number of known dropped messages for this instance.
Public propertyIsValid
Gets a value indicating whether or not the ISubscription is still valid.
Public propertyMaxPendingBytes
Gets the maximum number of pending bytes seen so far by this instance.
Public propertyMaxPendingMessages
Gets the maximum number of messages seen so far by this instance.
Public propertyPendingByteLimit
Gets or sets the maximum allowed count of pending bytes.
Public propertyPendingBytes
Gets the number of bytes not yet processed on this instance.
Public propertyPendingMessageLimit
Gets or sets the maximum allowed count of pending messages.
Public propertyPendingMessages
Gets the number of messages not yet processed on this instance.
Public propertyQueue
Gets the optional queue group name.
Public propertyQueuedMessageCount
Gets the number of messages remaining in the delivery queue.
Public propertySubject
Gets the subject for this subscription.
Top
Methods
  NameDescription
Public methodAutoUnsubscribe
Issues an automatic call to Unsubscribe when max messages have been received.
Public methodClearMaxPending
Clears the maximum pending bytes and messages statistics.
Public methodDispose
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Public methodDrain
Drains a subscription for gracefully unsubscribing.
Public methodDrain(Int32)
Drains a subscription for gracefully unsubscribing.
Public methodDrainAsync
Drains a subscription for gracefully unsubscribing.
Public methodDrainAsync(Int32)
Drains a subscription for gracefully unsubscribing.
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetMaxPending
Returns the maximum number of pending bytes and messages during the life of the Subscription.
Public methodGetPending
Returns the pending byte and message counts.
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Public methodNextMessage
Public methodNextMessage(Int32)
Returns the next MsgTMessage available to a synchronous subscriber, or block up to a given timeout until the next one is available.
Public methodSetPendingLimits
Sets the limits for pending messages and bytes for this instance.
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Public methodUnsubscribe
Removes interest in the Subject.
Top
See Also