Сложный тип сообщений с ActiveMQ и .NET с использованием Spring.net Не работает

Question

Я пытаюсь поставить в очередь сообщения в Apache ActiveMQ, используя MVC в качестве приложения-отправителя, и у меня есть служба окон, встроенная в C#, в качестве слушателя для Apache ActiveMQ. Но я получаю исключение, читая сообщение в конце слушателя выше.

Код отправителя MVC.

public void GenerateMQMessages(EmailModel mail) 
     { 
      try 
      { 
       //// Create the Connection Factory 
       ConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/"); 
       NmsTemplate nmsTemplate = new NmsTemplate(factory); 
       nmsTemplate.Send("EmailQueue", new GenericMessageCreator<dummyClass>(new dummyClass { Prop1 = 1, Prop2 = "Hello There" })); 
      } 
      catch (System.Exception e) 
      { 
      } 
     } 

public class GenericMessageCreator<T> : IMessageCreator 
    { 
     public T Body { get; set; } 

     public GenericMessageCreator(T body) 
     { 
      this.Body = body; 
     } 

     IMessage IMessageCreator.CreateMessage(ISession session) 
     { 
      ActiveMQObjectMessage msg = new ActiveMQObjectMessage(); 
      msg.Body = this.Body; 
      return msg; 
     } 
    } 

[Serializable] 
    public class dummyClass : ISerializable 
    { 
     public int Prop1 { get; set; } 
     public string Prop2 { get; set; } 

     public void GetObjectData(SerializationInfo info, StreamingContext context) 
     { 
      //throw new NotImplementedException(); 
     } 
    } 

C# Windows код обслуживания.

protected override void OnStart(string[] args) 
     { 
      try 
      { 
       //// Create the Connection factory 
       ConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/");     

       SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer();     
       listenerContainer.ConnectionFactory = factory; 
       listenerContainer.DestinationName = "EmailQueue"; 
       listenerContainer.MessageListener = new GenericMessageListener<dummyClass>(); 
       listenerContainer.AfterPropertiesSet(); 

      } 
      catch (System.Exception e) 
      { 

      } 
     } 

public class GenericMessageListener<T> : IMessageListener 
    { 
     public void OnMessage(IMessage message) 
     { 
      try 
      { 
       ActiveMQObjectMessage msg = new ActiveMQObjectMessage(); 
       if (msg != null) 
       { 
        T body = (T)msg.Body; 

        //dummyClass body = (dummyClass)msg.Body; 
        typeof(T).GetProperties() 
         .ToList() 
         .ForEach(prop => 
         { 
          var p = string.Format("{0} = {1},", prop.Name, prop.GetValue(body, new object[] { })); 
         });      
       } 
      } 
      catch (Exception e) 
      { 

      } 
     }   
} 


[Serializable] 
    public class dummyClass : ISerializable 
    { 
     public int Prop1 { get; set; } 
     public string Prop2 { get; set; } 

     public void GetObjectData(SerializationInfo info, StreamingContext context) 
     { 
      //throw new NotImplementedException(); 
     } 
    } 

Исключение на стороне службы окна Когда я развернуть объект Message '((Apache.NMS.ActiveMQ.Commands.ActiveMQObjectMessage) (сообщение)). Тело' бросил исключение типа «System.Runtime.Serialization .SerializationException '

Answer 1

Вы прочитали эту статью?

Complex Type Messaging with ActiveMQ and .NET