@@ -49,7 +49,7 @@ namespace DotNetCore.CAP.Kafka | |||||
catch (Exception ex) | catch (Exception ex) | ||||
{ | { | ||||
_logger.LogError( | _logger.LogError( | ||||
$"kafka topic message [{keyName}] has benn raised an exception of sending. the exception is: {ex.Message}"); | |||||
$"kafka topic message [{keyName}] has been raised an exception of sending. the exception is: {ex.Message}"); | |||||
return Task.FromResult(OperateResult.Failed(ex)); | return Task.FromResult(OperateResult.Failed(ex)); | ||||
} | } | ||||
@@ -76,7 +76,7 @@ OUTPUT DELETED.MessageId,DELETED.[MessageType];"; | |||||
} | } | ||||
} | } | ||||
// CapReceviedMessage | |||||
// CapReceivedMessage | |||||
public async Task StoreReceivedMessageAsync(CapReceivedMessage message) | public async Task StoreReceivedMessageAsync(CapReceivedMessage message) | ||||
{ | { | ||||
@@ -6,10 +6,12 @@ using System.Collections.Generic; | |||||
using System.Linq.Expressions; | using System.Linq.Expressions; | ||||
using System.Reflection; | using System.Reflection; | ||||
// ReSharper disable once CheckNamespace | |||||
namespace Microsoft.Extensions.Internal | namespace Microsoft.Extensions.Internal | ||||
{ | { | ||||
internal class ObjectMethodExecutor | internal class ObjectMethodExecutor | ||||
{ | { | ||||
// ReSharper disable once InconsistentNaming | |||||
private static readonly ConstructorInfo _objectMethodExecutorAwaitableConstructor = | private static readonly ConstructorInfo _objectMethodExecutorAwaitableConstructor = | ||||
typeof(ObjectMethodExecutorAwaitable).GetConstructor(new[] | typeof(ObjectMethodExecutorAwaitable).GetConstructor(new[] | ||||
{ | { | ||||
@@ -7,5 +7,10 @@ | |||||
public string Name { get; set; } | public string Name { get; set; } | ||||
public string Content { get; set; } | public string Content { get; set; } | ||||
public override string ToString() | |||||
{ | |||||
return $"Group:{Group}, Name:{Name}, Content:{Content}"; | |||||
} | |||||
} | } | ||||
} | } |