Gearman 2.x client example

client.py

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

import sys
import time

from gearman import GearmanClient

client = GearmanClient(["127.0.0.1"])

i = 0
while 1:
    result = client.submit_job('speak', str(i))
    print 'Dispatched %d' % i
    print 'Result is: %s' % str(result.result)
    i += 1
    time.sleep(1)