Jak mogę usunąć wiadomości z kolejki?

Question

Mam wiadomości, które utknęły w kolejce i szukam sposobu, aby je programowo usunąć.

Czy istnieje sposób na usunięcie wiadomości z kolejki, jeśli trwa dłużej niż X dni? Mogę połączyć i usunąć kolejkę podobną do tej, ale nie wiem, jak usunąć poszczególne wiadomości.

MessageQueue queue = new MessageQueue(@".\private$\SomeTestName"); 
//queue.Purge(); //deletes the entire queue 
try 
{ 
    // Peek and format the message. 
    Message m = myQueue.Peek(); 

    // Display message information. 
    Console.WriteLine("Sent time {0}", m.SentTime); 
    Console.WriteLine("Arrived time {0}", m.ArrivedTime); 
} 

Answer 1

Nie można tego zrobić za pomocą interfejsu API. Ale można użyć

• GetMessageEnumerator2() i
• RemoveCurrent()

Zaletą korzystania wyliczenie jest to, że jeśli kolejka ma wiele wiadomości, czytając wszystkie z nich mogą spowodować OutOfMemoryException. Z modułem wyliczającym można odczytać tylko 1 wiadomość naraz, a pamięć przeznaczona na to może być ponownie wykorzystana.

Inną sztuczką zwiększającą wydajność jest określanie właściwości do odczytania, więc jeśli treść wiadomości jest duża i nie interesuje Cię zawartość, możesz wyłączyć jej odczytanie.

var enumerator = _queue.GetMessageEnumerator2(); // get enumerator 
var staleDate = DateTime.UtcNow.AddDays(-3);  // take 3 days from UTC now  
var filter = new MessagePropertyFilter();   // configure props to read 
filter.ClearAll();        // don't read any property 
filter.ArrivedTime = true;      // enable arrived time 
_queue.MessageReadPropertyFilter = filter;  // apply filter 

while (enumerator.MoveNext())  
    if(enumerator.Current.ArrivedTime.Date >= staleDate) 
     enumerator.RemoveCurrent(); 

Answer 2

Zadzwoń GetAllMessages i dodaj czek, aby znaleźć swoją wiadomość i wykonaj operację usunięcia tej wiadomości. Przykładowy kod,

Message[] messages = msgQueue.GetAllMessages(); 
    foreach (Message msg in messages){ 
     doSomething(); 
    } 

Answer 3

myślę, że można zrobić coś takiego:

MessageQueue queue = new MessageQueue(@".\private$\SomeTestName"); 
var messages = queue.GetAllMessages(); 
var messagesToDelete = messages.Where(m => m.ArrivedTime < DateTime.Now.AddDays(-1)).ToList(); 
messagesToDelete.ForEach(m=>queue.ReceiveById(m.Id)); 

Oczywiście, trzeba będzie zmodyfikować datę rzeczy dla odpowiedniego scenariusza.

Answer 4

Można również użyć metody ReceiveById, aby usunąć wiadomości z kolejki.

Sprawdź ten link się: https://msdn.microsoft.com/en-us/library/system.messaging.messagequeue.receivebyid%28v=vs.110%29.aspx