in src/main/csharp/MessageConsumer.cs [167:199]
private void HandleXmsMessage(IBM.XMS.IMessage xmsMessage)
{
Apache.NMS.IMessage message = XMSConvert.ToNMSMessage(xmsMessage);
if(message != null)
{
if(this.ConsumerTransformer != null)
{
IMessage newMessage = ConsumerTransformer(this.nmsSession, this, message);
if(newMessage != null)
{
message = newMessage;
}
}
if(Listener != null)
{
try
{
Listener(message);
}
catch(Exception ex)
{
Apache.NMS.Tracer.Debug("Error handling message: " + ex.Message);
}
}
else
{
this.dispatcher.Enqueue(message);
}
}
}