add queueid log

IvanZheng · IvanZheng · commit efc779989890 · 2014-01-22T00:19:54.000+08:00
diff --git a/Src/Sample/EQueueTest/log4net.config b/Src/Sample/EQueueTest/log4net.config
@@ -23,6 +23,7 @@
     <layout type="log4net.Layout.PatternLayout">
       <conversionPattern value="%date %5level %logger - %message%newline" />
     </layout>
+    <threshold value="ERROR" />
   </appender>
   <appender name="traceAppender" type="log4net.Appender.TraceAppender">
     <layout type="log4net.Layout.PatternLayout">
diff --git a/Src/iFramework.Plugins/IFramework.MessageQueue.EQueue/CommandConsumer.cs b/Src/iFramework.Plugins/IFramework.MessageQueue.EQueue/CommandConsumer.cs
@@ -11,12 +11,14 @@
 using IFramework.Infrastructure.Unity.LifetimeManagers;
 using IFramework.UnitOfWork;
 using IFramework.SysException;
+using System.Collections.Concurrent;
 
 namespace IFramework.MessageQueue.EQueue
 {
     public class CommandConsumer : MessageConsumer<MessageContext>
     {
         public static List<CommandConsumer> CommandConsumers = new List<CommandConsumer>();
+        public static ConcurrentDictionary<string, string> _handledCommandDict = new ConcurrentDictionary<string, string>();
         public static string GetConsumersStatus()
         {
             var status = string.Empty;
@@ -79,6 +81,12 @@ protected override void ConsumeMessage(MessageContext messageContext, QueueMessa
             {
                 return;
             }
+            var currentName = string.Format("consumer:{0} queueID:{1}", this.Name, queueMessage.QueueId);
+            if (!_handledCommandDict.TryAdd(messageContext.MessageID, currentName))
+            {
+                _Logger.ErrorFormat("Duplicated command [{0}] to be processed in QueueID:{1}.", messageContext.MessageID, currentName);
+            }
+
 
             _Logger.DebugFormat("Start Handle command, commandID:{0} queueID:{1}", messageContext.MessageID, queueMessage.QueueId);
             var message = messageContext.Message;

Original file line number	Diff line number	Diff line change
`@@ -11,12 +11,14 @@`
`11`	`11`	`using IFramework.Infrastructure.Unity.LifetimeManagers;`
`12`	`12`	`using IFramework.UnitOfWork;`
`13`	`13`	`using IFramework.SysException;`
	`14`	`+using System.Collections.Concurrent;`
`14`	`15`
`15`	`16`	`namespace IFramework.MessageQueue.EQueue`
`16`	`17`	`{`
`17`	`18`	`public class CommandConsumer : MessageConsumer<MessageContext>`
`18`	`19`	`{`
`19`	`20`	`public static List<CommandConsumer> CommandConsumers = new List<CommandConsumer>();`
	`21`	`+ public static ConcurrentDictionary<string, string> _handledCommandDict = new ConcurrentDictionary<string, string>();`
`20`	`22`	`public static string GetConsumersStatus()`
`21`	`23`	`{`
`22`	`24`	`var status = string.Empty;`
`@@ -79,6 +81,12 @@ protected override void ConsumeMessage(MessageContext messageContext, QueueMessa`
`79`	`81`	`{`
`80`	`82`	`return;`
`81`	`83`	`}`
	`84`	`+ var currentName = string.Format("consumer:{0} queueID:{1}", this.Name, queueMessage.QueueId);`
	`85`	`+ if (!_handledCommandDict.TryAdd(messageContext.MessageID, currentName))`
	`86`	`+ {`
	`87`	`+ _Logger.ErrorFormat("Duplicated command [{0}] to be processed in QueueID:{1}.", messageContext.MessageID, currentName);`
	`88`	`+ }`
	`89`	`+`
`82`	`90`
`83`	`91`	`_Logger.DebugFormat("Start Handle command, commandID:{0} queueID:{1}", messageContext.MessageID, queueMessage.QueueId);`
`84`	`92`	`var message = messageContext.Message;`