Transform Handler

transform-handler.cs

public class TransformHandler : MessageHandler
{
    public override async Task<Message> HandleMessage(Message sourceMessage)
    {
        var message = (Message<int, string>)sourceMessage;
        var sinkMessage = new Message<int, string>(message.Key, message.Value.ToUpper());
        return await base.HandleMessage(sinkMessage);
    }
}