Author: tross
Date: Thu Nov 20 12:28:17 2008
New Revision: 719359
URL: http://svn.apache.org/viewvc?rev=719359&view=rev
Log:
QPID-1464 - Moved qmf console API out of python/qpid and into python/qmf
Added:
incubator/qpid/trunk/qpid/python/qmf/
incubator/qpid/trunk/qpid/python/qmf/__init__.py
incubator/qpid/trunk/qpid/python/qmf/console.py
- copied unchanged from r719245,
incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py
Removed:
incubator/qpid/trunk/qpid/python/qpid/qmfconsole.py
Modified:
incubator/qpid/trunk/qpid/cpp/src/tests/acl.py
incubator/qpid/trunk/qpid/python/commands/qpid-config
incubator/qpid/trunk/qpid/python/commands/qpid-printevents
incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats
incubator/qpid/trunk/qpid/python/commands/qpid-route
incubator/qpid/trunk/qpid/python/qpid/management.py
incubator/qpid/trunk/qpid/python/qpid/managementdata.py
incubator/qpid/trunk/qpid/python/qpid/testlib.py
Modified: incubator/qpid/trunk/qpid/cpp/src/tests/acl.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/acl.py?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/acl.py (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/acl.py Thu Nov 20 12:28:17 2008
@@ -24,7 +24,7 @@
from qpid.connection import Connection
from qpid.datatypes import uuid4
from qpid.testlib import TestBase010, testrunner
-from qpid.qmfconsole import Session
+from qmf.console import Session
from qpid.datatypes import Message
def scan_args(name, default=None, args=sys.argv[1:]):
@@ -456,4 +456,4 @@
extract_args("--port", args)
args.append("acl")
- if not testrunner.run(args): sys.exit(1)
\ No newline at end of file
+ if not testrunner.run(args): sys.exit(1)
Modified: incubator/qpid/trunk/qpid/python/commands/qpid-config
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/commands/qpid-config?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/commands/qpid-config (original)
+++ incubator/qpid/trunk/qpid/python/commands/qpid-config Thu Nov 20 12:28:17
2008
@@ -23,7 +23,7 @@
import getopt
import sys
import locale
-from qpid import qmfconsole
+from qmf.console import Session
_recursive = False
_host = "localhost"
@@ -93,7 +93,7 @@
def SetBroker (self, brokerUrl):
self.url = brokerUrl
- self.qmf = qmfconsole.Session()
+ self.qmf = Session()
self.broker = self.qmf.addBroker(brokerUrl)
def Disconnect(self):
Modified: incubator/qpid/trunk/qpid/python/commands/qpid-printevents
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/commands/qpid-printevents?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/commands/qpid-printevents (original)
+++ incubator/qpid/trunk/qpid/python/commands/qpid-printevents Thu Nov 20
12:28:17 2008
@@ -24,7 +24,7 @@
import sys
import socket
import time
-from qpid.qmfconsole import Console, Session
+from qmf.console import Console, Session
class EventConsole(Console):
def event(self, broker, event):
Modified: incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats (original)
+++ incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats Thu Nov 20
12:28:17 2008
@@ -26,7 +26,7 @@
import socket
import qpid
from threading import Condition
-from qpid.qmfconsole import Session, Console
+from qmf.console import Session, Console
from qpid.peer import Closed
from qpid.connection import Connection, ConnectionFailed
from qpid.util import connect
Modified: incubator/qpid/trunk/qpid/python/commands/qpid-route
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/commands/qpid-route?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/commands/qpid-route (original)
+++ incubator/qpid/trunk/qpid/python/commands/qpid-route Thu Nov 20 12:28:17
2008
@@ -24,7 +24,7 @@
import socket
import os
import locale
-from qpid import qmfconsole
+from qmf.console import Session, BrokerURL
def Usage():
print "Usage: qpid-route [OPTIONS] dynamic add <dest-broker> <src-broker>
<exchange> [tag] [exclude-list]"
@@ -65,9 +65,9 @@
class RouteManager:
def __init__(self, localBroker):
- self.local = qmfconsole.BrokerURL(localBroker)
+ self.local = BrokerURL(localBroker)
self.remote = None
- self.qmf = qmfconsole.Session()
+ self.qmf = Session()
self.broker = self.qmf.addBroker(localBroker)
def disconnect(self):
@@ -81,7 +81,7 @@
return None
def addLink(self, remoteBroker):
- self.remote = qmfconsole.BrokerURL(remoteBroker)
+ self.remote = BrokerURL(remoteBroker)
if self.local.match(self.remote.host, self.remote.port):
raise Exception("Linking broker to itself is not permitted")
@@ -100,7 +100,7 @@
print "Connect method returned:", res.status, res.text
def delLink(self, remoteBroker):
- self.remote = qmfconsole.BrokerURL(remoteBroker)
+ self.remote = BrokerURL(remoteBroker)
brokers = self.qmf.getObjects(_class="broker")
broker = brokers[0]
link = self.getLink()
@@ -137,7 +137,7 @@
added = False
links = qmf.getObjects(_class="link")
for link in links:
- url = qmfconsole.BrokerURL("%s:%d" % (link.host, link.port))
+ url = BrokerURL("%s:%d" % (link.host, link.port))
if url.name() not in brokerList:
print " %s..." % url.name(),
try:
@@ -263,7 +263,7 @@
print "Bridge method returned:", res.status, res.text
def delQueueRoute(self, remoteBroker, exchange, queue):
- self.remote = qmfconsole.BrokerURL(remoteBroker)
+ self.remote = BrokerURL(remoteBroker)
link = self.getLink()
if link == None:
if not _quiet:
@@ -293,7 +293,7 @@
raise Exception("Route not found")
def delRoute(self, remoteBroker, exchange, routingKey, dynamic=False):
- self.remote = qmfconsole.BrokerURL(remoteBroker)
+ self.remote = BrokerURL(remoteBroker)
link = self.getLink()
if link == None:
if not _quiet:
Added: incubator/qpid/trunk/qpid/python/qmf/__init__.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qmf/__init__.py?rev=719359&view=auto
==============================================================================
--- incubator/qpid/trunk/qpid/python/qmf/__init__.py (added)
+++ incubator/qpid/trunk/qpid/python/qmf/__init__.py Thu Nov 20 12:28:17 2008
@@ -0,0 +1,18 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you 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.
+#
Modified: incubator/qpid/trunk/qpid/python/qpid/management.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/management.py?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/management.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/management.py Thu Nov 20 12:28:17 2008
@@ -18,7 +18,7 @@
#
###############################################################################
-## This file is being obsoleted by qpid/qmfconsole.py
+## This file is being obsoleted by qmf/console.py
###############################################################################
"""
Modified: incubator/qpid/trunk/qpid/python/qpid/managementdata.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/managementdata.py?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/managementdata.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/managementdata.py Thu Nov 20 12:28:17
2008
@@ -21,7 +21,7 @@
###############################################################################
-## This file is being obsoleted by qpid/qmfconsole.py
+## This file is being obsoleted by qmf/console.py
###############################################################################
import qpid
Modified: incubator/qpid/trunk/qpid/python/qpid/testlib.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/testlib.py?rev=719359&r1=719358&r2=719359&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/testlib.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/testlib.py Thu Nov 20 12:28:17 2008
@@ -22,7 +22,7 @@
#
import sys, re, unittest, os, random, logging, traceback
-import qpid.client, qpid.spec, qpid.qmfconsole
+import qpid.client, qpid.spec, qmf.console
import Queue
from fnmatch import fnmatch
from getopt import getopt, GetoptError
@@ -364,7 +364,7 @@
self.qmf = None
def startQmf(self):
- self.qmf = qpid.qmfconsole.Session()
+ self.qmf = qmf.console.Session()
self.qmf_broker = self.qmf.addBroker(str(testrunner.url))
def connect(self, host=None, port=None):
