File Coverage

blib/lib/Job/Machine/Client.pm

Criterion	Covered	Total	%
statement	9	26	34.6
branch			n/a
condition	0	15	0.0
subroutine	3	7	42.8
pod	4	4	100.0
total	16	52	30.7

package Job::Machine::Client;
$Job::Machine::Client::VERSION = '0.25';
use strict;
use warnings;

use base 'Job::Machine::Base';

sub send {
	my ($self, $data, $queue) = @_;
	$queue ||= $self->{queue};
	my $id = $self->db->insert_task($data,$queue);
	$self->{db}->notify(queue => $queue);
	return $id;
}

sub check {
	my ($self, $id) = @_;
	$id ||= $self->id;
	$self->{subscribed} ||= $self->subscribe($id,1); # Subscribe if not already subscribed
	return $self->db->get_notification;
}

sub uncheck {
	my ($self, $id) = @_;
	$id ||= $self->id;
	delete $self->{subscribed};
	$self->db->unlisten(queue => $id, reply => 1);
	return 1;
}

sub receive {
	my ($self, $id) = @_;
	$id ||= $self->id;
	return $self->db->fetch_first_result($id);
};

1;

__END__