quickstarts/pub_sub/csharp/sdk/checkout/Program.cs

18 lines
535 B
C#

using System;
using Dapr.Client;
using System.Text.Json.Serialization;
using System.Threading.Tasks;
for (int i = 1; i <= 10; i++) {
var order = new Order(i);
using var client = new DaprClientBuilder().Build();
// Publish an event/message using Dapr PubSub
await client.PublishEventAsync("orderpubsub", "orders", order);
Console.WriteLine("Published data: " + order);
await Task.Delay(TimeSpan.FromSeconds(1));
}
public record Order([property: JsonPropertyName("orderId")] int OrderId);