Borrado de la cola del bus de servicio azul de una vez

Question

Estamos utilizando una cola de bus de servicio en nuestro proyecto. Necesitamos una funcionalidad para eliminar todos los mensajes de la cola cuando el administrador decida borrar la cola. Busqué en la red pero no pude encontrar ninguna función que haga esto dentro de la clase QueueClient.

¿Tengo que mostrar todos los mensajes uno por uno y luego marcarlos para borrar la cola o hay una manera mejor?

QueueClient queueClient = _messagingFactory.CreateQueueClient(
           queueName, ReceiveMode.PeekLock); 

BrokeredMessage brokeredMessage = queueClient.Receive(); 

while (brokeredMessage != null) 
{ 
    brokeredMessage.Complete(); 
    brokeredMessage = queueClient.Receive(); 
} 

Answer 1

Utilizando el método Receive() dentro del bucle while como si hará que su código se ejecute de forma indefinida una vez que la cola está vacía, como el método Receive() estará esperando otro mensaje que aparezca en la cola.

Si desea que esto se ejecute automáticamente, intente con el método Peek().

Por ejemplo:

while (queueClient.Peek() != null) 
{ 
    var brokeredMessage = queueClient.Receive(); 
    brokeredMessage.Complete(); 
} 

Usted puede hacer esto de nuevo más simple con la ReceiveMode.ReceiveAndDelete como fue mencionado por Hocho.

Answer 2

Para Azure-ServiceBus-Queues hay un ReceiveBatch-method que le permite recibir un lote de n -mensajes en el momento. Combinado con ReceiveMode.ReceiveAndDelete puede borrar la cola de manera más eficiente.

Advertencia El número n de mensajes podría ser devuelto pero no está garantizada. También hay un límite para el tamaño del lote de mensajes de 256K.

Answer 3

Usando:

• Tanto enfoque (de @ScottBrady y @participant)
• Y la abstracción MessageReceiver

puede escribir un método que se vacía una cola bus de servicio o de un tema/suscripción:

MessageReceiver messageReceiver = ... 
while (messageReceiver.Peek() != null) 
{ 
    // Batch the receive operation 
    var brokeredMessages = messageReceiver.ReceiveBatch(300); 

    // Complete the messages 
    var completeTasks = brokeredMessages.Select(m => Task.Run(() => m.Complete())).ToArray(); 

    // Wait for the tasks to complete. 
    Task.WaitAll(completeTasks); 
} 

Answer 4

La manera más rápida de limpiar un Azure Serv iceBus Queue es establecer un muy corto DefaultMessageTimeToLive, espere unos segundos, intente recibir de la cola forzarlo para actualizar y restaurar el DefaultMessageTimeToLive inicial.

Puede hacerlo desde el portal o de código:

var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString); 
var queueDescription = _namespaceManager.GetQueue(queueName); 
var queueClient = QueueClient.CreateFromConnectionString(connectionString, queueName, ReceiveMode.ReceiveAndDelete); 

var dl = queueDescription.EnableDeadLetteringOnMessageExpiration; 
var ttl = queueDescription.DefaultMessageTimeToLive; 

queueDescription.EnableDeadLetteringOnMessageExpiration = false; 
queueDescription.DefaultMessageTimeToLive = TimeSpan.FromSeconds(1); 

Thread.Sleep(5000); 
var dumy = queueClient.ReceiveBatch(200, TimeSpan.FromSeconds(1)).ToArray(); 

queueDescription.EnableDeadLetteringOnMessageExpiration = dl; 
queueDescription.DefaultMessageTimeToLive = ttl; 

Answer 5

Hay una sencilla Clear() método para borrar toda la cola si está utilizando la biblioteca de WindowsAzure.Storage Nuget. Utilizo la clase Microsoft.Windows.Azure.Queue de esa biblioteca para administrar la cola. De lo contrario, puede acceder a través de su API per their documentation. No sé cuánto tiempo ha estado el método en la biblioteca de Azure y probablemente no existía cuando se formuló originalmente la pregunta, pero la API REST se remonta al menos desde 2014 por this Azure feedback post

El completo.código NET para borrar la cola con la biblioteca Azure es:

string connectionString = "YourAzureConnectionStringHere"; 
string queueName = "YourWebJobQueueName"; 
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(connectionString); 

// Create the queue client, then get a reference to queue 
CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient(); 
queue = queueClient.GetQueueReference(GetQueueName(queueName)); 

// Clear the entire queue 
queue.Clear(); 

Answer 6

Estoy teniendo buenos resultados utilizando una combinación de ReceiveAndDelete, PrefetchCount, ReceiveBatchAsync, y un simple lazo de la verdad en lugar de utilizar la ojeada. Ejemplo con MessagingFactory a continuación:

var receiverFactory = MessagingFactory.CreateFromConnectionString("ConnString"); 
var receiver = receiverFactory.CreateMessageReceiver("QName", ReceiveMode.ReceiveAndDelete); 
receiver.PrefetchCount = 300; 

bool loop = true; 
while (loop) 
{ 
    var messages = await receiver.ReceiveBatchAsync(300, TimeSpan.FromSeconds(1)); 
    loop = messages.Any(); 
} 

requiere el paquete Nuget WindowsAzure.ServiceBus Sólo.