Skip to content
Orleans logoMicrosoft Orleans

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.