RawRabbit Publi sh сообщение - PullRequest
       11

RawRabbit Publi sh сообщение

0 голосов
/ 19 марта 2020

Как я могу опубликовать sh и получить сообщение, которое я пробовал, как этот код ниже, он создает очередь и обменивается, но в мое приложение не поступает никаких сообщений? Что я делаю не так?

    //Publisher
    public static IBusClient GetBusClient()
            {
                var config = new RawRabbitConfiguration
                {
                    Hostnames = { "localhost" },
                    Port = 5672,
                    VirtualHost = "/",
                    Username = "guest",
                    Password = "guest"
                };
                var client = BusClientFactory.CreateDefault(config);
                return client;
            } 
            static  void Main(string[] args)
            {
                string message = "Hello World";
                const string EXCHANGE_NAME = "myRabbit";
                Action<IPublishConfigurationBuilder> x = (ctx) => ctx.WithExchange(x => x.WithName(EXCHANGE_NAME));
                var _bus = GetBusClient();
                 _bus.PublishAsync(new BasicMessage { Message = message }, Guid.NewGuid(), x);
            }

//Subscribber
        public static void Main(string[] args)
        {

            var bus = GetBusClient();
            bus.SubscribeAsync<SubMsg>(async (msg, context) =>
            {
                Console.WriteLine($"{msg.Message}.");
                await Task.FromResult(true);
            }, ctx => ctx.WithExchange(x => x.WithName("myRabbit").WithAutoDelete(false).WithDurability(true)).WithQueue(x => x.WithName("myConsole").WithExclusivity(false).WithDurability(true).WithAutoDelete(false)));
            Console.ReadLine();
        }
...