Локальная шина сообщений

Недавно мне стало интересно, как я могу улучшить архитектуру прослушивателя TestNG.

TestNG предоставляет множество различных прослушивателей, которые пользователи могут указать перед началом пробного запуска (с использованием командной строки, ant, Maven, testng.xml или программно).

Эти слушатели говорят вам, когда:

• Тест пройден успешно, не пройден или пропущен.
• Тестовый метод должен быть вызван и когда он вернется.
• Конфигурационный метод начинается или заканчивается (существует пять типов каждого: набор, тест, класс, метод и группа, и у вас есть события до и после для каждого).
• Репортер должен быть уведомлен об обновлении его результатов (либо в конце запуска комплекта, либо после каждого метода тестирования).

Все эти слушатели улавливаются с помощью различных интерфейсов , и они развивались несколько органически за эти последние шесть лет , как потребность и запросы появились, показывая некоторое перекрытие в функциональности , а также требует эволюции неудобного интерфейса, Java навязывает ( Приложение A и экспонат B ).

Одним из возможных решений такой проблемы является шина сообщений (или событий).

Шины сообщений существовали очень давно, и большинство моих кандидатских диссертаций были посвящены их использованию и влиянию на распределенные приложения. Я даже написал один для моего доктора под названием Коала Talk . Это было около 1993 года, почти двадцать лет назад.

Де — факто стандартом в мире Java является спецификация JMS, которая была реализована во многих продуктах , таких как ActiveMQ или RabbitMQ. Как спецификация, так и реализации прошли боевые испытания и доказали свою полезность для современного программного обеспечения.

public class App {

  @Subscriber
  public void event1(NotifyEvent ne) {
    System.out.println("event1: " + ne);
  }

}

MessageBus mb = new MessageBus();
mb.register(new App());
mb.post(new NotifyEvent("notify"));