readMessageCount method

  1. @override
Future<int> readMessageCount()

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;
}