Click or drag to resize

ISyncSubscriptionTMessage Interface

Implements an ISyncSubscription for typed messages.

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

Type Parameters

TMessage
The message type.

The ISyncSubscriptionTMessage 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 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.
(Inherited from ISubscription.)
Public methodUnsubscribe
Removes interest in the Subject.
(Inherited from ISubscription.)
Top
See Also