腾龙娱乐游戏网址【xs10159.com】

xs10111

using System.Text;using EventHorizon.RocketMQ.Grpc.Producer;public sealed class OrderPublisher(IGrpcProducer producer){    public async Task<string> PublishAsync(        string orderId,        CancellationToken cancellationToken)    {        var message = new Message("eventhorizon-test-topic", Encoding.UTF8.GetBytes(orderId))        {            Tag = "created",            MessageGroup = orderId        };        message.Keys.Add(orderId);        message.Properties["source"] = "checkout";        var receipt = await producer.SendAsync(message, cancellationToken);        return receipt.MessageId;    }