/ 
AnyMQ-ZeroMQ-0.06
River stage zero No dependents
/ AnyMQ::ZeroMQ

NAME

AnyMQ::ZeroMQ - AnyMQ adaptor for ZeroMQ

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

AnyMQ, ZeroMQ::PubSub

ACKNOWLEDGEMENTS

AnyMQ, AnyEvent::ZeroMQ

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.