diff --git a/python/examples/README.txt b/python/examples/README.txt
index 41a6bbd..512ca4c 100644
--- a/python/examples/README.txt
+++ b/python/examples/README.txt
@@ -2,8 +2,22 @@
 similar intermediary that supports the AMQP 1.0 protocol, allows
 anonymous connections and accepts links to and from a node named
 'examples'. A very simple broker emulating script - broker.py - is
-provided against which the examples can also be run (transactions are
-not yet supported in this script).
+provided against which some of the examples can also be run.
+
+Transactions and selectors are not yet supported in this script, so the
+examples that require these features (tx_recy.py, tx_send.py,
+tx_recv_interactive.py, server_tx.py & selected_recv.py) need to be run
+with a broker that supports these features (for instance the qpidd broker)
+
+There is a test script that will run most of the examples. This script needs
+a broker to be running already as a prerequisite. As this script runs the
+transactional and selector requiring examples this broker must support these
+features.
+
+For example:
+    qpidd --queue-patterns '.*' &
+    PATH=.:$PATH python -m unittest -v
+run from within the examples directory
 
 Note: For builds that include SASL support via the cyrus sasl library,
 those examples that accept incoming connections may require some SASL
diff --git a/python/examples/abstract_server.py b/python/examples/abstract_server.py
index 6a7e312..e0e3eb7 100755
--- a/python/examples/abstract_server.py
+++ b/python/examples/abstract_server.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,8 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
-
 from proton_server import Server
 
 
diff --git a/python/examples/broker.py b/python/examples/broker.py
index b47c636..0f2e889 100755
--- a/python/examples/broker.py
+++ b/python/examples/broker.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -22,8 +22,6 @@
 import optparse
 import uuid
 
-import unittest
-
 from proton import Endpoint
 from proton.handlers import MessagingHandler
 from proton.reactor import Container
diff --git a/python/examples/client.py b/python/examples/client.py
index b149040..19f7edc 100755
--- a/python/examples/client.py
+++ b/python/examples/client.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,11 +18,10 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
 from proton import Message
 from proton.handlers import MessagingHandler
-from proton.reactor import Container, DynamicNodeProperties
+from proton.reactor import Container
 
 
 class Client(MessagingHandler):
diff --git a/python/examples/client_http.py b/python/examples/client_http.py
index add9420..3f76aea 100755
--- a/python/examples/client_http.py
+++ b/python/examples/client_http.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import tornado.ioloop
 import tornado.web
 from tornado.gen import coroutine
diff --git a/python/examples/colour_send.py b/python/examples/colour_send.py
index 170f227..e04d7e1 100755
--- a/python/examples/colour_send.py
+++ b/python/examples/colour_send.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
 from proton import Message
 from proton.handlers import MessagingHandler
diff --git a/python/examples/db_common.py b/python/examples/db_common.py
index 7d5c9b7..bd598de 100755
--- a/python/examples/db_common.py
+++ b/python/examples/db_common.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,12 +18,9 @@
 # under the License.
 #
 
-try:
-    import Queue
-except ImportError:
-    import queue as Queue
 
 import sqlite3
+import queue
 import threading
 
 
@@ -31,7 +28,7 @@
     def __init__(self, db, injector):
         self.db = db
         self.injector = injector
-        self.tasks = Queue.Queue()
+        self.tasks = queue.Queue()
         self.position = None
         self.pending_events = []
         self.running = True
@@ -111,7 +108,7 @@
                     while True:
                         f(conn)
                         f = self.tasks.get(False)
-                except Queue.Empty:
+                except queue.Empty:
                     pass
                 conn.commit()
                 for event in self.pending_events:
diff --git a/python/examples/db_ctrl.py b/python/examples/db_ctrl.py
index a263f96..8b5d4c3 100755
--- a/python/examples/db_ctrl.py
+++ b/python/examples/db_ctrl.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import sqlite3
 import sys
 
diff --git a/python/examples/db_recv.py b/python/examples/db_recv.py
index 8e293ce..7c95a2f 100755
--- a/python/examples/db_recv.py
+++ b/python/examples/db_recv.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import optparse
 from proton.handlers import MessagingHandler
 from proton.reactor import ApplicationEvent, Container, EventInjector
diff --git a/python/examples/db_send.py b/python/examples/db_send.py
index c18f17f..577aa92 100755
--- a/python/examples/db_send.py
+++ b/python/examples/db_send.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,13 +18,8 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
-import time
-try:
-    import Queue
-except ImportError:
-    import queue as Queue
+import queue
 
 
 from proton import Message
@@ -41,7 +36,7 @@
         self.sent = 0
         self.confirmed = 0
         self.load_count = 0
-        self.records = Queue.Queue(maxsize=50)
+        self.records = queue.Queue(maxsize=50)
         self.target = count
         self.db = Db("src_db", EventInjector())
 
diff --git a/python/examples/direct_recv.py b/python/examples/direct_recv.py
index 50551fc..d85ef91 100755
--- a/python/examples/direct_recv.py
+++ b/python/examples/direct_recv.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import optparse
 from proton.handlers import MessagingHandler
 from proton.reactor import Container
diff --git a/python/examples/direct_send.py b/python/examples/direct_send.py
index 762d0cb..2e08904 100755
--- a/python/examples/direct_send.py
+++ b/python/examples/direct_send.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
 from proton import Message
 from proton.handlers import MessagingHandler
diff --git a/python/examples/helloworld.py b/python/examples/helloworld.py
index 4e2adc9..fef5092 100755
--- a/python/examples/helloworld.py
+++ b/python/examples/helloworld.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 from proton import Message
 from proton.handlers import MessagingHandler
 from proton.reactor import Container
diff --git a/python/examples/helloworld_blocking.py b/python/examples/helloworld_blocking.py
index fb260d5..a5e5fb0 100755
--- a/python/examples/helloworld_blocking.py
+++ b/python/examples/helloworld_blocking.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,10 +18,8 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton import Message
 from proton.utils import BlockingConnection
-from proton.handlers import IncomingMessageHandler
 
 conn = BlockingConnection("localhost:5672")
 receiver = conn.create_receiver("examples")
diff --git a/python/examples/helloworld_direct.py b/python/examples/helloworld_direct.py
index 4218b53..65c0d72 100755
--- a/python/examples/helloworld_direct.py
+++ b/python/examples/helloworld_direct.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 from proton import Message
 from proton.handlers import MessagingHandler
 from proton.reactor import Container
diff --git a/python/examples/helloworld_direct_tornado.py b/python/examples/helloworld_direct_tornado.py
index 2b3bbd2..e1d2ae5 100755
--- a/python/examples/helloworld_direct_tornado.py
+++ b/python/examples/helloworld_direct_tornado.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton import Message
 from proton.handlers import MessagingHandler
 from proton_tornado import Container
diff --git a/python/examples/helloworld_tornado.py b/python/examples/helloworld_tornado.py
index 5604b21..68f9e60 100755
--- a/python/examples/helloworld_tornado.py
+++ b/python/examples/helloworld_tornado.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton import Message
 from proton.handlers import MessagingHandler
 from proton_tornado import Container
diff --git a/python/examples/proton_server.py b/python/examples/proton_server.py
index 6dfd807..b588ea1 100755
--- a/python/examples/proton_server.py
+++ b/python/examples/proton_server.py
@@ -1,4 +1,3 @@
-from __future__ import print_function
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
diff --git a/python/examples/proton_tornado.py b/python/examples/proton_tornado.py
index 55e8db8..a359b4c 100755
--- a/python/examples/proton_tornado.py
+++ b/python/examples/proton_tornado.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
diff --git a/python/examples/queue_browser.py b/python/examples/queue_browser.py
index 7f659f0..08b81a2 100755
--- a/python/examples/queue_browser.py
+++ b/python/examples/queue_browser.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton.reactor import Container, Copy
 from proton.handlers import MessagingHandler
 
diff --git a/python/examples/recurring_timer.py b/python/examples/recurring_timer.py
index 58f3ffd..55fbb26 100755
--- a/python/examples/recurring_timer.py
+++ b/python/examples/recurring_timer.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton.reactor import Container, Handler
 
 
diff --git a/python/examples/recurring_timer_tornado.py b/python/examples/recurring_timer_tornado.py
index ff4c078..1d9bff4 100755
--- a/python/examples/recurring_timer_tornado.py
+++ b/python/examples/recurring_timer_tornado.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton.reactor import Handler
 from proton_tornado import Container
 
diff --git a/python/examples/selected_recv.py b/python/examples/selected_recv.py
index 43b576b..5d8b374 100755
--- a/python/examples/selected_recv.py
+++ b/python/examples/selected_recv.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
 from proton import Url
 from proton.reactor import Container, Selector
diff --git a/python/examples/server.py b/python/examples/server.py
index eb0d66e..aad5504 100755
--- a/python/examples/server.py
+++ b/python/examples/server.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import optparse
 from proton import Message, Url
 from proton.handlers import MessagingHandler
diff --git a/python/examples/server_direct.py b/python/examples/server_direct.py
index 8cc7d9c..16496fa 100755
--- a/python/examples/server_direct.py
+++ b/python/examples/server_direct.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,8 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
-
 import uuid
 from proton import Message
 from proton.handlers import MessagingHandler
diff --git a/python/examples/server_tx.py b/python/examples/server_tx.py
index 731f9eb..7a2b9f2 100755
--- a/python/examples/server_tx.py
+++ b/python/examples/server_tx.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 from proton import Message
 from proton.reactor import Container
 from proton.handlers import MessagingHandler, TransactionHandler
diff --git a/python/examples/simple_recv.py b/python/examples/simple_recv.py
index 52724a3..f55dfa2 100755
--- a/python/examples/simple_recv.py
+++ b/python/examples/simple_recv.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import optparse
 from proton.handlers import MessagingHandler
 from proton.reactor import Container
diff --git a/python/examples/simple_send.py b/python/examples/simple_send.py
index 1d36517..f078c12 100755
--- a/python/examples/simple_send.py
+++ b/python/examples/simple_send.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
 from proton import Message
 from proton.handlers import MessagingHandler
diff --git a/python/examples/sync_client.py b/python/examples/sync_client.py
index 9a395ae..3b6d8d3 100755
--- a/python/examples/sync_client.py
+++ b/python/examples/sync_client.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -23,13 +23,9 @@
 (also known as RPC or Remote Procedure Call) using proton.
 
 """
-from __future__ import print_function, unicode_literals
-
 import optparse
-from proton import Message, Url, ConnectionException, Timeout
+from proton import Message, Url
 from proton.utils import SyncRequestResponse, BlockingConnection
-from proton.handlers import IncomingMessageHandler
-import sys
 
 parser = optparse.OptionParser(usage="usage: %prog [options]",
                                description="Send requests to the supplied address and print responses.")
diff --git a/python/examples/test_examples.py b/python/examples/test_examples.py
index c40bf1a..51974cc 100644
--- a/python/examples/test_examples.py
+++ b/python/examples/test_examples.py
@@ -29,37 +29,21 @@
     def __init__(self, args, **kwargs):
         super(Popen, self).\
             __init__(args,
+                     shell=False,
                      stderr=subprocess.STDOUT,
                      stdout=subprocess.PIPE,
                      universal_newlines=True, **kwargs)
 
-    # For Python 2 compatibility add context manager support to Popen if it's not there
-    if not hasattr(subprocess.Popen, '__enter__'):
-        def __enter__(self):
-            return self
 
-    # For Python 2 compatibility add context manager support to Popen if it's not there
-    if not hasattr(subprocess.Popen, '__exit__'):
-        def __exit__(self, exc_type, exc_val, exc_tb):
-            try:
-                if self.stdin:
-                    self.stdin.close()
-                if self.stdout:
-                    self.stdout.close()
-                if self.stderr:
-                    self.stderr.close()
-            finally:
-                self.wait()
-
-
-def remove_unicode_prefix(line):
-    return re.sub(r"u(['\"])", r"\1", line)
-
+# Like subprocess.run with our defaults but returning the Popen object
+def run(args, **kwargs):
+    p = Popen(args, **kwargs)
+    p.wait()
+    return p
 
 class ExamplesTest(unittest.TestCase):
     def test_helloworld(self, example="helloworld.py"):
-        with Popen([example]) as p:
-            p.wait()
+        with run([example]) as p:
             output = [l.strip() for l in p.stdout]
             self.assertEqual(output, ['Hello World!'])
 
@@ -77,19 +61,17 @@
 
     def test_simple_send_recv(self, recv='simple_recv.py', send='simple_send.py'):
         with Popen([recv]) as r:
-            with Popen([send]):
+            with run([send]):
                 pass
-            actual = [remove_unicode_prefix(l.strip()) for l in r.stdout]
-            expected_py2 = ["{'sequence': int32(%i)}" % (i + 1,) for i in range(100)]
-            expected_py3 = ["{'sequence': %i}" % (i + 1,) for i in range(100)]
-            self.assertIn(actual, [expected_py2, expected_py3])
+            actual = [l.strip() for l in r.stdout]
+            expected = ["{'sequence': %i}" % (i + 1,) for i in range(100)]
+            self.assertEqual(actual, expected)
 
     def test_client_server(self, client=['client.py'], server=['server.py'], sleep=0):
         with Popen(server) as s:
             if sleep:
                 time.sleep(sleep)
-            with Popen(client) as c:
-                c.wait()
+            with run(client) as c:
                 actual = [l.strip() for l in c.stdout]
                 inputs = ["Twas brillig, and the slithy toves",
                           "Did gire and gymble in the wabe.",
@@ -128,7 +110,7 @@
 
         # run send and recv
         with Popen(['db_recv.py', '-m', '100']) as r:
-            with Popen(['db_send.py', '-m', '100']):
+            with run(['db_send.py', '-m', '100']):
                 pass
             r.wait()
             # verify output of receive
@@ -137,10 +119,9 @@
             self.assertEqual(actual, expected)
 
         # verify state of databases
-        with Popen(['db_ctrl.py', 'list', './dst_db']) as v:
-            v.wait()
+        with run(['db_ctrl.py', 'list', './dst_db']) as v:
             expected = ["(%i, 'Message-%i')" % (i + 1, i + 1) for i in range(100)]
-            actual = [remove_unicode_prefix(l.strip()) for l in v.stdout]
+            actual = [l.strip() for l in v.stdout]
             self.assertEqual(actual, expected)
 
     def test_tx_send_tx_recv(self):
@@ -150,36 +131,31 @@
         self.maxDiff = None
         with Popen(['direct_recv.py', '-a', 'localhost:8888']) as r:
             time.sleep(0.5)
-            with Popen(['simple_send.py', '-a', 'localhost:8888']):
+            with run(['simple_send.py', '-a', 'localhost:8888']):
                 pass
             r.wait()
-            actual = [remove_unicode_prefix(l.strip()) for l in r.stdout]
-            expected_py2 = ["{'sequence': int32(%i)}" % (i + 1,) for i in range(100)]
-            expected_py3 = ["{'sequence': %i}" % (i + 1,) for i in range(100)]
-            self.assertIn(actual, [expected_py2, expected_py3])
+            actual = [l.strip() for l in r.stdout]
+            expected = ["{'sequence': %i}" % (i + 1,) for i in range(100)]
+            self.assertEqual(actual, expected)
 
     def test_direct_send_simple_recv(self):
         with Popen(['direct_send.py', '-a', 'localhost:8888']):
             time.sleep(0.5)
-            with Popen(['simple_recv.py', '-a', 'localhost:8888']) as r:
-                r.wait()
-                actual = [remove_unicode_prefix(l.strip()) for l in r.stdout]
-                expected_py2 = ["{'sequence': int32(%i)}" % (i + 1,) for i in range(100)]
-                expected_py3 = ["{'sequence': %i}" % (i + 1,) for i in range(100)]
-                self.assertIn(actual, [expected_py2, expected_py3])
+            with run(['simple_recv.py', '-a', 'localhost:8888']) as r:
+                actual = [l.strip() for l in r.stdout]
+                expected = ["{'sequence': %i}" % (i + 1,) for i in range(100)]
+                self.assertEqual(actual, expected)
 
     def test_selected_recv(self):
-        with Popen(['colour_send.py']):
+        with run(['colour_send.py']):
             pass
 
-        with Popen(['selected_recv.py', '-m', '50']) as r:
-            r.wait()
+        with run(['selected_recv.py', '-m', '50']) as r:
             actual = [l.strip() for l in r.stdout]
             expected = ["green %i" % (i + 1) for i in range(100) if i % 2 == 0]
             self.assertEqual(actual, expected)
 
-        with Popen(['simple_recv.py', '-m', '50']) as r:
-            r.wait()
+        with run(['simple_recv.py', '-m', '50']) as r:
             actual = [l.strip() for l in r.stdout]
             expected = ["red %i" % (i + 1) for i in range(100) if i % 2 == 1]
             self.assertEqual(actual, expected)
diff --git a/python/examples/tx_recv.py b/python/examples/tx_recv.py
index bea05ab..2e4a736 100755
--- a/python/examples/tx_recv.py
+++ b/python/examples/tx_recv.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import optparse
 from proton import Url
 from proton.reactor import Container
diff --git a/python/examples/tx_recv_interactive.py b/python/examples/tx_recv_interactive.py
index 63bc76b..e7626be 100755
--- a/python/examples/tx_recv_interactive.py
+++ b/python/examples/tx_recv_interactive.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function
 import sys
 import threading
 from proton.reactor import ApplicationEvent, Container, EventInjector
diff --git a/python/examples/tx_send.py b/python/examples/tx_send.py
index 3d53be5..8ba6638 100755
--- a/python/examples/tx_send.py
+++ b/python/examples/tx_send.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
@@ -18,7 +18,6 @@
 # under the License.
 #
 
-from __future__ import print_function, unicode_literals
 import optparse
 from proton import Message, Url
 from proton.reactor import Container