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