Fix publishing of AMQP message to the correct exchange
This commit is contained in:
parent
4cd3a60f20
commit
50a83145a6
@ -31,7 +31,7 @@ namespace Api.AMQP
|
|||||||
|
|
||||||
string message = JsonSerializer.Serialize(deviceLimit);
|
string message = JsonSerializer.Serialize(deviceLimit);
|
||||||
var body = Encoding.UTF8.GetBytes(message);
|
var body = Encoding.UTF8.GetBytes(message);
|
||||||
await _channel.BasicPublishAsync(exchange: string.Empty, routingKey: _queue, body: body);
|
await _channel.BasicPublishAsync(exchange: _queue, routingKey: _queue, body: body);
|
||||||
|
|
||||||
|
|
||||||
// Short delay before disconnecting from rabbitMQ
|
// Short delay before disconnecting from rabbitMQ
|
||||||
|
Loading…
Reference in New Issue
Block a user