Skip to content

Instantly share code, notes, and snippets.

@berviantoleo
Last active October 5, 2024 08:39
Consumer
using Azure.Storage.Queues;
string queueName = "hello-test";
string connectionString = "DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==;QueueEndpoint=http://127.0.0.1:10001/devstoreaccount1;";
// Instantiate a QueueClient to create and interact with the queue
QueueClient queueClient = new QueueClient(connectionString, queueName);
do
{
Console.WriteLine($"Capture: {DateTime.Now}");
var properties = queueClient.GetProperties();
int cachedMessagesCount = properties.Value.ApproximateMessagesCount;
// Display number of messages
Console.WriteLine($"Number of messages in queue: {cachedMessagesCount}");
var receivedMessages = await queueClient.ReceiveMessagesAsync(maxMessages: 10);
if (receivedMessages.Value.Count() == 0)
{
Console.WriteLine("Empty message!");
}
foreach (var receivedMessage in receivedMessages.Value)
{
// Display the message
Console.WriteLine($"ID: {receivedMessage.MessageId} Message: {receivedMessage.MessageText}");
// ensure remove it after processing
await queueClient.DeleteMessageAsync(receivedMessage.MessageId, receivedMessage.PopReceipt);
}
Console.WriteLine("------------");
Thread.Sleep(3000);
} while (true);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment