Revision 8c911970 snf-cyclades-app/synnefo/logic/management/commands/queue-inspect.py

b/snf-cyclades-app/synnefo/logic/management/commands/queue-inspect.py
31 31 
import pprint
32 32 

  		





  33
  33
  
    
from optparse import make_option


  		





  34
  
  
    
from django.core.management.base import BaseCommand, CommandError


  		





  
  34
  
    
from django.core.management.base import CommandError


  		





  
  35
  
    
from snf_django.management.commands import SynnefoCommand


  		





  35
  36
  
    

  		





  36
  37
  
    
from synnefo.lib.amqp import AMQPClient


  		





  37
  38
  
    

  		





  38
  39
  
    

  		





  39
  
  
    
class Command(BaseCommand):


  		





  
  40
  
    
class Command(SynnefoCommand):


  		





  40
  41
  
    
    args = "<queue name>"


  		





  41
  42
  
    
    help = "Inspect the messages of a queue. Close all other clients in "\


  		





  42
  43
  
    
           "order to be able to inspect unacknowledged messages."


  		





  43
  44
  
    

  		





  44
  
  
    
    option_list = BaseCommand.option_list + (


  		





  
  45
  
    
    option_list = SynnefoCommand.option_list + (


  		





  45
  46
  
    
        make_option('--no-requeue', action='store_false', dest='requeue',


  		





  46
  47
  
    
                    default=True, help="Do not requeue the messages"),


  		





  47
  48
  
    
        make_option('-i', '--interactive', action='store_true', default=False,


  		












Also available in:
  Unified diff