IMessageInformation.HandlerType now returns the resolved type instead…

… of the registered interface type.
judwhite · Apr 1, 2015 · dab065b · dab065b
1 parent e56e1b6
commit dab065b
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 11 deletions.
diff --git a/NsqSharp.Tests/Utils/Channels/ChanTest.cs b/NsqSharp.Tests/Utils/Channels/ChanTest.cs
@@ -134,8 +134,8 @@ public void SelectTwoChannels()
 
             var list = new List<int>();
 
-            t1.Start();
             t2.Start();
+            t1.Start();
 
             Select
                 .DebugName("SelectTwoChannels")

diff --git a/NsqSharp/Bus/Logging/IMessageInformation.cs b/NsqSharp/Bus/Logging/IMessageInformation.cs
@@ -14,8 +14,6 @@ internal class MessageInformation : IMessageInformation, ICurrentMessageInformat
         public object DeserializedMessageBody { get; set; }
         public DateTime Started { get; set; }
         public DateTime? Finished { get; set; }
-        public bool BackoffTriggered { get; set; }
-        public DateTime? RequeuedUntil { get; set; }
     }
 
     internal class FailedMessageInformation : IFailedMessageInformation

diff --git a/NsqSharp/Bus/MessageDistributor.cs b/NsqSharp/Bus/MessageDistributor.cs
@@ -96,6 +96,7 @@ public void HandleMessage(Message message)
                 try
                 {
                     handler = _objectBuilder.GetInstance(_handlerType);
+                    messageInformation.HandlerType = handler.GetType();
                 }
                 catch (Exception ex)
                 {
@@ -158,9 +159,6 @@ public void HandleMessage(Message message)
                     else
                         message.Finish();
 
-                    messageInformation.BackoffTriggered = message.BackoffTriggered;
-                    messageInformation.RequeuedUntil = message.RequeuedUntil;
-
                     _messageAuditor.TryOnFailed(_logger, _bus,
                         new FailedMessageInformation
                         (
@@ -175,8 +173,6 @@ public void HandleMessage(Message message)
                 }
 
                 messageInformation.Finished = DateTime.UtcNow;
-                messageInformation.BackoffTriggered = message.BackoffTriggered;
-                messageInformation.RequeuedUntil = message.RequeuedUntil;
 
                 _messageAuditor.TryOnSucceeded(_logger, _bus, messageInformation);
             }

diff --git a/NsqSharp/Properties/AssemblyInfo.cs b/NsqSharp/Properties/AssemblyInfo.cs
@@ -31,4 +31,4 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("0.3.2")]
+[assembly: AssemblyVersion("0.3.3")]
diff --git a/nuget/NsqSharp.nuspec b/nuget/NsqSharp.nuspec
@@ -3,7 +3,7 @@
   <metadata>
     <id>NsqSharp</id>
     <title>NsqSharp</title>
-    <version>0.3.2</version>
+    <version>0.3.3</version>
     <authors>Judson White</authors>
     <owners>Judson White</owners>
     <licenseUrl>https://raw.githubusercontent.com/judwhite/NsqSharp/master/LICENSE</licenseUrl>
@@ -12,7 +12,7 @@
     <requireLicenseAcceptance>false</requireLicenseAcceptance>
     <description>Client library for NSQ, a realtime distributed messaging platform. http://nsq.io</description>
     <summary>Client library for NSQ, a realtime distributed messaging platform. http://nsq.io</summary>
-    <releaseNotes>Initial release.</releaseNotes>
+    <releaseNotes>Minor change: IMessageInformation.HandlerType now returns the resolved type instead of the registered interface type.</releaseNotes>
     <copyright>Copyright 2015</copyright>
     <tags>nsq queue esb service bus distributed messaging</tags>
   </metadata>