File Coverage

blib/lib/POEIKC/Plugin/GlobalQueue/ClientLite.pm

Criterion	Covered	Total	%
statement	10	12	83.3
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod			n/a
total	14	16	87.5

package POEIKC::Plugin::GlobalQueue::ClientLite;

use strict;
use 5.008_001;
our $VERSION = '0.01';
use Sys::Hostname ();
use POE::Component::IKC::ClientLite;

sub new {
    my $class = shift ;
    my $self = {
        	ikc 		=> undef,
        	RaiseError 	=> 0,
        	error => undef,
        	@_
        };
    for (qw(ip port name serialiser timeout connect_timeout block_size)){
		$self->{create_ikc_client}->{$_} = delete $self->{$_} if exists $self->{$_};
    }
    $class = ref $class if ref $class;
    bless  $self,$class ;
    return $self ;
}

sub ikc {
	my $self = shift;
	$self->{ikc} = shift if @_ >= 1;
	return $self->{ikc};
}

sub error {shift->{error}}

sub connect {
	my $self = shift;
	$self->{error} = undef;
	my %param = (
		ip 		=> Sys::Hostname::hostname,
		port 	=> 40101,
		name 	=> join('_'=>Sys::Hostname::hostname, ($0 =~ /(\w+)/g), $$),
		%{$self->{create_ikc_client}},
		@_
	);
	$self->{ikc} = create_ikc_client(%param);
	if (not($self->{ikc})) {
		$self->{error}  = $POE::Component::IKC::ClientLite::error;
		$self->{RaiseError} and die($POE::Component::IKC::ClientLite::error);
	}
	return $self->{ikc};
}

sub enqueue {
	my $self = shift;
	$self->{error} = undef;
	my $capsule = shift;
	$self->{ikc} ||= $self->connect;
	if ( $self->{ikc} ) {
		my $ret = $self->{ikc}->post_respond(
			'GlobalQueue/enqueue_respond' =>$capsule
		);
		return $ret;
	}
	return ;
}

sub dequeue {
	my $self = shift;
	$self->{error} = undef;
	$self->{ikc} ||= $self->connect;
	if ( $self->{ikc} ) {
		my $ret = $self->{ikc}->post_respond(
			'GlobalQueue/dequeue_respond' =>\@_
		);
		return $ret;
	}
	return ;
}

sub length{
	my $self = shift;
	$self->{ikc} ||= $self->connect;
	if ( $self->{ikc} ) {
		my $ret = $self->{ikc}->post_respond(
			'GlobalQueue/length_respond' =>@_
		);
		return $ret;
	}
	return ;
}



1;
__END__