zmq_proxy / ZMQ::Poll in Actor

[alhafoudh]

Hi,
how to properly start and handle zmq_proxy or at least ZMQ::Poll?

For example for ROUTER and DEALER socket pair.

[Asmod4n]

Its rather straightforward how to do DEALER and ROUTER stuff, made a small gist for it https://gist.github.com/Asmod4n/9372750 /cc @tarcieri

[alhafoudh]

Thanks for the example, but I cannot see the proxying of the messages from ROUTER to DEALER and back in the example.

[Asmod4n]

The server(dealer) sends messages to the handler(router), the handler then sends information back and the server reads them.

[alhafoudh]

I am not quite sure to which ZMQ pattern are you referring to, but I refer to this pattern:

http://zguide.zeromq.org/page:all#Shared-Queue-DEALER-and-ROUTER-sockets
https://github.com/imatix/zguide/raw/master/images/fig16.png

ROUTER and DEALER are on same node and passing messages internally e.g. proxying

I apologize if this was not clear from the issue description.

[Asmod4n]

The polling is done in the Reactor: https://github.com/celluloid/celluloid-zmq/blob/master/lib/celluloid/zmq/reactor.rb#L13 or do you mean https://github.com/chuckremes/ffi-rzmq/blob/master/lib/ffi-rzmq/device.rb ? @alhafoudh

[alhafoudh]

As I understand the polling in Reactor is to do the the actor signaling efficient, but I need to make another Poller inside an Actor with two sockets. The DealerSocker and RouterSocket.
Yes, the Device in ffi-rzmq is exactly what I need, but the celluloid-zmq does not play well with it :(

[Asmod4n]

I believe you have to run it in its own actor.

At least the specs here do it that way https://github.com/chuckremes/ffi-rzmq/blob/master/spec/device_spec.rb#L30 ^^

[alhafoudh]

Yes, but when zmq_proxy is called the program control is never returned and this is a problem for celluloid actors

[Asmod4n]

@alhafoudh https://github.com/zeromq/czmq will sonnish(i hope) release a 3.0 version of its high level C binding which does this in the background.
I have written a ruby ffi wrapper for it which i will release once they release czmq 3, that wrapper will then maybe become the new basis for celluloid-zmq.