NAME

Xango::Broker::Push - Xango's Push-Crawler

SYNOPSIS

use Xango::Broker::Push;

Xango::Broker::Push->spawn(
  Loop => 1
);

# in some other session...
foreach my $job (@jobs) {
  $kernel->post($broker_session, 'dispatch_job', $job);
}

DESCRIPTION

Xango::Broker::Push implements the push-model crawler for Xango. A separate session must notify the crawler that there are jobs to be fetched.

This is the preferred model if:

(a) Crawling is triggered by an event, not in a periodic manner
(b) You have long intervals between when jobs are available
(c) You have external entities that can work in a separate process to generate
the list of jobs to be processed

PARAMETERS

Loop (boolean)

If true, the broker session will continue even when the dispatch queue is empty. By default the Push crawler stops when the queue is exhausted, but you can set this to true if you know there are more jobs coming later.

When you set this option, use the 'shutdown' state from elsewhere to stop the broker session.

STATES

enqueue_job($job)

Enqueues a job to be processed.

flush_pending

flushes pending jobs, if possible

finalize_job

SEE ALSO

Xango::Broker::Base Xango::Broker::Pull

AUTHOR

Copyright (c) 2005 Daisuke Maki <dmaki@cpan.org>. All rights reserved. Development funded by Brazil, Ltd. <http://b.razil.jp>