gistfile1.perl

my $bus = AnyMQ->new;
builder {
    enable "Static", path => sub { s!^/static/!! }, root => 'static';
    enable "Hippie", root => '/_hippie',
        init => sub {
            my $room = shift;
            my $h = shift;
            my $sub = $bus->new_listener($h->id);
            $sub->subscribe($bus->topic($room));
            $sub->poll(sub { $h->send_msg($_[0]) });
        },
        on_error => sub {
            my $room = shift;
            # $sub->destroyed(1)
        },
        on_message => sub {
            my $room = shift;
            my $msg = shift;
#            $msg->{address} = $req->address;
            $msg->{time} = time;
            $bus->topic($room)->publish($msg);
        }
        ;
    $app;
};