NAME

ZeroMQ::PubSub::Server - Listen for published events and broadcast them to all connected subscribers

SYNOPSIS

use ZeroMQ::PubSub::Server;
my $server = ZeroMQ::PubSub::Server->new(
    # clients connect here to publish events
    publish_addrs => [ 'tcp://0.0.0.0:4000', 'ipc:///tmp/pub.sock' ],

    # clients connect here to subscribe to events
    subscribe_addrs => [ 'tcp://0.0.0.0:5000', 'ipc:///tmp/sub.sock' ],

    debug => 1,
);

# listen for events forever
{
    # listen for events being published to our server
    my $pub_sock = $self->bind_publish_socket;

    # set up to broadcast events to waiting subscribers
    my $sub_sock = $self->bind_subscribe_socket;

    # main processing loop
    while (1) {
        # block while we get one message
        my $msg = $server->recv;

        # deep clone $msg so that event handlers can't modify it
        my $orig = clone($msg);

        # run event handlers
        $self->dispatch_event($msg);

        # broadcast event to subscribers
        $server->broadcast($orig)
    }
}

# exact same as above
$server->run;

ATTRIBUTES

publish_addrs

ArrayRef of socket addresses to receive client event publishing requests

subscribe_addrs

ArrayRef of socket addresses that clients can connect to for receiving events

METHODS

bind_publish_socket

Bind publish socket to publish_addrs

bind_subscribe_socket

Listen for clients wishing to subscribe to published events

recv

Blocks and receives one event. Returns object parsed from JSON, or undef if failure.

broadcast($event)

Sends $event to all connected subscribers.

poll_once

Blocks and waits for a publish message, dispatches to event handlers, then broadcasts it to subscribers.

run

Runs pubsub server forever. See synopsis.

SEE ALSO

ZeroMQ::PubSub::Client, ZeroMQ::PubSub