diff options
author | Rafael H. Schloming <rhs@apache.org> | 2010-01-29 21:52:55 +0000 |
---|---|---|
committer | Rafael H. Schloming <rhs@apache.org> | 2010-01-29 21:52:55 +0000 |
commit | 5cd0ee04a9c1095b96f312d5694f607b07d59b63 (patch) | |
tree | abeaa34e5d20d86af29a91c1f8fae35631041fee /python/server | |
parent | 7f2532ceb27fae57ebe8f2d80ba40665f0e6e1cf (diff) | |
download | qpid-python-5cd0ee04a9c1095b96f312d5694f607b07d59b63.tar.gz |
removed extraneous cruft
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904641 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/server')
-rwxr-xr-x | python/server | 80 |
1 files changed, 0 insertions, 80 deletions
diff --git a/python/server b/python/server deleted file mode 100755 index 56edd38490..0000000000 --- a/python/server +++ /dev/null @@ -1,80 +0,0 @@ -#!/usr/bin/env python -# -# 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. -# -import qpid -from qpid.connection import Connection, listen -from qpid.delegate import Delegate -from qpid.peer import Peer -from qpid import Struct - -class Server(Delegate): - - def __init__(self): - Delegate.__init__(self) - self.queues = {} - self.bindings = {} - - def connection_open(self, ch, msg): - msg.open_ok() - - def session_open(self, ch, msg): - print "session open on channel %s" % ch.id - msg.attached() - - def execution_flush(self, ch, msg): - pass - - def queue_declare(self, ch, msg): - self.queues[msg.queue] = [] - print "queue declared: %s" % msg.queue - msg.complete() - - def queue_bind(self, ch, msg): - if self.bindings.has_key(msg.exchange): - queues = self.bindings[msg.exchange] - else: - queues = set() - self.bindings[msg.exchange] = queues - queues.add((msg.routing_key, msg.queue)) - msg.complete() - - def queue_query(self, ch, msg): - st = Struct(msg.method.result) - ch.execution_result(msg.command_id, st) - msg.complete() - - def message_subscribe(self, ch, msg): - print msg - msg.complete() - - def message_transfer(self, ch, msg): - print msg.content - msg.complete() - - -spec = qpid.spec.load("../specs/amqp.0-10-preview.xml") - -for io in listen("0.0.0.0", 5672): - c = Connection(io, spec) - p = Peer(c, Server()) - c.tini() - p.start() - ch = p.channel(0) - ch.connection_start() - ch.connection_tune() |