Skip to content

DefaultQueueAdapterReceiverMonitor Methods

Queue adapter receiver monitor used as a default option in GeneratorStreamprovider and MemoryStreamProvider

TrackInitialization(bool, TimeSpan, Exception)

View source
public void TrackInitialization(bool success, TimeSpan callTime, Exception exception)
Track attempts to initialize the receiver.

Parameters

successbool
True if read succeeded, false if read failed.
callTimeTimeSpan
Init operation time.
exceptionException
Exception caught if initialize fail.

TrackMessagesReceived(long, DateTime?, DateTime?)

View source
public void TrackMessagesReceived(long count, DateTime? oldestMessageEnqueueTimeUtc, DateTime? newestMessageEnqueueTimeUtc)
Tracks messages read and time taken per successful read. Tracked per successful partition read operation.

Parameters

countlong
Messages read.
oldestMessageEnqueueTimeUtcDateTime?
The oldest message enqueue time (UTC).
newestMessageEnqueueTimeUtcDateTime?
The newest message enqueue time (UTC).

TrackRead(bool, TimeSpan, Exception)

View source
public void TrackRead(bool success, TimeSpan callTime, Exception exception)
Track attempts to read from the partition. Tracked per partition read operation.

Parameters

successbool
True if read succeeded, false if read failed.
callTimeTimeSpan
Time spent in read operation.
exceptionException
The exception caught if read failed.

TrackShutdown(bool, TimeSpan, Exception)

View source
public void TrackShutdown(bool success, TimeSpan callTime, Exception exception)
Track attempts to shutdown the receiver.

Parameters

successbool
True if read succeeded, false if read failed.
callTimeTimeSpan
Shutdown operation time.
exceptionException
Exception caught if shutdown fail.