Шаблон конвейера ZeroMQ

Я реализую систему обмена сообщениями, в которой внешние программы, называемые агентами могут общаться через производителей ZeroMq. Итак, каждый раз, когда происходит интересующее событие, агент отправляет сообщение в ZeroMq.

Мне интересно реализовать это, используя паттерн конвейера.

Я нашел несколько примеров (Ventilator-Worker-Results Manager), но компонент Ventilator создает конечную точку для приема подключений от исполнителя, а затем отправляет все сообщения в пакетном режиме.

Мой сценарий совсем другой. «Агент» подключается каждый раз, когда необходимо отправить событие - он не ждет подключений от рабочих, поэтому мне интересно, возможно ли это? Также немаловажным фактом является то, что сообщения нужно обрабатывать, чтобы они были отправлены.