import psync

print( psync.app.control.discard_all() )

@@ -11,45 +11,404 @@
 nc%0A%0A
-print( psync.app.control.discard_all(
+# These might work IF the CELERY_ROUTES config setting were set properly%0A#print( psync.app.control.discard_all() )%0A#print( psync.app.control.purge() )%0A%0A# Otherwise, name the queues here%0Aimport celery.bin.amqp%0Aamqp = celery.bin.amqp.amqp( app = psync.app )%0Aqueuenames = %5B 'celery', 'hardlinks', 'directories' %5D%0Afor q in queuenames:%0A    print( 'Queue: ' + q )%0A    print( amqp.run( 'queue.purge', q 
 ) )%0A

Update for rabbitmq