addtoQPIDDB.py

#!/usr/bin/python

import sys
from lofar.qpidinfrastructure.QPIDDB import qpidinfra
from lofar.common import dbcredentials

from optparse import OptionParser

if __name__ == '__main__':
    parser = OptionParser('%prog [options]',
	     description='Add items to the QPIDinfra database from the commandline')
    parser.add_option('-b', '--broker', dest='broker', type='string', default=None, help='Address of the qpid broker (required)')
    parser.add_option('-f', '--federation', dest='federation' , type='string', default=None, help='Address of the federated broker')
    parser.add_option('-q', '--queue', dest='queue', type='string', default=None, help='Name of the queue on the broker')
    parser.add_option('-e', '--exchange', dest='exchange', type='string', default=None, help='Name of the exchange on the broker')
    parser.add_option('-k', '--routingkey', dest='routingkey', type='string', default='#', help='Federation routing key')
    parser.add_option_group(dbcredentials.options_group(parser, "qpidinfra"))

    (options, args) = parser.parse_args()

    if (len(sys.argv)<2):
	 parser.print_help()
	 sys.exit(0)

    dbcreds = dbcredentials.parse_options(options)
    QPIDinfra = qpidinfra(dbcreds)

    if (options.broker==None):
	parser.print_help()
	sys.exit(1)

    else:
	QPIDinfra.addhost(options.broker)

    if (options.queue):
	QPIDinfra.addqueue(options.queue)
	QPIDinfra.bindqueuetohost(options.queue,options.broker)
    
    if (options.exchange):
	QPIDinfra.addexchange(options.exchange)
	QPIDinfra.bindexchangetohost(options.exchange,options.broker)
    
    if (options.federation):
	QPIDinfra.addhost(options.federation)
	if (options.queue):
	    QPIDinfra.addqueue(options.queue) # should be superfluous
	    ecxchange=''
	    if (options.exchange):
		QPIDinfra.addexchange(options.exchange)
		exchange=options.exchange
	    
	    QPIDinfra.bindqueuetohost(options.queue,options.federation)
	    QPIDinfra.setqueueroute(options.queue,options.broker,options.federation,options.exchange)
	else:
	    if (options.exchange):
	        QPIDinfra.addexchange(options.exchange) # should be superfluous
	        QPIDinfra.bindexchangetohost(options.exchange,options.federation)
	        QPIDinfra.setexchangeroute(options.exchange,options.routingkey,options.broker,options.federation)
	    else:
		raise Exception("federation can only be setup with a queue or an exchange")