management/python/lib/qmf/client.py [301:421]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def queueMoveMessages(self, srcQueue, destQueue, qty):
        """Move messages from one queue to another"""
        self._method("queueMoveMessages", {'srcQueue':srcQueue,'destQueue':destQueue,'qty':qty})

    def queueRedirect(self, sourceQueue, targetQueue):
        """Enable/disable delivery redirect for indicated queues"""
        self._method("queueRedirect", {'sourceQueue':sourceQueue,'targetQueue':targetQueue})

    def setLogLevel(self, level):
        """Set the log level"""
        self._method("setLogLevel", {'level':level})

    def getLogLevel(self):
        """Get the log level"""
        return self._method('getLogLevel')

    def setTimestampConfig(self, receive):
        """Set the message timestamping configuration"""
        self._method("setTimestampConfig", {'receive':receive})

    def getTimestampConfig(self):
        """Get the message timestamping configuration"""
        return self._method('getTimestampConfig')

    def setLogHiresTimestamp(self, logHires):
        """Set the high resolution timestamp in logs"""
        self._method("setLogHiresTimestamp", {'logHires':logHires})

    def getLogHiresTimestamp(self):
        """Get the high resolution timestamp in logs"""
        return self._method('getLogHiresTimestamp')

    def addExchange(self, exchange_type, name, options={}, **kwargs):
        properties = {}
        properties['exchange-type'] = exchange_type
        for k,v in options.items():
            properties[k] = v
        for k,v in kwargs.items():
            properties[k] = v
        args = {'type':       'exchange',
                'name':        name,
                'properties':  properties,
                'strict':      True}
        self._method('create', args)

    def delExchange(self, name):
        args = {'type': 'exchange', 'name': name}
        self._method('delete', args)

    def addQueue(self, name, options={}, **kwargs):
        properties = options
        for k,v in kwargs.items():
            properties[k] = v
        args = {'type':       'queue',
                'name':        name,
                'properties':  properties,
                'strict':      True}
        self._method('create', args)

    def delQueue(self, name, if_empty=True, if_unused=True):
        options = {'if_empty':  if_empty,
                   'if_unused': if_unused}
        args = {'type':        'queue', 
                'name':         name,
                'options':      options}
        self._method('delete', args)

    def bind(self, exchange, queue, key="", options={}, **kwargs):
        properties = options
        for k,v in kwargs.items():
            properties[k] = v
        args = {'type':       'binding',
                'name':       "%s/%s/%s" % (exchange, queue, key),
                'properties':  properties,
                'strict':      True}
        self._method('create', args)

    def unbind(self, exchange, queue, key, **kwargs):
        args = {'type':       'binding',
                'name':       "%s/%s/%s" % (exchange, queue, key),
                'strict':      True}
        self._method('delete', args)

    def reloadAclFile(self):
        self._method('reloadACLFile', {}, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")

    def acl_lookup(self, userName, action, aclObj, aclObjName, propMap):
        args = {'userId':      userName,
                'action':      action,
                'object':      aclObj,
                'objectName':  aclObjName,
                'propertyMap': propMap}
        return self._method('Lookup', args, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")

    def acl_lookupPublish(self, userName, exchange, key):
        args = {'userId':       userName,
                'exchangeName': exchange,
                'routingKey':   key}
        return self._method('LookupPublish', args, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")

    def Redirect(self, sourceQueue, targetQueue):
        args = {'sourceQueue': sourceQueue,
                'targetQueue': targetQueue}
        return self._method('queueRedirect', args, "org.apache.qpid.broker:broker:amqp-broker")

    def create(self, _type, name, properties={}, strict=False):
        """Create an object of the specified type"""
        args = {'type': _type,
                'name': name,
                'properties': properties,
                'strict': strict}
        return self._method('create', args)

    def delete(self, _type, name, options):
        """Delete an object of the specified type"""
        args = {'type': _type,
                'name': name,
                'options': options}
        return self._method('delete', args)

    def list(self, _type):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



management/python/lib/qpidtoollibs/broker.py [211:332]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  def queueMoveMessages(self, srcQueue, destQueue, qty):
    """Move messages from one queue to another"""
    self._method("queueMoveMessages", {'srcQueue':srcQueue,'destQueue':destQueue,'qty':qty})

  def queueRedirect(self, sourceQueue, targetQueue):
    """Enable/disable delivery redirect for indicated queues"""
    self._method("queueRedirect", {'sourceQueue':sourceQueue,'targetQueue':targetQueue})

  def setLogLevel(self, level):
    """Set the log level"""
    self._method("setLogLevel", {'level':level})

  def getLogLevel(self):
    """Get the log level"""
    return self._method('getLogLevel')

  def setTimestampConfig(self, receive):
    """Set the message timestamping configuration"""
    self._method("setTimestampConfig", {'receive':receive})

  def getTimestampConfig(self):
    """Get the message timestamping configuration"""
    return self._method('getTimestampConfig')

  def setLogHiresTimestamp(self, logHires):
    """Set the high resolution timestamp in logs"""
    self._method("setLogHiresTimestamp", {'logHires':logHires})

  def getLogHiresTimestamp(self):
    """Get the high resolution timestamp in logs"""
    return self._method('getLogHiresTimestamp')

  def addExchange(self, exchange_type, name, options={}, **kwargs):
    properties = {}
    properties['exchange-type'] = exchange_type
    for k,v in options.items():
      properties[k] = v
    for k,v in kwargs.items():
      properties[k] = v
    args = {'type':       'exchange',
            'name':        name,
            'properties':  properties,
            'strict':      True}
    self._method('create', args)

  def delExchange(self, name):
    args = {'type': 'exchange', 'name': name}
    self._method('delete', args)

  def addQueue(self, name, options={}, **kwargs):
    properties = options
    for k,v in kwargs.items():
      properties[k] = v
    args = {'type':       'queue',
            'name':        name,
            'properties':  properties,
            'strict':      True}
    self._method('create', args)

  def delQueue(self, name, if_empty=True, if_unused=True):
    options = {'if_empty':  if_empty,
               'if_unused': if_unused}

    args = {'type':        'queue', 
            'name':         name,
            'options':      options}
    self._method('delete', args)

  def bind(self, exchange, queue, key="", options={}, **kwargs):
    properties = options
    for k,v in kwargs.items():
      properties[k] = v
    args = {'type':       'binding',
            'name':       "%s/%s/%s" % (exchange, queue, key),
            'properties':  properties,
            'strict':      True}
    self._method('create', args)

  def unbind(self, exchange, queue, key, **kwargs):
    args = {'type':       'binding',
            'name':       "%s/%s/%s" % (exchange, queue, key),
            'strict':      True}
    self._method('delete', args)

  def reloadAclFile(self):
    self._method('reloadACLFile', {}, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")

  def acl_lookup(self, userName, action, aclObj, aclObjName, propMap):
    args = {'userId':      userName,
            'action':      action,
            'object':      aclObj,
            'objectName':  aclObjName,
            'propertyMap': propMap}
    return self._method('Lookup', args, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")

  def acl_lookupPublish(self, userName, exchange, key):
    args = {'userId':       userName,
            'exchangeName': exchange,
            'routingKey':   key}
    return self._method('LookupPublish', args, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")

  def Redirect(self, sourceQueue, targetQueue):
    args = {'sourceQueue': sourceQueue,
            'targetQueue': targetQueue}
    return self._method('queueRedirect', args, "org.apache.qpid.broker:broker:amqp-broker")

  def create(self, _type, name, properties={}, strict=False):
    """Create an object of the specified type"""
    args = {'type': _type,
            'name': name,
            'properties': properties,
            'strict': strict}
    return self._method('create', args)

  def delete(self, _type, name, options):
    """Delete an object of the specified type"""
    args = {'type': _type,
            'name': name,
            'options': options}
    return self._method('delete', args)

  def list(self, _type):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -