Я пытаюсь создать несколько фиктивных сообщений как часть POC для клиента, и клиент хочет знать эталон производительности нашего приложения.
что мы делаем / пытаемся достичь:
- создает огромные данные для темы activeMq, чтобы понять поведение в час пик.
- получить данные из темы, обработать их и сохранить в db.
во время этой операции я заметил, что количество отправленных записей равно 2925052 (напечатано в коде один раз после отправки в продюсер), а в конце потребителя - 1679098 (из числа java), но на консоли это примерно так, как показано ниже.я не понимаю, почему эти числа не совпадают.
Messages Dequeued
2597286 2564455
проблемы:
- производитель останавливается после указанного выше счета 2925052 (его запускиз цикла eclipse ... for)
- почему эти цифры не совпадают в консоли и коде.я использовал очередь activemq, и тот же код работает хорошо и подсчитывает совпадения в выходных данных консоли и программы.