From d029b6c30db679e1b83b839fca866f164094af3b Mon Sep 17 00:00:00 2001 From: mHalo Date: Thu, 6 Aug 2020 12:53:04 +0800 Subject: [PATCH] fixed #622 #624 (#625) --- src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs | 2 +- src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs b/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs index 9cae360..ed5ee54 100644 --- a/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs +++ b/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs @@ -108,8 +108,8 @@ namespace DotNetCore.CAP.PostgreSql { Id = reader.GetInt64(index++), Version = reader.GetString(index++), - Group = queryDto.MessageType == MessageType.Subscribe ? reader.GetString(index++) : default, Name = reader.GetString(index++), + Group = queryDto.MessageType == MessageType.Subscribe ? reader.GetString(index++) : default, Content = reader.GetString(index++), Retries = reader.GetInt32(index++), Added = reader.GetDateTime(index++), diff --git a/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs b/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs index f8e278c..eedf675 100644 --- a/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs +++ b/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs @@ -125,7 +125,7 @@ namespace DotNetCore.CAP.Internal // Ignore partial attributes when no topic attribute is defined on class. if (topicClassAttribute is null) { - topicMethodAttributes = topicMethodAttributes.Where(x => x.IsPartial); + topicMethodAttributes = topicMethodAttributes.Where(x => !x.IsPartial); } if (!topicMethodAttributes.Any())