NAME
AnyMQ::ZeroMQ - AnyMQ adaptor for ZeroMQ
VERSION
Version 0.01
SYNOPSIS
# create a subscriber
my $sub_bus = AnyMQ->new_with_traits(
traits => [ 'ZeroMQ' ],
subscribe_address => 'tcp://localhost:4001',
);
# subscribe to topic
my $sub_topic = $sub_bus->topic('ping');
my $listener = $sub_bus->new_listener($sub_topic);
$listener->poll(sub { "got ping event!" });
# create a publisher
my $pub_bus = AnyMQ->new_with_traits(
traits => ['ZeroMQ'],
publish_address => 'tcp://localhost:4000', # accepts any address that ZeroMQ supports
);
my $pub_topic = $pub_bus->topic('ping');
$pub_topic->publish({ foo => 'bar' });
AUTHOR
Mischa Spiegelmock, <revmischa at cpan.org>
BUGS
Please use the GitHub issue tracker
SEE ALSO
ACKNOWLEDGEMENTS
LICENSE AND COPYRIGHT
Copyright 2011 Mischa Spiegelmock.
This program is free software; you can redistribute it and/or modify it under the terms of either: the GNU General Public License as published by the Free Software Foundation; or the Artistic License.
See http://dev.perl.org/licenses/ for more information.