Kind of live test

Author: fafhrd91

sdk/eventhub/azure-eventhub/tests/pyamqp_tests/synctests/test_send_receive_pyamqp.py

@@ -8,6 +8,7 @@
 from azure.eventhub._pyamqp import authentication, ReceiveClient, SendClient
 from azure.eventhub._pyamqp.constants import TransportType
 from azure.eventhub._pyamqp.message import Message
+from azure.eventhub._pyamqp._encode import encode_described
 
 
 def send_message(live_eventhub):
@@ -54,3 +55,43 @@ def test_event_hubs_client_amqp(live_eventhub):
     ) as receive_client:
         messages = receive_client.receive_message_batch(max_batch_size=1)
         assert len(messages) > 0
+
+
+def test_described(live_eventhub):
+    uri = "sb://{}/{}".format(live_eventhub["hostname"], live_eventhub["event_hub"])
+    sas_auth = authentication.SASTokenAuth(
+        uri=uri, audience=uri, username=live_eventhub["key_name"], password=live_eventhub["access_key"]
+    )
+
+    target = "amqps://{}/{}/Partitions/{}".format(
+        live_eventhub["hostname"], live_eventhub["event_hub"], live_eventhub["partition"]
+    )
+
+    out = bytearray();
+    encode_described(out, (12345, "TEST"))
+
+    message = Message(value=out)
+
+    with SendClient(
+            live_eventhub["hostname"], target, auth=sas_auth, debug=True, transport_type=TransportType.Amqp
+    ) as send_client:
+        send_client.send_message(message)
+
+    source = "amqps://{}/{}/ConsumerGroups/{}/Partitions/{}".format(
+        live_eventhub["hostname"],
+        live_eventhub["event_hub"],
+        live_eventhub["consumer_group"],
+        live_eventhub["partition"],
+    )
+
+    with ReceiveClient(
+            live_eventhub["hostname"],
+            source,
+            auth=sas_auth,
+            debug=False,
+            timeout=500,
+            prefetch=1,
+            transport_type=TransportType.Amqp,
+    ) as receive_client:
+        messages = receive_client.receive_message_batch(max_batch_size=1)
+        assert len(messages) > 0