Updated build scripts

Author: annatisch

HISTORY.rst

@@ -3,7 +3,7 @@
 Release History
 ===============
 
-0.1.0rc2 (unreleased)
+0.1.0rc2 (2018-07-02)
 +++++++++++++++++++++
 
 - **Breaking change** Submodule `async` has been renamed to the internal `_async`.

build_many_linux_32bit.sh

@@ -14,6 +14,7 @@ export OPENSSL_ROOT_DIR="/opt/pyca/cryptography/openssl"
 /opt/python/cp34-cp34m/bin/python -m pip install cython==0.27.3 wheel
 /opt/python/cp35-cp35m/bin/python -m pip install cython==0.27.3 wheel
 /opt/python/cp36-cp36m/bin/python -m pip install cython==0.27.3 wheel
+/opt/python/cp37-cp37m/bin/python -m pip install cython==0.27.3 wheel
 
 # Build the wheels
 pushd /data
@@ -25,3 +26,6 @@ auditwheel repair dist/uamqp-${UAMQP_VERSION}-cp35-cp35m-linux_i686.whl
 
 /opt/python/cp36-cp36m/bin/python setup.py bdist_wheel
 auditwheel repair dist/uamqp-${UAMQP_VERSION}-cp36-cp36m-linux_i686.whl
+
+/opt/python/cp37-cp37m/bin/python setup.py bdist_wheel
+auditwheel repair dist/uamqp-${UAMQP_VERSION}-cp37-cp37m-linux_i686.whl

build_many_linux_64bit.sh

@@ -14,6 +14,7 @@ export OPENSSL_ROOT_DIR="/opt/pyca/cryptography/openssl"
 /opt/python/cp34-cp34m/bin/python -m pip install cython==0.27.3 wheel
 /opt/python/cp35-cp35m/bin/python -m pip install cython==0.27.3 wheel
 /opt/python/cp36-cp36m/bin/python -m pip install cython==0.27.3 wheel
+/opt/python/cp37-cp37m/bin/python -m pip install cython==0.27.3 wheel
 
 # Build the wheels
 pushd /data
@@ -25,3 +26,6 @@ auditwheel repair dist/uamqp-${UAMQP_VERSION}-cp35-cp35m-linux_x86_64.whl
 
 /opt/python/cp36-cp36m/bin/python setup.py bdist_wheel
 auditwheel repair dist/uamqp-${UAMQP_VERSION}-cp36-cp36m-linux_x86_64.whl
+
+/opt/python/cp37-cp37m/bin/python setup.py bdist_wheel
+auditwheel repair dist/uamqp-${UAMQP_VERSION}-cp37-cp37m-linux_x86_64.whl

build_osx.sh

@@ -13,3 +13,4 @@ export CFLAGS="-I/tmp/openssl/include"
 python3.4 setup.py bdist_wheel
 python3.5 setup.py bdist_wheel
 python3.6 setup.py bdist_wheel
+python3.7 setup.py bdist_wheel

samples/test_azure_event_hubs_receive.py

@@ -145,8 +145,8 @@ def test_event_hubs_iter_receive_sync(live_eventhub_config):
         log.info(message.annotations.get(b'x-opt-sequence-number'))
         log.info(str(message))
         count += 1
-        if count >= 100000:
-            log.info("Got {} messages. Shutting down.".format(count))
+        if count >= 10:
+            log.info("Got {} messages. Breaking.".format(count))
             message.accept()
             break
     count = 0

samples/test_azure_event_hubs_receive_async.py

@@ -80,10 +80,24 @@ async def test_event_hubs_iter_receive_async(live_eventhub_config):
         live_eventhub_config['consumer_group'],
         live_eventhub_config['partition'])
 
-    receive_client = uamqp.ReceiveClientAsync(source, debug=False, auth=sas_auth, timeout=10, prefetch=10)
-    async for message in receive_client.receive_messages_iter_async():
-        annotations = message.annotations
-        log.info("Sequence Number: {}".format(annotations.get(b'x-opt-sequence-number')))
+    receive_client = uamqp.ReceiveClientAsync(source, debug=False, auth=sas_auth, timeout=1000, prefetch=10)
+    count = 0
+    message_generator = receive_client.receive_messages_iter_async()
+    async for message in message_generator:
+        log.info("No. {} : {}".format(message.annotations.get(b'x-opt-sequence-number'), message))
+        count += 1
+        if count >= 10:
+            log.info("Got {} messages. Breaking.".format(count))
+            message.accept()
+            break
+    count = 0
+    async for message in message_generator:
+        count += 1
+        if count >= 10:
+            log.info("Got {} more messages. Shutting down.".format(count))
+            message.accept()
+            break
+    await receive_client.close_async()
 
 
 @pytest.mark.asyncio