diff --git a/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/ConnectionReauthenticator.cs b/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/ConnectionReauthenticator.cs index 481b8c481e7..54b4089b4d9 100644 --- a/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/ConnectionReauthenticator.cs +++ b/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/ConnectionReauthenticator.cs @@ -74,11 +74,12 @@ async void ReauthenticateConnections(object sender, ElapsedEventArgs elapsedEven Option clientCredentials = await this.credentialsCache.Get(identity); bool result = await clientCredentials .Map( - async c => + c => { - bool authRes = await this.authenticator.ReauthenticateAsync(c); - Events.ClientCredentialsResult(identity, authRes); - return authRes; + Console.WriteLine("Returning false for all clients."); + // bool authRes = await this.authenticator.ReauthenticateAsync(c); + // Events.ClientCredentialsResult(identity, authRes); + return Task.FromResult(false); }) .GetOrElse( () => diff --git a/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/device/DeviceMessageHandler.cs b/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/device/DeviceMessageHandler.cs index eac51d8b59d..98fd021c23e 100644 --- a/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/device/DeviceMessageHandler.cs +++ b/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Core/device/DeviceMessageHandler.cs @@ -522,9 +522,18 @@ public async Task InvokeMethodAsync(DirectMethodRequest re return await taskCompletion.Task; } - public Task OnDesiredPropertyUpdates(IMessage twinUpdates) => this.underlyingProxy.OnDesiredPropertyUpdates(twinUpdates); + public Task OnDesiredPropertyUpdates(IMessage twinUpdates) + { + Console.WriteLine("OnDesiredPropertyUpdates StackTrace: '{0}'", Environment.StackTrace); + return this.underlyingProxy.OnDesiredPropertyUpdates(twinUpdates); + } - public Task SendTwinUpdate(IMessage twin) => this.underlyingProxy.SendTwinUpdate(twin); + public Task SendTwinUpdate(IMessage twin) + { + // print stack trace here + Console.WriteLine("SendTwinUpdate StackTrace: '{0}'", Environment.StackTrace); + return this.underlyingProxy.SendTwinUpdate(twin); + } public Task CloseAsync(Exception ex) => this.underlyingProxy.CloseAsync(ex);