From ecdbc801a319aaf9816ab6cc34e69532fc9d3a3a Mon Sep 17 00:00:00 2001 From: Menno van Lavieren Date: Mon, 10 Jul 2017 13:13:04 +0200 Subject: [PATCH] Bug fix in setup nested contexts, Controller was invoked from the outer context --- Tapeti/Connection/TapetiConsumer.cs | 2 +- Tapeti/TapetiConfig.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Tapeti/Connection/TapetiConsumer.cs b/Tapeti/Connection/TapetiConsumer.cs index e55b024..57c31f2 100644 --- a/Tapeti/Connection/TapetiConsumer.cs +++ b/Tapeti/Connection/TapetiConsumer.cs @@ -133,7 +133,7 @@ namespace Tapeti.Connection addHandler(async (c, next) => { - await binding.Invoke(context, message); + await binding.Invoke(c, message); }); firstCaller.Call(context) diff --git a/Tapeti/TapetiConfig.cs b/Tapeti/TapetiConfig.cs index 32f5907..078e3c5 100644 --- a/Tapeti/TapetiConfig.cs +++ b/Tapeti/TapetiConfig.cs @@ -111,7 +111,7 @@ namespace Tapeti else if (middleware is IPublishMiddleware) Use((IPublishMiddleware)middleware); else - throw new ArgumentException($"Unsupported middleware implementation: {middleware.GetType().Name}"); + throw new ArgumentException($"Unsupported middleware implementation: {(middleware == null ? "null" : middleware.GetType().Name)}"); } }