The socket can be connected to multiple addresses by passing an array as the first argument.
Users can configure topology (pushpull or pubsub), HWM, LINGER, and pubsub topic as options in initialize.
Topic can be a proc in which case it is called for every message with the event as argument.
The output uses a per-instance at_exit hook to ensure sockets are closed. I don't know the gotchas for at_exit hooks, but probably best to avoid creating a lot of these until Cabin has graceful teardown support.
This branch adds a zeromq output for Cabin.
The socket can be connected to multiple addresses by passing an array as the first argument.
Users can configure topology (pushpull or pubsub), HWM, LINGER, and pubsub topic as options in initialize.
Topic can be a proc in which case it is called for every message with the event as argument.
The output uses a per-instance at_exit hook to ensure sockets are closed. I don't know the gotchas for at_exit hooks, but probably best to avoid creating a lot of these until Cabin has graceful teardown support.