NAME

Swarmage::Queue::IKC::Client - IKC Client Acting As Queue

SYNOPSIS

  use Swarmage::Queue::IKC::Client;
  my $queue = Swarmage::Queue::IKC::Client->new(
    ip   => "xxx.xxx.xxx.xxx",
    port => "xxxx"
  );
  $queue->pump( ... )

DESCRIPTION

Swarmage::Queue::IKC::Client attaches itself to a remote POE kernel, and asks the remote kernel for new tasks to be executed.

The remote kernel must implement a "pump" state, which should accept the same arguments as the other queues.

METHODS

new

is_async

pump

Delegates to the remote kernel's pump event.

enqueue

Delegates to the remote kernel's enqueue event.

dequeue

Delegates to the remote kernel's dequeue event.