diff options
| -rwxr-xr-x | qpid/python/hello-world | 64 | ||||
| -rwxr-xr-x | qpid/python/server | 80 | ||||
| -rwxr-xr-x | qpid/python/server010 | 72 |
3 files changed, 0 insertions, 216 deletions
diff --git a/qpid/python/hello-world b/qpid/python/hello-world deleted file mode 100755 index efee84059c..0000000000 --- a/qpid/python/hello-world +++ /dev/null @@ -1,64 +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 sys -from qpid.connection import Connection -from qpid.util import connect -from qpid.datatypes import uuid4, Message - -broker = "127.0.0.1" -port = 5672 - -if len(sys.argv) > 1: broker = sys.argv[1] -if len(sys.argv) > 2: port = int(sys.argv[2]) - -if len(sys.argv) > 3: - print >> sys.stderr, "usage: hello-world [ <broker> [ <port> ] ]" - sys.exit(1) - -# connect to the server and start a session -conn = Connection(connect(broker, port)) -conn.start() -ssn = conn.session(str(uuid4())) - -# create a queue -ssn.queue_declare("test-queue") - -# publish a message -dp = ssn.delivery_properties(routing_key="test-queue") -mp = ssn.message_properties(content_type="text/plain") -msg = Message(dp, mp, "Hello World!") -ssn.message_transfer(message=msg) - -# subscribe to a queue -ssn.message_subscribe(destination="messages", queue="test-queue", - accept_mode=ssn.accept_mode.none) -incoming = ssn.incoming("messages") - -# start incoming message flow -incoming.start() - -# grab a message from the queue - -print incoming.get(timeout=10) - -# cancel the subscription and close the session and connection -ssn.message_cancel(destination="messages") -ssn.close() -conn.close() diff --git a/qpid/python/server b/qpid/python/server deleted file mode 100755 index 56edd38490..0000000000 --- a/qpid/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() diff --git a/qpid/python/server010 b/qpid/python/server010 deleted file mode 100755 index 8dfcd7a585..0000000000 --- a/qpid/python/server010 +++ /dev/null @@ -1,72 +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. -# - -from qpid import delegates -from qpid.connection010 import Connection -from qpid.util import connect, listen -from qpid.spec010 import load -from qpid.session import Client -from qpid.datatypes import Message -from qpid.log import enable, DEBUG, WARN - -import sys - -if "-v" in sys.argv: - level = DEBUG -else: - level = WARN - -enable("qpid", level) - -spec = load("../specs/amqp.0-10.xml") - -class Server: - - def connection(self, connection): - return delegates.Server(connection, self.session) - - def session(self, session): - session.auto_sync = False - return SessionDelegate(session) - -class SessionDelegate(Client): - - def __init__(self, session): - self.session = session - - def queue_declare(self, qd): - print "Queue %s declared..." % qd.queue - - def queue_query(self, qq): - return qq._type.result.type.new((qq.queue,), {}) - - def message_transfer(self, cmd, headers, body): - m = Message(body) - m.headers = headers - self.session.message_transfer(cmd.destination, cmd.accept_mode, cmd.acquire_mode, m) - - def message_accept(self, messages): - print "ACCEPT %s" % messages - -server = Server() - -for s in listen("0.0.0.0", spec.port): - conn = Connection(s, spec, server.connection) - conn.start(5) |