in src/main/csharp/Protocol/StompWireFormat.cs [90:141]
public void Marshal(Object o, BinaryWriter dataOut)
{
Tracer.Debug("StompWireFormat - Marshaling: " + o);
if(o is ConnectionInfo)
{
WriteConnectionInfo((ConnectionInfo) o, dataOut);
}
else if(o is Message)
{
WriteMessage((Message) o, dataOut);
}
else if(o is ConsumerInfo)
{
WriteConsumerInfo((ConsumerInfo) o, dataOut);
}
else if(o is MessageAck)
{
WriteMessageAck((MessageAck) o, dataOut);
}
else if(o is TransactionInfo)
{
WriteTransactionInfo((TransactionInfo) o, dataOut);
}
else if(o is ShutdownInfo)
{
WriteShutdownInfo((ShutdownInfo) o, dataOut);
}
else if(o is RemoveInfo)
{
WriteRemoveInfo((RemoveInfo) o, dataOut);
}
else if(o is KeepAliveInfo)
{
WriteKeepAliveInfo((KeepAliveInfo) o, dataOut);
}
else if(o is Command)
{
Command command = o as Command;
if(command.ResponseRequired)
{
Response response = new Response();
response.CorrelationId = command.CommandId;
SendCommand(response);
Tracer.Debug("StompWireFormat - Autorespond to command: " + o.GetType());
}
}
else
{
Tracer.Debug("StompWireFormat - Ignored command: " + o.GetType());
}
}