summaryrefslogtreecommitdiff
path: root/qpid/python/examples/direct
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/python/examples/direct')
-rw-r--r--qpid/python/examples/direct/config_direct_exchange.py4
-rw-r--r--qpid/python/examples/direct/direct_consumer.py2
2 files changed, 1 insertions, 5 deletions
diff --git a/qpid/python/examples/direct/config_direct_exchange.py b/qpid/python/examples/direct/config_direct_exchange.py
index 45af6f63b9..e64ad678b8 100644
--- a/qpid/python/examples/direct/config_direct_exchange.py
+++ b/qpid/python/examples/direct/config_direct_exchange.py
@@ -49,9 +49,5 @@ session.queue_bind(exchange="amq.direct", queue="message_queue", routing_key="ro
#----- Cleanup ---------------------------------------------
-# Clean up before exiting so there are no open threads.
-#
-# Close Channel 1.
-# Close the connection using Channel 0, which is used for all connection methods.
session.session_close()
diff --git a/qpid/python/examples/direct/direct_consumer.py b/qpid/python/examples/direct/direct_consumer.py
index 4e50dfbc2a..38b1ba30a0 100644
--- a/qpid/python/examples/direct/direct_consumer.py
+++ b/qpid/python/examples/direct/direct_consumer.py
@@ -72,4 +72,4 @@ message.complete(cumulative=True)
# Clean up before exiting so there are no open threads.
#
-# session.session_close()
+session.session_close()