ntminer 6 years ago
parent
commit
ee555b051c

+ 1 - 1
src/NTMinerBus/Bus/MessageDispatcher.cs

@@ -26,7 +26,7 @@
                 throw new ArgumentNullException(nameof(message));
             }
             var messageType = typeof(TMessage);
-            MessageTypeAttribute messageTypeDescription = MessageTypeAttribute.GetMessageTypeDescription(messageType);
+            MessageTypeAttribute messageTypeDescription = MessageTypeAttribute.GetMessageTypeAttribute(messageType);
             if (_handlers.ContainsKey(messageType)) {
                 var messageHandlers = _handlers[messageType].ToArray();
                 foreach (var messageHandler in messageHandlers) {

+ 9 - 9
src/NTMinerBus/Bus/MessageTypeAttribute.cs

@@ -5,22 +5,22 @@ using System.Linq;
 namespace NTMiner.Bus {
     [AttributeUsage(AttributeTargets.Class)]
     public class MessageTypeAttribute : Attribute {
-        private static readonly Dictionary<Type, MessageTypeAttribute> SMessageTypeDescriptionDic = new Dictionary<Type, MessageTypeAttribute>();
-        public static MessageTypeAttribute GetMessageTypeDescription(Type messageType) {
-            if (SMessageTypeDescriptionDic.ContainsKey(messageType)) {
-                return SMessageTypeDescriptionDic[messageType];
+        private static readonly Dictionary<Type, MessageTypeAttribute> _messageTypeAttributeDic = new Dictionary<Type, MessageTypeAttribute>();
+        public static MessageTypeAttribute GetMessageTypeAttribute(Type messageType) {
+            if (_messageTypeAttributeDic.ContainsKey(messageType)) {
+                return _messageTypeAttributeDic[messageType];
             }
             object atrrObj = messageType.GetCustomAttributes(typeof(MessageTypeAttribute), false).FirstOrDefault();
-            MessageTypeAttribute messageTypeDescription;
+            MessageTypeAttribute attr;
             if (atrrObj == null) {
-                messageTypeDescription = new MessageTypeAttribute(messageType.Name);
+                attr = new MessageTypeAttribute(messageType.Name);
             }
             else {
-                messageTypeDescription = (MessageTypeAttribute)atrrObj;
+                attr = (MessageTypeAttribute)atrrObj;
             }
-            SMessageTypeDescriptionDic.Add(messageType, messageTypeDescription);
+            _messageTypeAttributeDic.Add(messageType, attr);
 
-            return messageTypeDescription;
+            return attr;
         }
 
         public MessageTypeAttribute(string description, bool isCanNoHandler = false) {

+ 5 - 0
src/NTMinerlib/Messages.cs

@@ -139,6 +139,11 @@ namespace NTMiner {
     #endregion
 
     #region LocalMessage
+    [MessageType(description: "添加本地消息")]
+    public class AddLocalMessageCommand : AddEntityCommand<ILocalMessage> {
+        public AddLocalMessageCommand(ILocalMessage input) : base(input) { }
+    }
+
     [MessageType(description: "记录了本地事件后")]
     public class LocalMessageAddedEvent : DomainEvent<ILocalMessage> {
         public LocalMessageAddedEvent(ILocalMessage source, List<ILocalMessage> removes) : base(source) {

+ 1 - 1
src/NTMinerlib/VirtualRoot.partials.Bus.cs

@@ -27,7 +27,7 @@ namespace NTMiner {
 
         public static IMessagePathId BuildCmdPath<TCmd>(Action<TCmd> action, LogEnum logType = LogEnum.DevConsole)
             where TCmd : ICmd {
-            MessageTypeAttribute messageTypeDescription = MessageTypeAttribute.GetMessageTypeDescription(typeof(TCmd));
+            MessageTypeAttribute messageTypeDescription = MessageTypeAttribute.GetMessageTypeAttribute(typeof(TCmd));
             string description = "处理" + messageTypeDescription.Description;
             return BuildPath(description, logType, action);
         }