MSMQ игнорируя объем транзакции

Question

Я пытаюсь прочитать данные из приватной очереди MSMQ, и я пытаюсь протестировать сбой, чтобы быть уверенным, что если процесс не завершится, то детали останутся в очереди , На данный момент в пределах моей транзакции он попадает в мою новую строку Exception и, как и ожидалось, попадает в блок catch, но выглядит так, как будто транзакция. Завершено, потому что после того, как исключение было выбрано, очередь пуста: вот мой фрагмент кода -

try 
     { 

      using (TransactionScope transaction = new TransactionScope()) 
      { 

       Message incoming = new Message 
       { 
        Formatter = formatter, 
        AcknowledgeType = AcknowledgeTypes.FullReceive, 
        Recoverable = true 

       }; 

       incoming = msgQ.Receive(new TimeSpan(0, 0, 3), MessageQueueTransactionType.Single); 

       if (incoming != null) 
       { 
        MemoryStream mem = (MemoryStream) incoming.BodyStream; 
        mem.Seek(0, SeekOrigin.Begin); 
        IFormatter ifm = new BinaryFormatter(); 
        var deserialisedMessage = (TravelMessageServiceObjects) ifm.Deserialize(mem); 
        ISubmissionsService submissionsService = new SubmissionsService(); 
        bool retVal = submissionsService.PerformSubmission(deserialisedMessage.Products, deserialisedMessage.PolicyReference); 
        if (!retVal) 
        { 

         string errorMessage = string.Concat("Policy Ref: ", deserialisedMessage.PolicyReference, 
          " Product: ", Enum.GetName(typeof(Products), deserialisedMessage.Products)); 
         throw new Exception(errorMessage); 
        } 
       } 
       transaction.Complete(); 
      } 

     } 
     catch (Exception ex) 
     { 
      IError logger = new Logger(); 
      logger.Log(this, SeverityEnum.Warning, ex); 

     } 

Answer 1

Создайте свою очередь, как транзакционный

и установить MessageQueueTransactionType в Automatic. Single работает только с внутренними транзакциями очереди сообщений.

incoming = msgQ.Receive(new TimeSpan(0, 0, 3), MessageQueueTransactionType.Automatic); 

Проверка, MSDTC Работает.

Проверка, брандмауэры не блокируют связь