Quartz 4

185_Publishing

1 min read

Publishing

Configuring subscriptions through Amazon SQS queues is done with the ToSqsQueue() extension method shown in the example below:

var host = await Host.CreateDefaultBuilder()
    .UseWolverine(opts =>
    {
        opts.UseAmazonSqsTransport();
 
        opts.PublishMessage<Message1>()
            .ToSqsQueue("outbound1")
 
            // Increase the outgoing message throughput, but at the cost
            // of strict ordering
            .MessageBatchMaxDegreeOfParallelism(Environment.ProcessorCount);
 
        opts.PublishMessage<Message2>()
            .ToSqsQueue("outbound2").ConfigureQueueCreation(request =>
            {
                request.Attributes[QueueAttributeName.MaximumMessageSize] = "1024";
            });
    }).StartAsync();

snippet source | anchor

url: /guide/durability/efcore/domain-events.md

Graph View