派生類型不發佈給消費者在MassTransit

我有問題發佈派生類型的通用消息並使用MassTransit v2.8.0調用處理程序。派生類型不發佈給消費者在MassTransit

如果我發佈類型爲HtmlBlockNewMessage的消息，則不會調用消費者。如果我發佈ServiceBusMessage對象並將消費者更改爲Consumes<ServiceBusMessage>.Context，則會調用消費者。

該派生類型的代碼失敗。它只適用於父類型（ServiceBusMessage）。

類型：

[Serializable] 
public class ServiceBusMessage 
{ 
} 

[Serializable] 
public class ServiceBusResponse 
{ 
    public int ResultCode { get; set; } 
} 

// Request 
[Serializable] 
public class ContentItemMessage : ServiceBusMessage 
{ 
    public string SiteId { get; set; } 
    public string PageId { get; set; } 
    public string ContentItemId { get; set; } 
} 

[Serializable] 
public class HtmlBlockNewMessage : ContentItemMessage 
{ 
    public string HtmlData { get; set; } 
} 

// Response 
[Serializable] 
public class ContentItemMessageResponse : ServiceBusResponse 
{ 
    public string Name { get; set; } 
    public string ItemType { get; set; } 
    public string ItemHandler { get; set; }  
} 

[Serializable] 
public class HtmlBlockNewMessageResponse : ContentItemMessageResponse 
{ 
    public string DataId { get; set; } 
}

消費者：

public class HtmlBlockConsumer : Consumes<HtmlBlockNewMessage>.Context 
{ 
    private IHtmlDataService htmlDataService; 
    public static ILogger Logger { get; set; } 

    public HtmlBlockConsumer() 
     : this(null) 
    { 
    } 

    public HtmlBlockConsumer(IHtmlDataService htmlDataService) 
    { 
     Logger = Log4NetLogger.GetLogger(); 

     this.htmlDataService = htmlDataService ?? IoC.Container.Resolve<IHtmlDataService>(); 
    } 

    public void Consume(IConsumeContext<HtmlBlockNewMessage> message) 
    { 
    // Do some stuff 

     message.Respond(new HtmlBlockNewMessageResponse() { ResultCode = 1 }); 
    }

}從發行方

公交登記：從消費側

 var bus = ServiceBusFactory.New(sbc => 
     { 
      sbc.EnableMessageTracing(); 

      sbc.UseMsmq(); 
      sbc.VerifyMsmqConfiguration(); 
      sbc.UseMulticastSubscriptionClient(); 
      sbc.SetNetwork("Test"); 
      sbc.UseXmlSerializer(); 
      sbc.UseControlBus(); 

      sbc.ReceiveFrom("msmq://localhost/AuctionCMS.Web.Publisher"); 

      MtServiceBus.ValidateBus(sbc); 
     }); 

     IoC.Container.RegisterInstance(bus);

總線註冊：

 var bus = ServiceBusFactory.New(sbc => 
     { 
      sbc.EnableMessageTracing(); 

      sbc.UseMsmq(); 
      sbc.VerifyMsmqConfiguration(); 
      sbc.UseMulticastSubscriptionClient(); 
      sbc.SetNetwork("Test"); 
      sbc.UseXmlSerializer(); 
      sbc.UseControlBus(); 

      sbc.ReceiveFrom("msmq://localhost/AuctionCMS.Consumer"); 

      sbc.Subscribe(subs => 
      { 
       // These are being manually registered due to some issues getting 
       // StructureMap to scan my assemblies 
       subs.Instance(new HtmlBlockConsumer()); 
       subs.Instance(new BrowserConsumer()); 
       subs.Instance(new OfferConsumer()); 
      }); 
     }); 

     IoC.Container.RegisterInstance(bus);

我發佈的擴展：

public static TR Publish<T, TR>(this IServiceBus bus, T message) where T : ServiceBusMessage where TR : ServiceBusResponse 
    { 
     TR response = null; 

     IoC.Container.Resolve<IServiceBus>().PublishRequest(message, callback => 
      { 
       callback.SetTimeout(10.Seconds()); 

       try 
       { 
        callback.Handle<TR>(m => 
         { 
          response = m;/
         }); 
       } 
       catch (Exception ex) 
       { 

        throw; 
       } 
      }); 

     return response; 
    }

調用代碼：

// First I create a message specific to the type of action I am performing 

var message = new HtmlBlockNewMessage() { HtmlData = "Hello" }; 

// Then I call a function which accepts a ContentItemMessage and calls Publish 

public void AddContentItem(ContentItemMessage message) 
{ 
    // Do some preprocessing 

    // This call times out 
    var response = this.auctionCmsServices.Bus.Publish<ContentItemMessage, 
      ContentItemMessageResponse>(message); 

    // Do some more processing 

}

這是例外

[RequestTimeoutException: Timeout waiting for response, RequestId: 54910000-307f-20cf-c0c2-08d06b31cf6f] 
    MassTransit.RequestResponse.RequestImpl`1.Wait() in d:\BuildAgent-03\work\aa063b4295dfc097\src\MassTransit\RequestResponse\RequestImpl.cs:124 
    MassTransit.RequestResponseExtensions.PublishRequest(IServiceBus bus, TRequest message, Action`1 configureCallback) in d:\BuildAgent-03\work\aa063b4295dfc097\src\MassTransit\RequestResponseExtensions.cs:31 
    AuctionCMS.Framework.ServiceBus.MtServiceBus.Publish(IServiceBus bus, T message) in c:\Users\rick\Documents\Visual Studio 2012\Projects\AuctionCMS\AuctionCMS.Framework\ServiceBus\MtServiceBus.cs:24 
    AuctionCMS.Framework.Entity.Page.AddContentItem(ISite site, String zone, Int32 location, ContentItemMessage message) in c:\Users\rick\Documents\Visual Studio 2012\Projects\AuctionCMS\AuctionCMS.Framework\Entity\Page.cs:48 
    AuctionCMS.Framework.Entity.Site.SetDefaultContent() in c:\Users\rick\Documents\Visual Studio 2012\Projects\AuctionCMS\AuctionCMS.Framework\Entity\Site.cs:117 
    AuctionCMS.Web.Controllers.AdminSitesController.NewSite(SiteNewModel model, HttpPostedFileBase file) in c:\Users\rick\Documents\Visual Studio 2012\Projects\AuctionCMS\AuctionCMS.Web\Controllers\AdminSitesController.cs:69 
    lambda_method(Closure , ControllerBase , Object[]) +179 
    System.Web.Mvc.ReflectedActionDescriptor.Execute(ControllerContext controllerContext, IDictionary`2 parameters) +261 
    System.Web.Mvc.ControllerActionInvoker.InvokeActionMethod(ControllerContext controllerContext, ActionDescriptor actionDescriptor, IDictionary`2 parameters) +39 
    System.Web.Mvc.Async.<>c__DisplayClass42.<BeginInvokeSynchronousActionMethod>b__41() +34 
    System.Web.Mvc.Async.<>c__DisplayClass39.<BeginInvokeActionMethodWithFilters>b__33() +124 
    System.Web.Mvc.Async.<>c__DisplayClass4f.<InvokeActionMethodFilterAsynchronously>b__49() +838059 
    System.Web.Mvc.Async.<>c__DisplayClass4f.<InvokeActionMethodFilterAsynchronously>b__49() +838059 
    System.Web.Mvc.Async.<>c__DisplayClass4f.<InvokeActionMethodFilterAsynchronously>b__49() +838059 
    System.Web.Mvc.Async.<>c__DisplayClass4f.<InvokeActionMethodFilterAsynchronously>b__49() +838059 
    System.Web.Mvc.Async.<>c__DisplayClass37.<BeginInvokeActionMethodWithFilters>b__36(IAsyncResult asyncResult) +15 
    System.Web.Mvc.Async.<>c__DisplayClass2a.<BeginInvokeAction>b__20() +33 
    System.Web.Mvc.Async.<>c__DisplayClass25.<BeginInvokeAction>b__22(IAsyncResult asyncResult) +838644 
    System.Web.Mvc.<>c__DisplayClass1d.<BeginExecuteCore>b__18(IAsyncResult asyncResult) +28 
    System.Web.Mvc.Async.<>c__DisplayClass4.<MakeVoidDelegate>b__3(IAsyncResult ar) +15 
    System.Web.Mvc.Controller.EndExecuteCore(IAsyncResult asyncResult) +65 
    System.Web.Mvc.Async.<>c__DisplayClass4.<MakeVoidDelegate>b__3(IAsyncResult ar) +15 
    System.Web.Mvc.Controller.EndExecute(IAsyncResult asyncResult) +51 
    System.Web.Mvc.<>c__DisplayClass8.<BeginProcessRequest>b__3(IAsyncResult asyncResult) +42 
    System.Web.Mvc.Async.<>c__DisplayClass4.<MakeVoidDelegate>b__3(IAsyncResult ar) +15 
    System.Web.Mvc.MvcHandler.EndProcessRequest(IAsyncResult asyncResult) +51 
    System.Web.CallHandlerExecutionStep.System.Web.HttpApplication.IExecutionStep.Execute() +606 
    System.Web.HttpApplication.ExecuteStep(IExecutionStep step, Boolean& completedSynchronously) +288

編輯：

我用一種通用的方法來解決這個問題。從來電者的角度來看，這很醜陋，但它很有用。

public TR AddContentItem<T, TR>(T message) where T : ContentItemMessage where TR : ContentItemMessageResponse 
    { 
     var response = this.auctionCmsServices.Bus.Publish<T, TR>(message); 

     return response; 
    }

調用代碼現在看起來是這樣的：

page.AddContentItem（新HtmlBlockNewMessage（）{HtmlData = 「這是一些HTML」}）;

來源

2013-08-19 rboarman

如何在容器中註冊'IServiceBus'？郵件列表可能是比這裏更好的地方，但這取決於你。 https://groups.google.com/d/pendingmsg/masstransit-discuss – Travis

爲什麼你有'IServiceBus'上的擴展方法忽略參數並從容器中拉取？這對我來說似乎很奇怪。我錯過了什麼嗎？ – Travis

我想你在這裏討論的打字問題：http://stackoverflow.com/questions/7236971/masstransit-message-mis-typing?rq=1 –

尤金的評論是正確的。這裏發生的是你正在發佈一個類型爲ContentItemMessage的消息。消息HtmlBlockNewMessage將不會執行，因爲消息發佈爲ContentItemMessage和ServiceBusMessage。 MassTransit message mis-typing是這方面的一些工作之一。

您的選擇：

變化AddContentItem使用一個通用的，或許還有一個約束
二手反射調用與正確的類型信息發佈
重組如何發佈的東西，所以這是不一個問題

底線是你應該總是發佈你想收到的類型。消息中的多態性很棘手。

來源

2013-08-21 12:52:45 Travis

更新的問題我更新了我的問題，我如何使用帶有約束的泛型來解決問題。謝謝您的幫助。你可能想要提供一個更優雅地處理這個問題的擴展。再次感謝。 – rboarman

派生類型不發佈給消費者在MassTransit

回答

相關問題