Я хочу построить архитектуру, управляемую событиями.
DomainEvent производится с заголовком.
Каждый сервис заинтересован только в каком-то DomainEvent.
Поэтому я использовал условие на потребителя:
@StreamListener(target = Sink.INPUT, condition = "headers['type'] == 'FooDomainEvent'")
public void onFooEvent(FooDomainEvent event) {
И это работает для событий с этим заголовком.
Но когда создается другой заголовок сообщения, я получаю это предупреждение в журнале
.DispatchingStreamListenerMessageHandler : Cannot find a @StreamListener matching for message with id: null
Как просто игнорировать других, не интересующихся событиями?
Спасибо