|
|
@@ -45,7 +45,7 @@ namespace DotNetCore.CAP.RabbitMQ |
|
|
|
_connection = _connectionFactory.CreateConnection(); |
|
|
|
_channel = _connection.CreateModel(); |
|
|
|
_channel.ExchangeDeclare(exchange: _exchageName, type: _rabbitMQOptions.EXCHANGE_TYPE); |
|
|
|
_channel.QueueDeclare(_queueName); |
|
|
|
_channel.QueueDeclare(_queueName, exclusive: false); |
|
|
|
} |
|
|
|
|
|
|
|
public void Listening(TimeSpan timeout) |
|
|
|