我尝试通过 MassTransit 发布的消息遇到了基本类型问题。考虑以下:
[Serializable]
public abstract class Event : CorrelatedBy<Guid> {
public Guid CorrelationId { get; set; }
public abstract string EventName { get; }
public override string ToString() {
return string.Format("{0} - {1}", EventName, CorrelationId);
}
}
[Serializable]
public class PersonCreated : Event {
public PersonCreated(Guid personId, string firstName, string lastName) {
PersonId = personId;
FirstName = firstName;
LastName = lastName;
}
public readonly Guid PersonId;
public readonly string FirstName;
public readonly string LastName;
}
但是,当我尝试发布一组抽象事件时,例如:
public void PublishEvents(IEnumerable<Event> events) {
foreach (var e in events) {
Bus.Instance.Publish(e);
}
}
我没有收到此集合中的任何事件,无论其具体类型如何。如果我在总线上发布之前将事件转换为其正确的具体类型,我确实会正确接收消息。
关于如何纠正此问题以允许处理我的抽象事件集合而不强制转换每个事件的任何想法?
EDIT:我尝试更改我的设置以使用 BinarySerialization,如下所示:
Bus.Initialize(sbc =>
{
sbc.UseBinarySerializer();
});
并且没有产生任何行为改变。我能够得到我的唯一方法Consumes<PersonCreated>
要调用的类是显式地将事件转换为PersonCreated
type.