Имейте в виду, что он все еще может проходить через сеть, поскольку архитектура MQ может иметь много промежуточных очередей. Точно так же не требуется, чтобы сообщение немедленно передавалось по каналу - отправитель может пакетировать сообщения и отправлять их с помощью триггера.
Лучший способ убедиться, что вы регистрируете все, что приходит, это сделать с помощью очереди перехватчиков.
Это очередь (назовем ее A), в которую записывает канал, и до этого изменения ваше приложение считывает. Затем у вас есть процесс передачи чтения из A, регистрирует сообщение и записывает его во вторую очередь (B). Эта вторая очередь - то, из чего ваше приложение теперь читает.