Как разделить демонстрацию MassTransit на приложения производителя и потребителя - PullRequest
Новая
       6

Как разделить демонстрацию MassTransit на приложения производителя и потребителя

1 голос
/ 05 апреля 2019

Я пытаюсь разделить демонстрацию MassTransit (https://masstransit -project.com / MassTransit / quickstart.html ) на два отдельных приложения, но мое потребительское приложение не получает никаких сообщений.

Я создал 3 проекта: Send, Receive и Messages. Send содержит класс Send, который является моим кодом производителя, Receive содержит класс Receive, который является моим кодом потребителя, а Messages содержит классы для моих сообщений.

Вот мой Send класс: 

using MassTransit;
using Messages;
using System;

namespace MassTransitTest
{
    class Send
    {
        static void Main(string[] args)
        {
            var bus = Bus.Factory.CreateUsingRabbitMq(config =>
            {
                var host = config.Host(new Uri("rabbitmq://localhost"), c =>
                {
                    c.Username("guest");
                    c.Password("guest");
                });
            });

            bus.Start();

            Console.WriteLine("Publishing message");

            bus.Publish(new TextMessage() { Text = "Testing 12345" });

            bus.Stop();

            Console.ReadLine();
        }
    }
}

вот мой Receive класс: 

using MassTransit;
using Messages;
using System;

namespace Receive
{
    class Receive
    {
        static void Main(string[] args)
        {
            var bus = Bus.Factory.CreateUsingRabbitMq(config =>
            {
                var host = config.Host(new Uri("rabbitmq://localhost"), c =>
                {
                    c.Username("guest");
                    c.Password("guest");
                });

                config.ReceiveEndpoint(host, "queue", endpoint =>
                {
                    endpoint.Handler<TextMessage>(context =>
                    {
                        return Console.Out.WriteLineAsync($"{context.Message.Text}");
                    });
                });
            });

            bus.Start();

            Console.WriteLine("Receive listening for messages");

            Console.ReadLine();

            bus.Stop();
        }
    }
}

Наконец, вот мой TextMessage класс: 

using System;

namespace Messages
{
    public class TextMessage
    {
        public string Text { get; set; }
    }
}

Когда я отправляю сообщение из моего Send класса, я хотел бы получить его и вывести на консоль из моего Receive класса.

1 Ответ

1 голос
/ 07 апреля 2019

Я понял это!Publish - это асинхронное сообщение, которое возвращает Task, поэтому мне нужно было await, и тогда все заработало.Моя программа Send закрывалась до того, как сообщение было сработано.

...