Gearman 2.x worker example

worker.py

#
# worker.py
#
# Based on code from http://www.darkcoding.net/software/choosing-a-message-queue-for-python-on-ubuntu-on-a-vps/
#
import time

from gearman import GearmanWorker

def speakTask(gearman_worker, job):
    r = 'Hello %s' % job.data
    print(r)
    return r

worker = GearmanWorker("[127.0.0.1]")
worker.register_task('speak', speakTask)
worker.work()