70 lines
1.9 KiB
C#
70 lines
1.9 KiB
C#
using System;
|
|
|
|
namespace Svrnty.CQRS.Sagas.RabbitMQ;
|
|
|
|
/// <summary>
|
|
/// Configuration options for RabbitMQ saga transport.
|
|
/// </summary>
|
|
public class RabbitMqSagaOptions
|
|
{
|
|
/// <summary>
|
|
/// RabbitMQ host name (default: localhost).
|
|
/// </summary>
|
|
public string HostName { get; set; } = "localhost";
|
|
|
|
/// <summary>
|
|
/// RabbitMQ port (default: 5672).
|
|
/// </summary>
|
|
public int Port { get; set; } = 5672;
|
|
|
|
/// <summary>
|
|
/// RabbitMQ user name (default: guest).
|
|
/// </summary>
|
|
public string UserName { get; set; } = "guest";
|
|
|
|
/// <summary>
|
|
/// RabbitMQ password (default: guest).
|
|
/// </summary>
|
|
public string Password { get; set; } = "guest";
|
|
|
|
/// <summary>
|
|
/// RabbitMQ virtual host (default: /).
|
|
/// </summary>
|
|
public string VirtualHost { get; set; } = "/";
|
|
|
|
/// <summary>
|
|
/// Exchange name for saga commands (default: svrnty.sagas.commands).
|
|
/// </summary>
|
|
public string CommandExchange { get; set; } = "svrnty.sagas.commands";
|
|
|
|
/// <summary>
|
|
/// Exchange name for saga responses (default: svrnty.sagas.responses).
|
|
/// </summary>
|
|
public string ResponseExchange { get; set; } = "svrnty.sagas.responses";
|
|
|
|
/// <summary>
|
|
/// Queue name prefix for this service (default: saga-service).
|
|
/// </summary>
|
|
public string QueuePrefix { get; set; } = "saga-service";
|
|
|
|
/// <summary>
|
|
/// Whether to use durable queues (default: true).
|
|
/// </summary>
|
|
public bool DurableQueues { get; set; } = true;
|
|
|
|
/// <summary>
|
|
/// Prefetch count for consumers (default: 10).
|
|
/// </summary>
|
|
public ushort PrefetchCount { get; set; } = 10;
|
|
|
|
/// <summary>
|
|
/// Connection retry delay (default: 5 seconds).
|
|
/// </summary>
|
|
public TimeSpan ConnectionRetryDelay { get; set; } = TimeSpan.FromSeconds(5);
|
|
|
|
/// <summary>
|
|
/// Maximum connection retry attempts (default: 10).
|
|
/// </summary>
|
|
public int MaxConnectionRetries { get; set; } = 10;
|
|
}
|