IPC::AnyEvent::Gearman - IPC through gearmand.
version 0.3
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");
'pid' is unique id for identifying each process. This can be any value not just PID. It is filled own PID by default.
ArrayRef of hosts.
When register function, it uses prefix+pid as function name. It is filled 'IPC::AnyEvent::Gearman#' by default.
on_receive Hander. First argument is DATA which is sent. This can be invoked after listen().
on_send handler. First argument is a channel string.
on_sendfail handler. First argument is a channel string.
To receive message, you MUST call listen().
get prefix+pid
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);
KHS, HyeonSeung Kim <sng2nara@hanmail.net>
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.
