in src/main/csharp/DefaultMessageConverter.cs [355:424]
protected virtual BaseMessage CreateNmsMessage(Message message,
bool convertBody)
{
BaseMessage result = null;
if((int) NMSMessageType.TextMessage == message.AppSpecific)
{
TextMessage textMessage = new TextMessage();
if(convertBody)
{
ConvertTextMessageBodyToNMS(message, textMessage);
}
result = textMessage;
}
else if((int) NMSMessageType.BytesMessage == message.AppSpecific)
{
BytesMessage bytesMessage = new BytesMessage();
if(convertBody)
{
ConvertBytesMessageBodyToNMS(message, bytesMessage);
}
result = bytesMessage;
}
else if((int) NMSMessageType.ObjectMessage == message.AppSpecific)
{
ObjectMessage objectMessage = new ObjectMessage();
if(convertBody)
{
ConvertObjectMessageBodyToNMS(message, objectMessage);
}
result = objectMessage;
}
else if((int) NMSMessageType.MapMessage == message.AppSpecific)
{
MapMessage mapMessage = new MapMessage();
if(convertBody)
{
ConvertMapMessageBodyToNMS(message, mapMessage);
}
result = mapMessage;
}
else if((int) NMSMessageType.StreamMessage == message.AppSpecific)
{
StreamMessage streamMessage = new StreamMessage();
if(convertBody)
{
ConvertStreamMessageBodyToNMS(message, streamMessage);
}
result = streamMessage;
}
else
{
BaseMessage baseMessage = new BaseMessage();
result = baseMessage;
}
result.ReadOnlyBody = true;
return result;
}