Is it possible to empty a job queue on a Gearman server

python message-queue gearman
daniyalzade picture daniyalzade · Dec 22, 2010 · Viewed 10.7k times · Source

Is it possible to empty a job queue on a Gearman server? I am using the python driver for Gearman, and the documentation does not have any information about emptying queues. I would imagine that this functionality should exist, possibly, with a direct connection to the Gearman server.

Answer

Gary Richardson picture Gary Richardson · Sep 18, 2012

I came across this method:

/usr/bin/gearman -t 1000 -n -w -f function_name > /dev/null

which basically dumps all the jobs into /dev/null.

Related questions

What's a good rate limiting algorithm?

I could use some pseudo-code, or better, Python. I am trying to implement a rate-limiting queue for a Python IRC bot, and it partially works, but if someone triggers less messages than the limit (e.g., rate limit is 5 messages …

Read More
Error "unknown delivery tag" occurs when i try ack messages to RabbitMQ using pika (python)

I want process messages in few threads but i'm getting error during execute this code: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika import connection, credentials import time import threading …

Read More
Getting number of messages in a RabbitMQ queue

We're using amqplib to publish/consume messages. I want to be able to read the number of messages on a queue (ideally both acknowledged and unacknowledged). This will allow me to show a nice status diagram to the admin users …

Read More