Browse Source

set exchange and queue with durable.

master
yangxiaodong 7 years ago
parent
commit
343e409508
2 changed files with 9 additions and 3 deletions
  1. +1
    -1
      src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs
  2. +8
    -2
      src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs

+ 1
- 1
src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs View File

@@ -43,7 +43,7 @@ namespace DotNetCore.CAP.RabbitMQ
{ {
var body = Encoding.UTF8.GetBytes(content); var body = Encoding.UTF8.GetBytes(content);


channel.ExchangeDeclare(_rabbitMQOptions.TopicExchangeName, RabbitMQOptions.ExchangeType);
channel.ExchangeDeclare(_rabbitMQOptions.TopicExchangeName, RabbitMQOptions.ExchangeType, durable: true);
channel.BasicPublish(exchange: _rabbitMQOptions.TopicExchangeName, channel.BasicPublish(exchange: _rabbitMQOptions.TopicExchangeName,
routingKey: keyName, routingKey: keyName,
basicProperties: null, basicProperties: null,


+ 8
- 2
src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs View File

@@ -48,12 +48,18 @@ namespace DotNetCore.CAP.RabbitMQ


_connection = _connectionFactory.CreateConnection(); _connection = _connectionFactory.CreateConnection();
_channel = _connection.CreateModel(); _channel = _connection.CreateModel();
_channel.ExchangeDeclare(exchange: _exchageName, type: RabbitMQOptions.ExchangeType);

_channel.ExchangeDeclare(
exchange: _exchageName,
type: RabbitMQOptions.ExchangeType,
durable: true);

var arguments = new Dictionary<string, object> { { "x-message-ttl", (int)_rabbitMQOptions.XMessageTTL.TotalMilliseconds } };
_channel.QueueDeclare(_queueName, _channel.QueueDeclare(_queueName,
durable: true, durable: true,
exclusive: false, exclusive: false,
autoDelete: false, autoDelete: false,
arguments: new Dictionary<string, object> { { "message-ttl", _rabbitMQOptions.XMessageTTL.TotalMilliseconds } });
arguments: arguments);
} }


public void Subscribe(IEnumerable<string> topics) public void Subscribe(IEnumerable<string> topics)


Loading…
Cancel
Save