POE::Component::RSSAggregator - Watch Muliple RSS Feeds for New Headlines

Acknowledgements

       Special thanks to Rocco Caputo, Martijn van Beers, Sean Burke, Prakash Kailasa and  Randal  Schwartz  for
       their help, guidance, patience, and bug reports. Guys thanks for actually taking time to use the code and
       give good, honest feedback.

Author

       Jeff Bisbee, "<jbisbee at cpan.org>"

Bugs

       Please  report  any  bugs  or  feature  requests  to "bug-poe-component-rssaggregator at rt.cpan.org", or
       through                    the                    web                    interface                     at
       <http://rt.cpan.org/NoAuth/ReportBug.html?Queue=POE-Component-RSSAggregator>.   I  will  be notified, and
       then you'll automatically be notified of progress on your bug as I make changes.

Constructors

POE::Component::RSSAggregator->new(%hash);
       Create a new instace of PoCo::RSSAggregator.

       •   alias

           POE alias to use for your instance of PoCo::RSSAggregator.

       •   debug

           Boolean  value  to turn on verbose output.  (debug is also passed to XML::RSS::Feed instances to turn
           on verbose output as well)

       •   tmpdir

           The tmpdir argument is passed on to XML::RSS::Feed as the directory to cache RSS between fetches (and
           instances).

       •   http_alias

           Optional.  Alias of an existing PoCoCl::HTTP.

       •   follow_redirects

           Optional.  Only if you don't have an exiting PoCoCl::HTTP.  Argument is  passed  to  PoCoCl::HTTP  to
           tell it the follow redirect level.  (Defaults to 2)

Copyright & License

       Copyright 2006 Jeff Bisbee, all rights reserved.

       This  program  is  free  software;  you can redistribute it and/or modify it under the same terms as Perl
       itself.

Methods

$rssagg->feed_list
       Returns the current feeds as an array or array_ref.

   $rssagg->feeds
       Returns  a  hash  ref of feeds with the key being the feeds name.  The hash reference you that belongs to
       the key is passed to XML::RSS::Feed->new($hash_ref). ( see XML::RSS::Feed )

   $rssagg->feed($feed_name)
       Accessor to access a the XML::RSS::Feed object via a feed's name.

   $rssagg->add_feed($hash_ref)
       The hash  reference  you  pass  in  to  add_feed  is  passed  to  XML::RSS::Feed->new($hash_ref).  (  see
       XML::RSS::Feed )

   $rssagg->remove_feed($feed_name)
       Pass in the name of the feed you want to remove.

   $rssagg->pause_feed($feed_name)
       Pass in the name of the feed you want to pause.

   $rssagg->resume_feed($feed_name)
       Pass in the name of the feed you want to resume (that you previously paused).

   $rssagg->shutdown
       Shutdown the instance of PoCo::RSSAggregator.

Name

       POE::Component::RSSAggregator - Watch Muliple RSS Feeds for New Headlines

Support

       You can find documentation for this module with the perldoc command.

           perldoc POE::Component::RSSAggregator

       You can also look for information at:

       •   AnnoCPAN: Annotated CPAN documentation

           <http://annocpan.org/dist/POE-Component-RSSAggregator>

       •   CPAN Ratings

           <http://cpanratings.perl.org/d/POE-Component-RSSAggregator>

       •   RT: CPAN's request tracker

           <http://rt.cpan.org/NoAuth/Bugs.html?Dist=POE-Component-RSSAggregator>

       •   Search CPAN

           <http://search.cpan.org/dist/POE-Component-RSSAggregator>

Synopsis

           #!/usr/bin/perl
           use strict;
           use warnings;
           use POE;
           use POE::Component::RSSAggregator;

           my @feeds = (
               {   url   => "http://www.jbisbee.com/rdf/",
                   name  => "jbisbee",
                   delay => 10,
               },
               {   url   => "http://lwn.net/headlines/rss",
                   name  => "lwn",
                   delay => 300,
               },
           );

           POE::Session->create(
               inline_states => {
                   _start      => \&init_session,
                   handle_feed => \&handle_feed,
               },
           );

           $poe_kernel->run();

           sub init_session {
               my ( $kernel, $heap, $session ) = @_[ KERNEL, HEAP, SESSION ];
               $heap->{rssagg} = POE::Component::RSSAggregator->new(
                   alias    => 'rssagg',
                   debug    => 1,
                   callback => $session->postback("handle_feed"),
                   tmpdir   => '/tmp',        # optional caching
               );
               $kernel->post( 'rssagg', 'add_feed', $_ ) for @feeds;
           }

           sub handle_feed {
               my ( $kernel, $feed ) = ( $_[KERNEL], $_[ARG1]->[0] );
               for my $headline ( $feed->late_breaking_news ) {

                   # do stuff with the XML::RSS::Headline object
                   print $headline->headline . "\n";
               }
           }