File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
src/DotNetCore.CAP/Internal Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 11using System ;
2- using System . Linq ;
32using System . Threading . Tasks ;
43using DotNetCore . CAP . Abstractions ;
54using DotNetCore . CAP . Models ;
@@ -32,11 +31,11 @@ public async Task<OperateResult> ExecuteAsync(CapReceivedMessage receivedMessage
3231 if ( ! _selector . TryGetTopicExector ( receivedMessage . Name , receivedMessage . Group ,
3332 out var executor ) )
3433 {
35- var error = "this message can not be found subscriber. Message:" + receivedMessage ;
34+ var error = "message can not be found subscriber. Message:" + receivedMessage ;
3635 error += "\r \n see: https://github.com/dotnetcore/CAP/issues/63" ;
3736 throw new SubscriberNotFoundException ( error ) ;
3837 }
39-
38+
4039 var consumerContext = new ConsumerContext ( executor , receivedMessage . ToMessageContext ( ) ) ;
4140 try
4241 {
You can’t perform that action at this time.
0 commit comments