in src/main/csharp/MessageConsumer.cs [175:207]
private void HandleTibcoMsg(object sender, TIBCO.EMS.EMSMessageEventArgs arg)
{
Apache.NMS.IMessage message = EMSConvert.ToNMSMessage(arg.Message);
if(null != message)
{
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);
}
}
}