NAME

NetSDS::App::QueueProcessor - queue processing server framework

SYNOPSIS

        -----------------------------
        # Configuration file

        # Queue server IP and port
        queue_server = "127.0.0.1:22201"

        # Pulling queue name
        queue_name = "myq"

        # Processing bandwidth (messages per second)
        bandwidth = 2

        # Timeout on idle loops
        idle_timeout = 3
        -----------------------------

        QProc->run(conf_file => './qproc.conf');

        1;

        package QProc;

        use Data::Dumper;
        use base 'NetSDS::App::QueueProcessor';

        # Message processing logic
        sub process {

                my ( $self, $msg ) = @_;

                # Just dump message structure
                print Dumper($msg);

        }

        1;

DESCRIPTION

NetSDS::App::QueueProcessor module implements framework for applications processing messages arriving from MemcacheQ queue server.

CLASS API

new([...]) - class constructor

initialize() - application initialization

Internal method implementing common startup actions.

main_loop() - main processing loop

Internal method for application logic.

process() - main JSON-RPC iteration

This is internal method that implements JSON-RPC call processing.

EXAMPLES

See samples/app_qproc.pl appliction.

SEE ALSO

NetSDS::Queue

NetSDS::App

TODO

None

AUTHOR

Michael Bochkaryov <misha@rattler.kiev.ua>

LICENSE

Copyright (C) 2008-2009 Michael Bochkaryov

This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA