in src/main/csharp/MessageProducer.cs [113:137]
public void Send(Apache.NMS.IDestination destination, Apache.NMS.IMessage message)
{
Apache.NMS.EMS.Destination dest = (Apache.NMS.EMS.Destination) destination;
Apache.NMS.EMS.Message msg = GetEMSMessage(message);
long timeToLive = (long) message.NMSTimeToLive.TotalMilliseconds;
if(0 == timeToLive)
{
timeToLive = this.tibcoMessageProducer.TimeToLive;
}
try
{
this.tibcoMessageProducer.Send(
dest.tibcoDestination,
msg.tibcoMessage,
this.tibcoMessageProducer.MsgDeliveryMode,
this.tibcoMessageProducer.Priority,
timeToLive);
}
catch(Exception ex)
{
ExceptionUtil.WrapAndThrowNMSException(ex);
}
}