私はEasyNetQとRabbitMQを初めて使っています。残念ながら私はメッセージの消費に問題があり、私が間違った出版をしているか、消費が正しくないかどうかはわかりません。私は公開することによって見ることができます、それはキューに送信し、それを消費することは、キューからそれを取るものです。消費のためにEasyNetQは発行し、消費します
public void send(RegistrationCreatedEvent obj)
{
MessageBus.Publish(Exchange, RoutingKey, true, new Message<RegistrationCreatedEvent>(obj));
}
コードスニペット::私は出版のためのIAdvancedBus
コードスニペットを使用していますS :
public void Receive()
{
MessageBus.Consume(Queue, (messageBody, properties, info) => Task.Factory.StartNew(() =>
{
var stringMessage = Encoding.Default.GetString(messageBody);
json = JsonConvert.DeserializeObject<RegistrationCreatedEvent>(stringMessage);
Console.WriteLine($"Message Received: {json}");
}));
}