From 01866e01faf055c7cbf6eca9d49be8500b44ddd2 Mon Sep 17 00:00:00 2001 From: Savorboard Date: Wed, 22 Nov 2017 16:05:31 +0800 Subject: [PATCH] modify ascension --- src/DotNetCore.CAP/Internal/ISubscriberExecutor.Default.cs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/DotNetCore.CAP/Internal/ISubscriberExecutor.Default.cs b/src/DotNetCore.CAP/Internal/ISubscriberExecutor.Default.cs index cbe7bf1..ca13a7f 100644 --- a/src/DotNetCore.CAP/Internal/ISubscriberExecutor.Default.cs +++ b/src/DotNetCore.CAP/Internal/ISubscriberExecutor.Default.cs @@ -1,5 +1,4 @@ using System; -using System.Linq; using System.Threading.Tasks; using DotNetCore.CAP.Abstractions; using DotNetCore.CAP.Models; @@ -32,11 +31,11 @@ namespace DotNetCore.CAP.Internal if (!_selector.TryGetTopicExector(receivedMessage.Name, receivedMessage.Group, out var executor)) { - var error = "this message can not be found subscriber. Message:" + receivedMessage; + var error = "message can not be found subscriber. Message:" + receivedMessage; error += "\r\n see: https://github.com/dotnetcore/CAP/issues/63"; throw new SubscriberNotFoundException(error); } - + var consumerContext = new ConsumerContext(executor, receivedMessage.ToMessageContext()); try {