readMessageCount method
ReadMessageCount method are reads the current number of messages in the _queue to be delivered. Returns Future that contains count number of messages Throws error.
Implementation
@override
Future<int> readMessageCount() async {
try {
_checkOpened('');
} catch (err) {
logger.error('', err as Exception,
'RabbitMQMessageQueue:MessageCount: ' + err.toString());
rethrow;
}
if (_queue == null) {
return 0;
}
return _queue!.messageCount;
}