/ 
IPC-AnyEvent-Gearman-0.8
River stage one • 1 direct dependent • 1 total dependent
/ IPC::AnyEvent::Gearman

NAME

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

VERSION

version 0.8

SYNOPSIS

use AnyEvent;
use IPC::AnyEvent::Gearman;

#receive    
my $recv = IPC::AnyEvent::Gearman->new(job_servers=>['localhost:9999']);
$recv->channel('BE_CALLED'); # channel is set with a random UUID by default 
$recv->on_recv(sub{
    my $msg = shift;
    print "received msg : $data\n";
    return "OK";#result
});
$recv->listen();

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

#send
my $ch = 'BE_CALLED';
my $send = IPC::AnyEvent::Gearman->new(server=>['localhost:9999']);
my $result = $send->send($ch,"TEST DATA");
pritn $result; # prints "OK"

ATTRIBUTES

job_servers

ArrayRef of hosts. *REQUIRED*

channel

get/set channel. When set, reconnect to new channel. It is set with Random-UUID by default.

on_recv

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

on_sent

on_sent handler. First argument is a channel string.

on_fail

on_fail handler. First argument is a channel string.

METHODS

listen

To receive message, you MUST call listen().

my $sender = IPC::AnyEvent::Gearman->new(channel=>'ADMIN',job_servers=>['localhost:9998']);
$sender->listen();

send

To send data to process listening channel, use this.

my $sender = IPC::AnyEvent::Gearman->new(job_servers=>['localhost:9998']);
$sender->send($channel,'DATA');

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.