From 77de844eb10eb6798c6ca866ae32ffddd88d57c8 Mon Sep 17 00:00:00 2001 From: eeichinger Date: Fri, 12 Dec 2008 16:08:04 +0000 Subject: [PATCH] fixed typo --- .../AbstractPeekingMessageListenerContainer.cs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/Spring/Spring.Messaging/Messaging/Listener/AbstractPeekingMessageListenerContainer.cs b/src/Spring/Spring.Messaging/Messaging/Listener/AbstractPeekingMessageListenerContainer.cs index 6afc42c5..37cddd14 100644 --- a/src/Spring/Spring.Messaging/Messaging/Listener/AbstractPeekingMessageListenerContainer.cs +++ b/src/Spring/Spring.Messaging/Messaging/Listener/AbstractPeekingMessageListenerContainer.cs @@ -301,7 +301,7 @@ namespace Spring.Messaging.Listener /// called. protected virtual void ReceiveAndExecute(object state) { - bool messageRecieved = true; + bool messageReceived = true; bool listenerTimeOut = false; MessageQueue mq = state as MessageQueue; @@ -328,10 +328,10 @@ namespace Spring.Messaging.Listener #endregion DateTime expirationTime = DateTime.Now.Add(ListenerTimeLimit); - while (!listenerTimeOut && messageRecieved) + while (!listenerTimeOut && messageReceived) { //Subclasses to perform receive operation - messageRecieved = DoReceiveAndExecute(mq); + messageReceived = DoReceiveAndExecute(mq); if (ListenerTimeLimit == TimeSpan.Zero) { @@ -351,7 +351,7 @@ namespace Spring.Messaging.Listener } catch (Exception ex) { - messageRecieved = false; + messageReceived = false; LOG.Error("Error receiving message from DefaultMessageQueue = [" + mq.QueueName + "]", ex); } finally @@ -364,14 +364,14 @@ namespace Spring.Messaging.Listener { activeListenerCount--; LOG.Debug("ActiveListenerCount = " + activeListenerCount); - LOG.Trace("ListenerTimeout = " + listenerTimeOut + ", MessageRecieved = " + messageRecieved); + LOG.Trace("ListenerTimeout = " + listenerTimeOut + ", MessageRecieved = " + messageReceived); if (activeListenerCount == 0) { LOG.Debug("All processing threads ended - calling StartPeek again."); //last active worker thread needs to restart the peeking process StartPeeking(); } - else if (listenerTimeOut && messageRecieved) + else if (listenerTimeOut && messageReceived) { LOG.Debug( "Processing thread ended due to timeout and last recieve operation was successfull, calling StartPeek again.");