Recibir MSMQ con transacción - reversión no hacer que el mensaje vuelva a estar disponible

Question

Tengo esto en una clase llamada "MessageQueueReceive".

public MessageQueueTransaction BlockingReceive(out Message message) 
{ 
    MessageQueueTransaction tran = null; 
    message = null; 

    tran = new MessageQueueTransaction(); 

    tran.Begin(); 
    try 
    { 
     message = Queue.Receive(new TimeSpan(0, 0, 5), tran); 
    } 
    catch (MessageQueueException ex) 
    { 
     // If the exception was a timeout, then just continue 
     // otherwise re-raise it. 
     if (ex.MessageQueueErrorCode != MessageQueueErrorCode.IOTimeout) 
      throw ex; 
    } 

    return tran; 

} 

Entonces mi bucle de procesamiento tiene esta: - herramienta de panel

while (!Abort) 
{ 
    try 
    { 
     tran = this.Queue.BlockingReceive(out msg); 

     if (msg != null) 
     { 
      // Process message here 

      if (tran != null) 
       tran.Commit(); 
     } 
    } 
    catch (Exception ex) 
    { 
     if (tran != null) 
      tran.Abort(); 

    } 
} 

El control muestra que las colas de mensajes que estoy usando son transaccionales. La cola del diario no está habilitada.

Este código crea la cola: -

private static MessageQueue CreateMessageQueue(string queueName, bool transactional = false) 
{ 
    MessageQueue messageQueue = MessageQueue.Create(queueName, transactional); 
    messageQueue.SetPermissions("Administrators", MessageQueueAccessRights.FullControl, 
      AccessControlEntryType.Allow); 
    return messageQueue; 
} 

El parámetro transaccional se establece como "verdadero" en que se requiera.

Lo que encuentro es que cuando ocurre una excepción durante el procesamiento del mensaje, se llama a tran.Abort, pero en ese punto esperaría que el mensaje se devuelva a la cola. Sin embargo, esto no está sucediendo y los mensajes se pierden.

¿Me falta algo obvio? ¿Alguien puede ver lo que estoy haciendo mal?

Answer 1

Gracias por todos los comentarios. Reorganicé mi código como sugirió Russell McClure, e intenté crear casos de prueba simples pero no pude reproducir el problema.

Al final, el problema no era en absoluto donde estaba mirando (¿con qué frecuencia sucede eso?).

En mi canalización, tenía un comprobador de mensajes duplicados. Los "mensajes" que trata mi sistema provienen de dispositivos remotos en una WAN, y ocasionalmente los mensajes en el cable están duplicados.

Cuando se extrae un mensaje del MSMQ, pasa a través del comprobador duplicado el escritor de la base de datos. Si el escritor de la base de datos falló, el duplicado seleccionado no eliminó el hash de su tabla. Cuando el proceso intente repetir el bucle, recibirá el mismo mensaje de la cola porque la transacción MSMQ se ha retrotraído cuando el escritor de la base de datos ha fallado. Sin embargo, en el segundo intento, el inspector duplicado detectaría que había visto el mensaje anteriormente y se lo tragaría en silencio.

La solución consistía en hacer que el inspector duplicado detectara la excepción proveniente del siguiente eslabón de la cadena, y revertir cualquier cosa que hubiera hecho también.

Answer 2

Su cola debe crearse como una cola transaccional para obtener lo que desea.

EDIT:

Bueno, si la cola es transaccional entonces que apunta al hecho de que están mal manejo de su transacción, aunque no puedo ver específicamente cómo está sucediendo. Cambiaría su método BlockingReceive para devolver el mensaje. Movería la creación del MessageQueueTransaction al método externo. Su código será mucho más fácil de mantener si tiene las llamadas al método Begin, Commit and Abort en el mismo método.