有没有办法
以编程方式
打开登录到本地硬盘驱动器?
(例如:日志到文件C:\ temp\rabbit.log)
(目录和名称当然会改变)
换句话说,我希望能够在创建rabbit mq连接时打开(或关闭)日志记录…
背景:
rabbitmq正从我的应用程序中的引用中使用
在visual studio中,通过nuget右键单击“引用”
add reference : RabbitMQ.Client.dll (v4.0.30319)
这是我运行rabbit mq客户端的代码。
(消息处理代码已被删除)
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using RabbitMQ.Client.MessagePatterns;
private void Internal_Run(CancellationToken cancelToken)
{
var connectionFactory = new ConnectionFactory();
// I know this is wrong... but this is what I would ***like*** to do:
// connectionFactory.IsLogging = true;
// connectionFactory.LogPathAndFile = "C:\\Temp\\Rabbit.log";
connectionFactory.HostName = "My Host";
connectionFactory.UserName = "My userName";
connectionFactory.Password = "My password";
string QueueName = "My unique queue name";
try
{
using (IConnection connection = connectionFactory.CreateConnection())
{
using (IModel model = connection.CreateModel())
{
//Note declare the queue here, as well. Because we might start the receiver before the sender,
// we want to make sure the queue exists before we try to consume messages from it
model.QueueDeclare(queue: QueueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
var subscription = new Subscription(model, QueueName, false);
int milisecondTimeOut_RabbitMQ = 500;
while (true)
{
BasicDeliverEventArgs basicDeliveryEventArgs;
if (subscription.Next(milisecondTimeOut_RabbitMQ, out basicDeliveryEventArgs))
{
if (basicDeliveryEventArgs == null)
{
continue;
}
if (basicDeliveryEventArgs.Body.Length == 0)
{
continue;
}
string messageContent = Encoding.UTF8.GetString(basicDeliveryEventArgs.Body);
subscription.Ack(basicDeliveryEventArgs); // send the ACK back to queue to let Rabbit know I processed the message
}
if (cancelToken.IsCancellationRequested)
{
break;
}
}
}
}
}
catch (OperationCanceledException oce)
{
// this is an expected cancellation - program shutting down
}
catch (Exception ex)
{
throw new Exception(ex.Message);
}
}
