summaryrefslogtreecommitdiff
path: root/qpid/python/examples
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2010-03-31 21:17:09 +0000
committerRafael H. Schloming <rhs@apache.org>2010-03-31 21:17:09 +0000
commit30ff4dcc85eaf5a2ea52cad9d965086c8062a4ce (patch)
treef316eee10c4613d74f2b768e043cf91a084e896f /qpid/python/examples
parentc53c4cc94e121c0fc3df6010cffa1bbb49a779db (diff)
downloadqpid-python-30ff4dcc85eaf5a2ea52cad9d965086c8062a4ce.tar.gz
added SSL support to API
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@929717 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/examples')
-rwxr-xr-xqpid/python/examples/api/drain2
-rwxr-xr-xqpid/python/examples/api/server2
-rwxr-xr-xqpid/python/examples/api/spout2
3 files changed, 3 insertions, 3 deletions
diff --git a/qpid/python/examples/api/drain b/qpid/python/examples/api/drain
index c244cbc09c..d7ac03afa6 100755
--- a/qpid/python/examples/api/drain
+++ b/qpid/python/examples/api/drain
@@ -73,7 +73,7 @@ class Formatter:
return eval(st, self.environ)
# XXX: should make URL default the port for us
-conn = Connection(url.host, url.port or AMQP_PORT,
+conn = Connection(url.host, url.port,
username=url.user,
password=url.password,
reconnect=opts.reconnect,
diff --git a/qpid/python/examples/api/server b/qpid/python/examples/api/server
index d7cd53de4b..f0bf1c2a4b 100755
--- a/qpid/python/examples/api/server
+++ b/qpid/python/examples/api/server
@@ -51,7 +51,7 @@ else:
parser.error("address is required")
# XXX: should make URL default the port for us
-conn = Connection(url.host, url.port or AMQP_PORT,
+conn = Connection(url.host, url.port,
username=url.user,
password=url.password,
reconnect=opts.reconnect,
diff --git a/qpid/python/examples/api/spout b/qpid/python/examples/api/spout
index 9606c3501f..0d37ede512 100755
--- a/qpid/python/examples/api/spout
+++ b/qpid/python/examples/api/spout
@@ -93,7 +93,7 @@ else:
content = text
# XXX: should make URL default the port for us
-conn = Connection(url.host, url.port or AMQP_PORT,
+conn = Connection(url.host, url.port,
username=url.user,
password=url.password,
reconnect=opts.reconnect,