MSMQ с помощью BinaryFormatter

Question

У меня есть компонент, который записывает в очередь (вот код):

using (MessageQueueTransaction transaction = new MessageQueueTransaction()) 
      { 
       transaction.Begin(); 
       using (var queue = new MessageQueue(@fullQueue, QueueAccessMode.Send)) 
       { 
        BinaryMessageFormatter formatter = new BinaryMessageFormatter(); 
        // XmlMessageFormatter formatter = new XmlMessageFormatter(new Type[] { typeof(Testing) }); 

        var testing = new Testing {myBody = string.Format("Hello {0}",Environment.UserName), myMessageText = "Header"}; 
        var message = new Message 
        { 
         Body = testing, 
         Label = Environment.MachineName, 
         UseDeadLetterQueue = true, 
         Recoverable = true, 
         Formatter = formatter 
        }; 
        queue.Send(message, MessageQueueTransactionType.Single); 

       } 
       transaction.Commit(); 

      } 

Теперь, когда я запускаю выше «Тестирование» просто Serializble объект с 2-мя свойствами на нем. Если я посмотрю на текст текста в очереди, он выглядит нормально.

Теперь у меня есть отдельный компонент для чтения из очереди:

BinaryMessageFormatter formatter = new BinaryMessageFormatter(); 
     // XmlMessageFormatter formatter = new XmlMessageFormatter(new Type[] { typeof(Testing) }); 
     MessageQueue msgQ = new MessageQueue(fullQueue, QueueAccessMode.Receive); 

     try 
     { 

      using (TransactionScope transaction = new TransactionScope()) 
      { 

       Message incoming = new Message { Formatter = formatter, AcknowledgeType = AcknowledgeTypes.FullReceive }; 

       incoming = msgQ.Receive(new TimeSpan(0, 0, 3),MessageQueueTransactionType.Single); 
       // var ttt = incoming.Body; 
       MemoryStream mem = (MemoryStream) incoming.BodyStream; 
       mem.Seek(0, SeekOrigin.Begin); 
       IFormatter ifm = new BinaryFormatter(); 
       Testing tt = (Testing)ifm.Deserialize(mem); 

       transaction.Complete(); 
      } 

     } 

Теперь в точке я выступаю в ifm.Deserialize, это ошибки с

Не удается найти сборку «MSMQWrite , Version = 1.0.0.0, Culture = neutral, PublicKeyToken = null ' Где MSMQWrite - это имя метода в моем компоненте записи.

При записи в очереди, я думал, что я, возможно, придется явно сериализовать объект первого, так на мой компонент, который пишет, я немного изменил код, чтобы быть:

var testing = new Testing {myBody = string.Format("Hello {0}",Environment.UserName), myMessageText = "Header"}; 
        MemoryStream mem = new MemoryStream(); 

        BinaryFormatter bf = new BinaryFormatter(); 
        bf.Serialize(mem,testing); 

        var message = new Message 
        { BodyStream = mem, 
         //Body = testing, 
         Label = Environment.MachineName, 
         UseDeadLetterQueue = true, 
         Recoverable = true, 
         Formatter = formatter 
        }; 
        queue.Send(message, MessageQueueTransactionType.Single); 

Как вы можете видеть, я устанавливаю BodyStream прямо сейчас, но я все равно получаю ту же ошибку при попытке чтения из очереди.

Answer 1

Вам необходимо ссылаться на сборку, которая содержит класс тестирования, от вашего второго компонента. Я предполагаю, что сборка - это MSMQWrite. Если вы уже ссылаетесь на нее, убедитесь, что она копируется в папку, из которой выполняется второй компонент, поэтому ее можно найти во время выполнения.

Другой вариант заключается в перемещении фактического класса, который сериализуется на другой компонент (например, MSMQCommon), и ссылается на него как на запись компонента, так и на одно чтение. Или просто один компонент.