RabbitMqTestView.xaml.Event.cs

이 파일의 문서화 페이지로 가기

using SampleSmart.Pages.PageSub.CommunicationTabs;
 
namespace SampleSmart.Pages.PageSub.CommunicationTabs.RabbitMQ;

public sealed class RabbitMqTestViewEvent
{
    private readonly CommunicationSampleRuntime _runtime;

    public RabbitMqTestViewEvent(CommunicationSampleRuntime runtime)
    {
        _runtime = runtime ?? throw new ArgumentNullException(nameof(runtime));
 
        Host = "localhost";
        Port = 5672;
        VirtualHost = "/";
        UserName = "guest";
        Password = "guest";
        ExchangeName = "dreamine.sample.exchange";
        QueueName = "dreamine.sample.queue";
        RoutingKey = "dreamine.sample.route";
        MessageText = "test";
    }

    public string Host { get; set; }

    public int Port { get; set; }

    public string VirtualHost { get; set; }

    public string UserName { get; set; }

    public string Password { get; set; }

    public string ExchangeName { get; set; }

    public string QueueName { get; set; }

    public string RoutingKey { get; set; }

    public string MessageText { get; set; }

    public string RabbitMqSelectionSummary =>
        $"Host={Host}:{Port}, VirtualHost={VirtualHost}, Exchange={ExchangeName}, Queue={QueueName}, RoutingKey={RoutingKey}";

    public void ConnectRabbitMq()
    {
        _ = _runtime.ConnectRabbitMqAsync(
            Host,
            Port,
            VirtualHost,
            UserName,
            Password,
            ExchangeName,
            QueueName,
            RoutingKey);
    }

    public void SubscribeRabbitMq()
    {
        _ = _runtime.SubscribeRabbitMqAsync(
            ExchangeName,
            QueueName,
            RoutingKey);
    }

    public void PublishRabbitMq()
    {
        if (string.IsNullOrWhiteSpace(MessageText))
        {
            MessageText = "test";
        }
 
        _ = _runtime.PublishRabbitMqAsync(
            ExchangeName,
            RoutingKey,
            MessageText);
    }

    public void DisconnectRabbitMq()
    {
        _ = _runtime.DisconnectRabbitMqAsync();
    }
}