| Swarmage documentation | view source | Contained in the Swarmage distribution. |
Swarmage::Queue::IKC::Client - IKC Client Acting As Queue
use Swarmage::Queue::IKC::Client;
my $queue = Swarmage::Queue::IKC::Client->new(
ip => "xxx.xxx.xxx.xxx",
port => "xxxx"
);
$queue->pump( ... )
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.
Delegates to the remote kernel's pump event.
Delegates to the remote kernel's enqueue event.
Delegates to the remote kernel's dequeue event.
| Swarmage documentation | view source | Contained in the Swarmage distribution. |