Merge pull request Azure#65 from Azure/alextolp/amqpwsaddlogs

Add logs for amqp ws tpm
CIPop · Oct 8, 2018 · 654a8cc · 654a8cc
1 parent ef85c47
commit 654a8cc
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/provisioning/transport/amqp/src/AmqpClientConnection.cs b/provisioning/transport/amqp/src/AmqpClientConnection.cs
@@ -75,7 +75,14 @@ public async Task OpenAsync(TimeSpan timeout, bool useWebSocket, X509Certificate
                     args.SetBuffer(buffer.Buffer, buffer.Offset, buffer.Length);
                     args.CompletedCallback = OnWriteHeaderComplete;
                     args.Transport = transport;
-                    transport.WriteAsync(args);
+                    bool writeAsyncResult = transport.WriteAsync(args);
+
+                    if (Logging.IsEnabled) Logging.Info(this, $"{nameof(AmqpClientConnection)}.{nameof(OpenAsync)}: Sent Protocol Header: {_sentHeader.ToString()} writeAsyncResult: {writeAsyncResult} completedSynchronously: {args.CompletedSynchronously}");
+
+                    if (args.CompletedSynchronously)
+                    {
+                        args.CompletedCallback(args);
+                    }
 
                     _tcs = new TaskCompletionSource<TransportBase>();
                     transport = await _tcs.Task.ConfigureAwait(false);