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, 52 insertions, 0 deletions

diff --git a/python/qpid/delegate.py b/python/qpid/delegate.py
new file mode 100644
index 0000000000..0467162498
--- /dev/null
+++ b/python/qpid/delegate.py
@@ -0,0 +1,52 @@
+#
+# 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.
+#
+
+"""
+Delegate implementation intended for use with the peer module.
+"""
+
+import threading, inspect
+from spec import pythonize
+
+class Delegate:
+
+  def __init__(self):
+    self.handlers = {}
+    self.invokers = {}
+    # initialize all the mixins
+    self.invoke_all("init")
+
+  def invoke_all(self, meth, *args, **kwargs):
+    for cls in inspect.getmro(self.__class__):
+      if hasattr(cls, meth):
+        getattr(cls, meth)(self, *args, **kwargs)
+
+  def dispatch(self, channel, message):
+    method = message.method
+    spec = method.klass.spec
+
+    try:
+      handler = self.handlers[method]
+    except KeyError:
+      name = "%s_%s" % (pythonize(method.klass.name),
+                        pythonize(method.name))
+      handler = getattr(self, name)
+      self.handlers[method] = handler
+
+    return handler(channel, message)
+
+  def close(self, reason):
+    self.invoke_all("close", reason)