summaryrefslogtreecommitdiff
path: root/trunk/qpid/python/hello-world
diff options
context:
space:
mode:
Diffstat (limited to 'trunk/qpid/python/hello-world')
-rwxr-xr-xtrunk/qpid/python/hello-world64
1 files changed, 0 insertions, 64 deletions
diff --git a/trunk/qpid/python/hello-world b/trunk/qpid/python/hello-world
deleted file mode 100755
index efee84059c..0000000000
--- a/trunk/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()