diff --git a/NsqSharp.Tests/Utils/Channels/ChanTest.cs b/NsqSharp.Tests/Utils/Channels/ChanTest.cs index 0d3e2f3..b07811a 100644 --- 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(); - t1.Start(); t2.Start(); + t1.Start(); Select .DebugName("SelectTwoChannels") diff --git a/NsqSharp/Bus/Logging/IMessageInformation.cs b/NsqSharp/Bus/Logging/IMessageInformation.cs index 5b322cf..97808cd 100644 --- 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 index ddc7289..351d68e 100644 --- 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 index fa4ea71..5e2c281 100644 --- 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 index ce2337a..81031b9 100644 --- a/nuget/NsqSharp.nuspec +++ b/nuget/NsqSharp.nuspec @@ -3,7 +3,7 @@ NsqSharp NsqSharp - 0.3.2 + 0.3.3 Judson White Judson White https://raw.githubusercontent.com/judwhite/NsqSharp/master/LICENSE @@ -12,7 +12,7 @@ false Client library for NSQ, a realtime distributed messaging platform. http://nsq.io Client library for NSQ, a realtime distributed messaging platform. http://nsq.io - Initial release. + Minor change: IMessageInformation.HandlerType now returns the resolved type instead of the registered interface type. Copyright 2015 nsq queue esb service bus distributed messaging