Import of qpid from etp:

  URL: https://etp.108.redhat.com/svn/etp/trunk/blaze
  Repository Root: https://etp.108.redhat.com/svn/etp
  Repository UUID: 06e15bec-b515-0410-bef0-cc27a458cf48
  Revision: 608



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@447994 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 190 insertions, 0 deletions

diff --git a/java/management/cli/src/python/stac.py b/java/management/cli/src/python/stac.py
new file mode 100644
index 0000000000..d521dc18c3
--- /dev/null
+++ b/java/management/cli/src/python/stac.py
@@ -0,0 +1,190 @@
+#
+# Copyright (c) 2006 The Apache Software Foundation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+"""
+Bridges between Python and Java, to provide a simpler and more Pythonesque environment.
+Certified to be free of dead parrots.
+"""
+# Imports
+from java.lang import *
+import org.amqp.blaze.management.jmx.AMQConsole as AMQConsole
+import org.amqp.blaze.stac.jmx.MBeanServerConnectionContext as MBeanServerConnectionContext
+
+# Globals
+commandPrompt = ""
+proxied = 0
+connected = 0
+amqConsole = None
+connectionContext = None
+
+# Functions
+def connect(url="", username="", password=""):
+  """
+  Connects to an AMQP broker. The URL must be in the form amq://host:port/context
+  """
+  try:
+    global connected
+    global connectionContext
+    if connected==1:
+      print "Already Connected!"
+      return
+
+    try:
+       parsedURL = parseURL(url)
+    except URLFormatError, ufe:
+       print "Invalid URL: " + ufe.msg
+       return
+
+    amqConsole = AMQConsole(parsedURL['host'], parsedURL['port'], username, password, parsedURL['context'])
+
+    amqConsole.initialise()
+    amqConsole.registerAllMBeans()
+    connectionContext = MBeanServerConnectionContext()
+    connectionContext.connect()
+    connected = 1
+  except Exception, e:
+    updateGlobals()
+    print e
+    e.printStackTrace()
+    cause = e.getCause()
+    if cause != None:
+        cause.printStackTrace()
+  else:
+    updateGlobals();
+
+def disconnect():
+    """
+    Disconnects from the broker
+    """
+    global connected
+    global connectionContext
+
+    if connected==0:
+      print "Not connected!"
+      return
+    try:
+        connectionContext.disconnect()
+        connected = 0
+    except Exception, e:
+        updateGlobals()
+        print e
+    else:
+        updateGlobals()
+
+def quit():
+    global connected
+    if connected != 0:
+        disconnect()    
+
+def ls():
+    """
+    Lists the current mbean
+    """
+    global connected
+    if connected == 0:
+        print "Not connected!"
+        return
+
+    connectionContext.ls()
+
+def cd(beanName):
+    """
+    Changes the current mbean
+    """
+    global connected
+    global connectionContext
+    if connected == 0:
+        print "Not connected!"
+        return
+
+    try:
+        connectionContext.cd(beanName)
+    except Exception, e:
+        updateGlobals()
+        msg = "Error: " + e.getMessage()
+        print msg
+    else:
+        updateGlobals()
+
+def invoke(methodName):
+    """
+    Invokes an operation of the current mbean
+    """
+    global connected
+    global connectionContext
+
+    if connected == 0:
+        print "Not connected!"
+        return
+
+    try:
+        connectionContext.invoke(methodName, None)
+    except Exception, e:
+        updateGlobals()
+        msg = "Error: " + e.getMessage()
+        print msg
+    else:
+        updateGlobals()
+
+class URLFormatError(Exception):
+    """Exception raised for errors in format of the URL
+
+    Attributes:
+        expression -- input expression in which the error occurred
+        message -- explanation of the error
+    """
+
+    def __init__(self, url, message):
+        self.url = url
+        self.msg = message
+
+def parseURL(url):
+    """
+    Parses an AMQ URL into host, port and context components returning them in a dictionary
+    """
+    idx = url.find("amq://")
+    errorMsg = "Invalid URL - must be format amq://hostname:port/vhost"
+    if idx != 0:
+        raise URLFormatError(url, errorMsg)
+
+    hostEndIdx = url.find(":", 6)
+    if hostEndIdx == -1:
+        raise URLFormatError(url, errorMsg)
+
+    hostname = url[6:hostEndIdx]
+
+    portIdx = url.find("/", hostEndIdx + 1)
+    port = url[hostEndIdx + 1:portIdx]
+    vhost = url[portIdx + 1:]
+    if portIdx == -1:
+        raise URLFormatError(url, errorMsg)
+
+    return {'host':hostname,'port':int(port),'context':vhost}
+
+def updateGlobals():
+    global commandPrompt
+    global connectionContext
+    if connected == 1:
+        commandPrompt = "AMQ:connected#" + connectionContext.getCurrentMBean().getAttributeValue("name", "java.lang.String") + "> "
+    else:
+        commandPrompt = "AMQ:disconnected> "
+# Classes
+
+
+# Global execution
+
+# Update all the global variables - this is called to sync everything at the start
+updateGlobals()