in src/Proton/Codec/Encoders/Messaging/PropertiesTypeEncoder.cs [41:114]
protected override void WriteElement(Properties properties, int index, IProtonBuffer buffer, IEncoderState state)
{
// When encoding ensure that values that were never set are omitted and a simple
// NULL entry is written in the slot instead (don't write defaults).
switch (index)
{
case 0:
state.Encoder.WriteObject(buffer, state, properties.MessageId);
break;
case 1:
state.Encoder.WriteBinary(buffer, state, properties.UserId);
break;
case 2:
state.Encoder.WriteString(buffer, state, properties.To);
break;
case 3:
state.Encoder.WriteString(buffer, state, properties.Subject);
break;
case 4:
state.Encoder.WriteString(buffer, state, properties.ReplyTo);
break;
case 5:
state.Encoder.WriteObject(buffer, state, properties.CorrelationId);
break;
case 6:
state.Encoder.WriteSymbol(buffer, state, properties.ContentType);
break;
case 7:
state.Encoder.WriteSymbol(buffer, state, properties.ContentEncoding);
break;
case 8:
if (properties.HasAbsoluteExpiryTime())
{
state.Encoder.WriteTimestamp(buffer, state, properties.AbsoluteExpiryTime);
}
else
{
buffer.EnsureWritable(sizeof(byte));
buffer.WriteUnsignedByte((byte)EncodingCodes.Null);
}
break;
case 9:
if (properties.HasCreationTime())
{
state.Encoder.WriteTimestamp(buffer, state, properties.CreationTime);
}
else
{
buffer.EnsureWritable(sizeof(byte));
buffer.WriteUnsignedByte((byte)EncodingCodes.Null);
}
break;
case 10:
state.Encoder.WriteString(buffer, state, properties.GroupId);
break;
case 11:
if (properties.HasGroupSequence())
{
state.Encoder.WriteUnsignedInteger(buffer, state, properties.GroupSequence);
}
else
{
buffer.EnsureWritable(sizeof(byte));
buffer.WriteUnsignedByte((byte)EncodingCodes.Null);
}
break;
case 12:
state.Encoder.WriteString(buffer, state, properties.ReplyToGroupId);
break;
default:
throw new ArgumentOutOfRangeException("Unknown Properties value index: " + index);
}
}