NAME

POEIKC::Daemon::AndClient - POE IKC daemon and client

SYNOPSIS

        package MyServerAndClient;

        use strict;
        use warnings;

        use Data::Dumper;
        use Class::Inspector;
        use POE qw(
                Sugar::Args
                Loop::IO_Poll
        );

        use base qw(POEIKC::Daemon::AndClient);

        use POEIKC::Daemon::Utility;

        sub new {
            my $class = shift ;
            my $self = {
                @_
                };
            $class = ref $class if ref $class;
            bless  $self,$class ;
            return $self ;
        }

        sub spawn
        {
                my $class = shift;
                my $self  = $class->new();
                my $session = POE::Session->create(
                    object_states => [ $self => Class::Inspector->methods(__PACKAGE__) ]
                );
                return $session->ID;
        }

        sub _start {
                my $poe     = sweet_args ;
                my $kernel  = $poe->kernel ;
                my $object  = $poe->object ;
                my $alias   = $POEIKC::Daemon::opt{name}.'_alias';
                $kernel->alias_set($alias);

                $kernel->call(
                        IKC =>
                                publish => $alias, Class::Inspector->methods(__PACKAGE__),
                );
        }

        sub catch {
                my $poe     = sweet_args ;
                my ( @data ) = @{$poe->args} ;
                POEIKC::Daemon::Utility::_DEBUG_log(@data);
                return [[$$, __PACKAGE__,__LINE__], \@data];
        }

        sub server_connect {
                my $poe     = sweet_args ;
                my $kernel  = $poe->kernel ;
                my $session = $poe->session;
                my $object = $poe->object;
                my ( $server, $port  ) = @{$poe->args} ;

                $server or die;
                $port or die;

                my $hash_param =        {
                        ip   => 'localhost', 
                        port => $port ,
                        on_connect => sub {
                                POEIKC::Daemon::Utility::_DEBUG_log('on_connect');
                        },
                        on_error =>sub {
                                POEIKC::Daemon::Utility::_DEBUG_log('on_error');
                        },
                };

                $kernel->yield(connect=> $server, $hash_param) unless $object->connected($server);

        }

        sub go {
                my $poe     = sweet_args ;
                my $kernel  = $poe->kernel ;
                my $session = $poe->session;
                my $object = $poe->object;
                my ( $server, $port  ) = @{$poe->args} ;

                my $call = sprintf "poe://%s/%s/catch", $server, $server.'_alias';
                my $back = "poe:callback";

                POEIKC::Daemon::Utility::_DEBUG_log([$call, $back]);

                $kernel->post('IKC', 'call', $call, $$.__PACKAGE__.':'.__LINE__, $back);
        }

        sub callback {
                my $poe         = sweet_args;
                my ( @data ) = @{$poe->args} ;
                POEIKC::Daemon::Utility::_DEBUG_log( [[$$, __PACKAGE__, __LINE__], \@data]);
        }

        1;

then ..

  poeikcd start -d -n=AAAA -p=1111 -I=eg/lib -M=MyServerAndClient
  poeikcd start -d -n=BBBB -p=2222 -I=eg/lib -M=MyServerAndClient

  poikc -p=1111 -D "AndClient->spawn"
  poikc -p=2222 -D "AndClient->spawn"

  poikc -p=1111 -D AAAA_alias server_connect BBBB 2222

  poikc -p=1111 -D AAAA_alias go BBBB 
  poikc -p=2222 -D BBBB_alias go AAAA 

DESCRIPTION

use it to communicate between poeikcd.

AUTHOR

Yuji Suzuki <yujisuzuki@mail.arbolbell.jp>

LICENSE

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

SEE ALSO

POE::Component::IKC::Client