summaryrefslogtreecommitdiff
path: root/Final/python/qpid/delegate.py
diff options
context:
space:
mode:
Diffstat (limited to 'Final/python/qpid/delegate.py')
-rw-r--r--Final/python/qpid/delegate.py54
1 files changed, 54 insertions, 0 deletions
diff --git a/Final/python/qpid/delegate.py b/Final/python/qpid/delegate.py
new file mode 100644
index 0000000000..035bb3c476
--- /dev/null
+++ b/Final/python/qpid/delegate.py
@@ -0,0 +1,54 @@
+#
+# 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.
+#
+
+"""
+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
+
+ 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)