Hi Matthias, I was actually looking for ASIO support in ZeroMQ. Thank you. But does your library provide what you say? I mean does it really use ZeroMQ on edges and use ASIO on a binary component level for distributed systems? I am looking for something like that and doing this myself would be the last option due to time constraints. Many thanks in advance if you continue to work on this :) -Asif On Wed, Feb 8, 2012 at 5:15 AM, Matthias Vallentin < vallentin@icsi.berkeley.edu> wrote:

A while ago, Maciej Gajewski started an effort to use Asio to observe a ZeroMQ socket [1]. Based on his code, I put together a thin library that wraps the implementation details. Since other have requested a working example, here it is now at github:

https://github.com/mavam/bmq

Any feedback is highly appreciated. A basic usage example looks like this:

#include #include

int main() { boost::asio::io_service io; bmq::context ctx(1); bmq::component c(ctx, io);

auto sink = c.add_sink(ZMQ_PAIR, "inproc://x"); c.subscribe(sink, [](bmq::message&& msg) { std::string str(static_cast(msg.data()), msg.size()); std::cout << str << std::endl; });

auto source = c.add_source(ZMQ_PAIR, "inproc://x");

bmq::message msg(const_cast("foo"), 3, nullptr); source->send(msg);

// Execute message handler. io.poll();

return 0; }

At this point, the library is really thin and only provides very rudimentary wrapping of ZeroMQ. In the future, I plan to extend it in order to facilitate applications that build on message-passing. The dataflow abstraction I envision is essentially a directed graph, where nodes represent components and edges communication links. 0mq provides the edges and the Asio handles asynchronous event processing at the component level. The motiviation is that this model lends itself well for scaling out distributed systems over large clusters.

Matthias

[1] http://permalink.gmane.org/gmane.network.zeromq.devel/9538 _______________________________________________ Boost-users mailing list Boost-users@lists.boost.org http://lists.boost.org/mailman/listinfo.cgi/boost-users