Daisuke Maki > Swarmage > Swarmage::Queue::IKC::Client

Download:
Swarmage-0.01005.tar.gz

Dependencies

Annotate this POD

CPAN RT

New  1
Open  0
View/Report Bugs
Source  

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.

syntax highlighting: