[KEERO-83] Windows Agent: Typo fixes + sample values in config
This commit is contained in:
parent
d141fbc4dc
commit
5873d3610b
@ -18,4 +18,13 @@
|
|||||||
<logger name="*" minlevel="Debug" writeTo="file" />
|
<logger name="*" minlevel="Debug" writeTo="file" />
|
||||||
</rules>
|
</rules>
|
||||||
</nlog>
|
</nlog>
|
||||||
|
<appSettings>
|
||||||
|
<add key="rabbitmq.host" value="localhost"/>
|
||||||
|
<add key="rabbitmq.user" value="guest"/>
|
||||||
|
<add key="rabbitmq.password" value="guest"/>
|
||||||
|
<add key="rabbitmq.vhost" value="/"/>
|
||||||
|
<add key="rabbitmq.resultExchange" value=""/>
|
||||||
|
<add key="rabbitmq.resultQueue" value="-execution-results"/>
|
||||||
|
|
||||||
|
</appSettings>
|
||||||
</configuration>
|
</configuration>
|
@ -45,9 +45,7 @@ namespace Mirantis.Keero.WindowsAgent
|
|||||||
session.QueueDeclare(queueName, true, false, false, null);
|
session.QueueDeclare(queueName, true, false, false, null);
|
||||||
var consumer = new QueueingBasicConsumer(session);
|
var consumer = new QueueingBasicConsumer(session);
|
||||||
var consumeTag = session.BasicConsume(queueName, false, consumer);
|
var consumeTag = session.BasicConsume(queueName, false, consumer);
|
||||||
Console.WriteLine("Deq");
|
|
||||||
var e = (RabbitMQ.Client.Events.BasicDeliverEventArgs)consumer.Queue.Dequeue();
|
var e = (RabbitMQ.Client.Events.BasicDeliverEventArgs)consumer.Queue.Dequeue();
|
||||||
Console.WriteLine("Message received");
|
|
||||||
Action ackFunc = delegate {
|
Action ackFunc = delegate {
|
||||||
session.BasicAck(e.DeliveryTag, false);
|
session.BasicAck(e.DeliveryTag, false);
|
||||||
session.BasicCancel(consumeTag);
|
session.BasicCancel(consumeTag);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user