Skip to content
Permalink
Browse files
Apply a fix to the session executor that was found in NMS.ActiveMQ
  • Loading branch information
Timothy A. Bish committed Nov 5, 2010
1 parent a8222a8 commit 65be62f38391b17d44bc950b3389e2dfa020838a
Showing 1 changed file with 6 additions and 7 deletions.
@@ -126,15 +126,14 @@ public void Dispatch(MessageDispatch dispatch)
{
consumer = this.consumers[dispatch.ConsumerId] as MessageConsumer;
}

// If the consumer is not available, just ignore the message.
// Otherwise, dispatch the message to the consumer.
if(consumer != null)
{
consumer.Dispatch(dispatch);
}
}

// If the consumer is not available, just ignore the message.
// Otherwise, dispatch the message to the consumer.
if(consumer != null)
{
consumer.Dispatch(dispatch);
}
}
catch(Exception ex)
{

0 comments on commit 65be62f

Please sign in to comment.