NAME

IPC::AnyEvent::Gearman - IPC through gearmand.

VERSION

version 0.001

SYNOPSIS

    use AnyEvent;
    use IPC::AnyEvent::Gearman;
    
    #receive    
    my $recv = IPC::AnyEvent::Gearman->new(servers=>['localhost:9999']);
    $recv->on_receive(sub{
        my $msg = shift;
        print "received msg : $data\n";
        return "OK";#result
    });
    $recv->listen();

    my $cv = AE::cv;
    $cv->recv;

    #send
    my $send = IPC::AnyEvent::Gearman->new(server=>['localhost:9999']);
    $send->pid(1102);
    my $result = $send->send("TEST DATA");

FUNCTIONS

new

pid 'pid' is unique id for identifying each process. This can be any value not just PID. It is filled own PID by default.

servers ArrayRef of hosts.

prefix When register function, it uses prefix+pid as function name. It is filled 'IPC::AnyEvent::Gearman#' by default.

on_receive on_receive Hander. First argument is DATA which is sent. This can be invoked after listen().

on_send on_send handler. First argument is a channel string.

on_sendfail on_sendfail handler. First argument is a channel string.

listen To receive message, you MUST call listen().

channel get prefix+pid

send To send data to process listening prefix+pid, use this. You must set 'pid' or 'prefix' attribute on new() method.

    my $send = IPC::AnyEvent::Gearman->new(pid=>1223);

AUTHOR

KHS, HyeonSeung Kim <sng2nara@hanmail.net>

COPYRIGHT AND LICENSE

This software is copyright (c) 2012 by HyeonSeung Kim.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.