缅甸赌场腾龙娱乐游戏链接 xs10159.com
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; }
页:
[1]