themplement在序列化之前的额外步骤,并从魔术集合中获取令人垂涎的主题名称。
public class AddTempKafkaHeaderStep : IOutgoingStep
{
public async Task Process(OutgoingStepContext context, Func<Task> next)
{
var message = context.Load<Message>();
var destinationAddress = context.Load<Pipeline.Send.DestinationAddresses>()?.FirstOrDefault();
...
}
}