は、我々は我々のプロジェクトでサービスバスキューを使用している

Question

一度で紺碧サービスバスキューをクリアします。管理者がキューをクリアすることを選択したときに、すべてのメッセージをキューから削除する機能が必要です。私はネット上で検索が、QueueClientクラス内これを行う任意の関数を見つけることができませんでした。

私はすべてのメッセージを一つずつをポップする必要があり、その後、キューをクリアするには、彼らが完全にマーキングやより良い方法はありますか？あなたのようなwhileループ内Receive()メソッドを使用して

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

BrokeredMessage brokeredMessage = queueClient.Receive(); 

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

Answer 1

Receive()方法はキューに表示される別のメッセージを待っされるように、キューが空になると、あなたのコードは、無期限に実行するようになりますされています。

あなたはこれを自動的に実行したい場合は、Peek()方法を使用してみてください。

例えば

：あなたはhochoで述べたようReceiveMode.ReceiveAndDeleteで再びこれを簡単にすることができます

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

。

Answer 2

Azure-ServiceBus-Queuesの場合、n - メッセージの時刻を受け取ることができるReceiveBatch-methodがあります。 ReceiveMode.ReceiveAndDeleteと組み合わせると、キューをより効率的に消去できます。

警告メッセージの数Nが返されるかもしれないが、それは保証されませんです。また、メッセージバッチサイズは256Kという制限があります。 （@ScottBradyと@participantから）

• どちらのアプローチ
• そして、あなたはサービスバスキューまたはトピックを/空のメソッドを書くことができMessageReceiver抽象

を：使用

Answer 3

購読：

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

Azure Servをクリーニングする最速の方法iceBusキューは、非常に短いDefaultMessageTimeToLiveを設定し、数秒待って、その後、初期DefaultMessageTimeToLiveを復元更新する力からキューからそれを受け取る試してみることです。

ポータルからまたはコードからそれを行うことができます：あなたはnugetからWindowsAzure.Storageライブラリを使用している場合は、キュー全体をクリアするための簡単な方法Clear()あり

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

。私は、キューを管理するために、そのライブラリからMicrosoft.Windows.Azure.Queueクラスを使用します。それ以外の場合は、API per their documentationでアクセスできます。 Azureライブラリにどのくらいの時間がかかっていたのか分かりません。最初に質問されたときには存在しなかったかもしれませんが、REST APIは少なくとも2014年に戻ってきました。this Azure feedback post

AzureのライブラリとキューをクリアするNETのコードは次のとおりです。

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

は私がReceiveAndDelete、PrefetchCount、ReceiveBatchAsyncの組み合わせ、およびシンプルな真実ループを使用して良い結果を持つのではなくかいま見を使用しています。以下MessagingFactoryと例：

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(); 
} 

のみWindowsAzure.ServiceBus Nugetパッケージが必要です。