Commit 9d3c89c6 authored by Savorboard's avatar Savorboard

Fix code readability

parent 2001c1dc
...@@ -93,7 +93,7 @@ namespace DotNetCore.CAP.RabbitMQ ...@@ -93,7 +93,7 @@ namespace DotNetCore.CAP.RabbitMQ
_connection = _connectionChannelPool.GetConnection(); _connection = _connectionChannelPool.GetConnection();
_channel = _connection.CreateModel(); _channel = _connection.CreateModel();
_channel.ExchangeDeclare( _channel.ExchangeDeclare(
_exchangeName, _exchangeName,
RabbitMQOptions.ExchangeType, RabbitMQOptions.ExchangeType,
...@@ -103,7 +103,7 @@ namespace DotNetCore.CAP.RabbitMQ ...@@ -103,7 +103,7 @@ namespace DotNetCore.CAP.RabbitMQ
{ {
{"x-message-ttl", _rabbitMQOptions.QueueMessageExpires} {"x-message-ttl", _rabbitMQOptions.QueueMessageExpires}
}; };
_channel.QueueDeclare(_queueName, durable: true, exclusive: false, autoDelete: false, arguments); _channel.QueueDeclare(_queueName, durable: true, exclusive: false, autoDelete: false, arguments: arguments);
} }
#region events #region events
...@@ -155,7 +155,7 @@ namespace DotNetCore.CAP.RabbitMQ ...@@ -155,7 +155,7 @@ namespace DotNetCore.CAP.RabbitMQ
var args = new LogMessageEventArgs var args = new LogMessageEventArgs
{ {
LogType = MqLogType.ConsumerShutdown, LogType = MqLogType.ConsumerShutdown,
Reason = e.ReplyText Reason = e.ReplyText
}; };
OnLog?.Invoke(sender, args); OnLog?.Invoke(sender, args);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment