Сложный тип сообщений с ActiveMQ и.NET с использованием Spring.net Не работает
Я пытаюсь поставить в очередь сообщения в 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();
}
}
Исключение на стороне службы Windows, когда я раскрываю объект сообщения '((Apache.NMS.ActiveMQ.Commands.ActiveMQObjectMessage)(message)). Тело' сгенерировало исключение типа 'System.Runtime.Serialization.SerializationException'