in content/artifacts/daytrader_singleServer.py [0:0]
def createJMSQueue ( qName, jndiName, SIBDest, delMode, scope ):
# qName - queue name
# jndiName - queue jndi name
# SIBDest - SIB destination
# delMode - delivery mode
# scope - scope
print " "
print "Creating JMS Queue " + qName + "..."
# Check if the queue already exists
qList = AdminTask.listSIBJMSQueues(scope )
queue = ""
if (len(qList) > 0):
for item in qList.split("\n"):
item = item.rstrip()
if (item.find(qName) >= 0):
queue = item
break
#endIf
#endFor
#endIf
if (queue == ""):
print " Queue Name: " + qName
print " JNDI Name: " + jndiName
print " SIB Destination: " + SIBDest
print " Delivery Mode: " + delMode
params = ["-name", qName, "-jndiName", jndiName, "-queueName", SIBDest, "-deliveryMode", delMode]
queue = AdminTask.createSIBJMSQueue(scope, params )
print qName + " created successfully!"
else:
print qName + " already exists!"
#endElse
return queue