Сложное сообщение и де-сериализация Masstransit

Question

Я публикую сообщение в MT, которое имеет несколько свойств, типизированных для объекта, поскольку я не знаю тип во время компиляции. Когда я получаю сообщение у потребителя, я вижу, что свойства, типизированные для объекта, заполняются экземплярами Newtonsoft JObject-экземпляров. Класс JObject-Class находится в ILMerged Newtonsoft.Json-assembly в Masstransit.dll. Класс JObject-Class в этой сборке отмечен как внутренний. Всякий раз, когда я пытаюсь передать значение свойства в JObject, предоставленный Nuget-Assembly Newtonsoft.Json, он терпит неудачу.

Так что мои вопросы:

• Что такое правильный способ бросить свойство-значение JObject?
• Почему бросок не работает? Это означает, каковы трудности, с которыми здесь столкнулись?
• Могу ли я получить сырое, несертифицированное тело сообщения в моем потребителе?

спасибо.

Answer 1

Вы не можете использовать сериализацию JSON, если вы выполняете написание во время выполнения любых контрактов с сообщениями. Если вы хотите это сделать, вам потребуется использовать двоичный сериализатор.

Вы не можете получить доступ к необработанному, несертифицированному сообщению-телу; если сообщение не может быть десериализовано, то код пользователя не вызывается.

Если любые типы, отмеченные как внутренние, не позволяют десериализовать сообщение. Конструктор не может быть вызван, поэтому не создается объект. Я не уверен, что бинарный сериализатор позволит вам обойти это ограничение, а не то, что я тестировал.

Если у вас есть другие вопросы, вы также можете присоединиться к списку рассылки, https://groups.google.com/forum/#!forum/masstransit-discuss.

Answer 2

Моя описанная выше проблема, вероятно, возникла из-за неправильного представления моей системы обмена сообщениями. Но я обнаружил неприятную обходной путь для преобразования вложенных JObjects в нужных объектов предметной области:

protected bool TryConvertJObjectToDtoOfType<T>(Object jObjectInDisguise, out T dto) 
    where T: BpnDto 
{ 
    try 
    { 
     if (jObjectInDisguise.GetType().Name != typeof(JObject).Name) 
      throw new ArgumentException("Object isn't a JObject", "jObjectInDisguise"); 

     var json = jObjectInDisguise.ToString(); 
     var settings = new JsonSerializerSettings() 
     { 
      MissingMemberHandling = MissingMemberHandling.Error 
     }; 

     dto = JsonConvert.DeserializeObject<T>(json, settings); 
     return true; 
    } catch 
    { 
     dto = null; 
     return false; 
    } 
} 

Answer 3

Как один из создателей MassTransit, если вы в том числе

public object MyMessageProperty { get; set; } 

В контракте сообщение, вы «делаю это неправильно. Используйте сильно типизированные функции публикации структуры, вместо того, чтобы выполнять собственную динамическую отправку поверх диспетчеризации, уже выполняемой системой публикации/подписки внутри MT.