Yet Another CPAN Grep

Message-Passing-Output-PocketIO ( C/CH/CHENRYN/Message-Passing-Output-PocketIO-0.01.tar.gz, CHENRYN, 2012; MetaCPAN )

Message-Passing-Output-PocketIO/lib/Message/Passing/Output/PocketIO.pm ( view source; MetaCPAN )

se qw/ Str ArrayRef /;
use Scalar::Util qw/ weaken /;
use namespace::clean -except => 'meta';
use JSON;
use AnyMQ;
use AnyEvent;
use PocketIO;
use Twiggy::Server;
use Plack::Builder;
use Data::Section

age' => sub {
                        my $class = shift;
                        $class->send( to_json($self->_messages) );
                        $self->_clear_messages;
                    }

   $server->register_service($app);
}

sub consume {
    my ( $self, $msg ) = @_;
    $msg = from_json($msg) unless ref($msg);
    $self->anymq->publish({ msg => $msg });
}


# Preloaded methods go he