Как я могу опубликовать 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();
}