当为Rebus Bus实施自定义iSerialializer时,我如何获得该主题的名称,即序列化消息旨在发送到?

问题描述 投票:0回答:0

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(); ... } }

rebus rebus-kafka
最新问题
© www.soinside.com 2019 - 2025. All rights reserved.