8000 dotnet: noAck -> autoAck · CodingCreeks/rabbitmq-tutorials@9b839f4 · GitHub
[go: up one dir, main page]
Skip to content

Commit 9b839f4

Browse files
kjnilssonkjnilsson
committed
dotnet: noAck -> autoAck
1 parent 6dac939 commit 9b839f4

File tree

16 files changed

+36
-29
lines changed

16 files changed

+36
-29
lines changed

‎.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@ java*/.idea/workspace.xml
2020
java*/.idea/encodings.xml
2121
*~
2222

23+
project.lock.json
24+
2325
.vscode/
2426
obj/
2527
bin/

‎dotnet-visual-studio/1_Receive/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ public static void Main()
2222
var message = Encoding.UTF8.GetString(body);
2323
Console.WriteLine(" [x] Received {0}", message);
2424
};
25-
channel.BasicConsume(queue: "hello", noAck: true, consumer: consumer);
25+
channel.BasicConsume(queue: "hello", autoAck: true, consumer: consumer);
2626

2727
Console.WriteLine(" Press [enter] to exit.");
2828
Console.ReadLine();

‎dotnet-visual-studio/2_Worker/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public static void Main()
3232

3333
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
3434
};
35-
channel.BasicConsume(queue: "task_queue", noAck: false, consumer: consumer);
35+
channel.BasicConsume(queue: "task_queue", autoAck: false, consumer: consumer);
3636

3737
Console.WriteLine(" Press [enter] to exit.");
3838
Console.ReadLine();

‎dotnet-visual-studio/3_ReceiveLogs/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public static void Main()
2323
var message = Encoding.UTF8.GetString(body);
2424
Console.WriteLine(" [x] {0}", message);
2525
};
26-
channel.BasicConsume(queue: queueName, noAck: true, consumer: consumer);
26+
channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);
2727

2828
Console.WriteLine(" Press [enter] to exit.");
2929
Console.ReadLine();

‎dotnet-visual-studio/4_ReceiveLogsDirect/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public static void Main(string[] args)
3838
var routingKey = ea.RoutingKey;
3939
Console.WriteLine(" [x] Received '{0}':'{1}'", routingKey, message);
4040
};
41-
channel.BasicConsume(queue: queueName, noAck: true, consumer: consumer);
41+
channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);
4242

4343
Console.WriteLine(" Press [enter] to exit.");
4444
Console.ReadLine();

‎dotnet-visual-studio/5_ReceiveLogsTopic/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public static void Main(string[] args)
3131
Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C");
3232

3333
var consumer = new QueueingBasicConsumer(channel);
34-
channel.BasicConsume(queue: queueName, noAck: true, consumer: consumer);
34+
channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);
3535

3636
while(true)
3737
{

‎dotnet-visual-studio/6_RPCClient/RPCClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ public RPCClient()
2020
channel = connection.CreateModel();
2121
replyQueueName = channel.QueueDeclare().QueueName;
2222
consumer = new QueueingBasicConsumer(channel);
23-
channel.BasicConsume(queue: replyQueueName, noAck: true, consumer: consumer);
23+
channel.BasicConsume(queue: replyQueueName, autoAck: true, consumer: consumer);
2424
}
2525

2626
public string Call(string message)

‎dotnet-visual-studio/6_RPCServer/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public static void Main()
1414
channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
1515
channel.BasicQos(0, 1, false);
1616
var consumer = new EventingBasicConsumer(channel);
17-
channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer);
17+
channel.BasicConsume(queue: "rpc_queue", autoAck: false, consumer: consumer);
1818
Console.WriteLine(" [x] Awaiting RPC requests");
1919

2020
consumer.Received += (model, ea) =>

‎dotnet/RPCClient/RPCClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ public RPCClient()
2020
channel = connection.CreateModel();
2121
replyQueueName = channel.QueueDeclare().QueueName;
2222
consumer = new QueueingBasicConsumer(channel);
23-
channel.BasicConsume(queue: replyQueueName, noAck: true, consumer: consumer);
23+
channel.BasicConsume(queue: replyQueueName, autoAck: true, consumer: consumer);
2424
}
2525

2626
public string Call(string message)

‎dotnet/RPCServer/RPCServer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public static void Main()
1414
channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
1515
channel.BasicQos(0, 1, false);
1616
var consumer = new EventingBasicConsumer(channel);
17-
channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer);
17+
channel.BasicConsume(queue: "rpc_queue", autoAck: false, consumer: consumer);
1818
Console.WriteLine(" [x] Awaiting RPC requests");
1919

2020
consumer.Received += (model, ea) =>

0 commit comments

Comments
 (0)
0