Skip to content

Commit

Permalink
Merge pull request #179 from dstockhammer/master
Browse files Browse the repository at this point in the history
Increase log level for "stopping receiving messages from queue" log...
  • Loading branch information
iancooper committed Apr 6, 2016
2 parents a0de108 + 44100d8 commit 651d381
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions Brighter/paramore.brighter.serviceactivator/MessagePump.cs
Original file line number Diff line number Diff line change
Expand Up @@ -172,7 +172,7 @@ public void Run()
}
catch (ConfigurationException configurationException)
{
if (Logger != null) Logger.DebugException("MessagePump: Stopping receiving of messages from {1} on thread # {0}", configurationException, Thread.CurrentThread.ManagedThreadId, Channel.Name);
if (Logger != null) Logger.ErrorException("MessagePump: Stopping receiving of messages from {1} on thread # {0}", configurationException, Thread.CurrentThread.ManagedThreadId, Channel.Name);

RejectMessage(message);
Channel.Dispose();
Expand Down Expand Up @@ -275,7 +275,7 @@ private Tuple<bool, bool> HandleProcessingException(AggregateException aggregate

if (exception is ConfigurationException)
{
if (Logger != null) Logger.DebugException("MessagePump: Stopping receiving of messages from {1} on thread # {0}", exception, Thread.CurrentThread.ManagedThreadId, Channel.Name);
if (Logger != null) Logger.ErrorException("MessagePump: Stopping receiving of messages from {1} on thread # {0}", exception, Thread.CurrentThread.ManagedThreadId, Channel.Name);
stop = true;
break;
}
Expand All @@ -294,7 +294,7 @@ private void IncrementUnacceptableMessageLimit()

private void RejectMessage(Message message)
{
if (Logger != null) Logger.DebugFormat("MessagePump: Rejecting message {0} from {2} on thread # {1}", message.Id, Thread.CurrentThread.ManagedThreadId, Channel.Name);
if (Logger != null) Logger.InfoFormat("MessagePump: Rejecting message {0} from {2} on thread # {1}", message.Id, Thread.CurrentThread.ManagedThreadId, Channel.Name);

Channel.Reject(message);
}
Expand Down

0 comments on commit 651d381

Please sign in to comment.