File Coverage

blib/lib/Net/QMQP.pm

Criterion	Covered	Total	%
statement	15	41	36.5
branch	0	6	0.0
condition	0	9	0.0
subroutine	5	8	62.5
pod	2	2	100.0
total	22	66	33.3

package Net::QMQP;

use strict;
use vars qw($VERSION);
use Carp;
use IO::Socket;

$VERSION = "0.01";

use base qw( Class::Accessor );

__PACKAGE__->mk_accessors( qw(sender recipients host message timeout port debug) );

sub new
{
    my $self = shift;
    my $type = ref($self) || $self;
    my %args = @_;

    my $obj = $type->SUPER::new(\%args);

    $obj->{host}    ||= 'localhost';
    $obj->{timeout} ||= 120;
    $obj->{port}    ||= 628;

    return $obj;
}

sub queueing
{
    my $self = shift;

    my $buff = _netstring($self->message);
    $buff   .= _netstring($self->sender);

    if( ref($self->recipients) eq 'ARRAY' ){
	$buff .= join("",map{_netstring($_)}@{$self->recipients});
    }else{
	$buff .= _netstring($self->recipients);
    }

    $buff = _netstring($buff);

    my $sock = IO::Socket::INET->new(PeerAddr => $self->host,
				     PeerPort => $self->port,
				     Proto    => 'tcp',
				     Timeout  => $self->timeout,
				     ) or die($@);

    $sock->autoflush(1);

    carp($buff) if $self->debug;

    print $sock $buff;

    my $res = join("",<$sock>);

    close($sock);

    return $res;
}

sub _netstring
{
    my $str = shift;
    return sprintf("%d:$str,",length($str));
}

1;

__END__