Note that there are some explanatory texts on larger screens.

plurals
  1. POTimeout publishing message in MassTransit request/response scenario
    primarykey
    data
    text
    <p>I am trying to set up a MassTransit request/response scenario. The issue is that the message never arrives at the consumer. I get a “timeout waiting for response” error on PublishRequest. No other errors are showing up in the log file. Messages are being created in msmq.</p> <p>Exception information: </p> <blockquote> <p>Exception type: TargetInvocationException Exception message: Exception has been thrown by the target of an invocation. at System.RuntimeTypeHandle.CreateInstance(RuntimeType type, Boolean publicOnly, Boolean noCheck, Boolean&amp; canBeCached, RuntimeMethodHandleInternal&amp; ctor, Boolean&amp; bNeedSecurityCheck) at System.RuntimeType.CreateInstanceSlow(Boolean publicOnly, Boolean skipCheckThis, Boolean fillCache, StackCrawlMark&amp; stackMark) at System.RuntimeType.CreateInstanceDefaultCtor(Boolean publicOnly, Boolean skipCheckThis, Boolean fillCache, StackCrawlMark&amp; stackMark)<br> at System.Activator.CreateInstance(Type type, Boolean nonPublic) at System.Activator.CreateInstance(Type type) at System.Web.Mvc.DefaultControllerFactory.DefaultControllerActivator.Create(RequestContext requestContext, Type controllerType)</p> <p>Timeout waiting for response, RequestId: 08cfa243-4a88-ba3a-20cf-307f54910000 at MassTransit.RequestResponse.RequestImpl<code>1.Wait() in d:\BuildAgent-03\work\8d1373c869590c5b\src\MassTransit\RequestResponse\RequestImpl.cs:line 124 at MassTransit.RequestResponseExtensions.PublishRequest[TRequest](IServiceBus bus, TRequest message, Action</code>1 configureCallback) in d:\BuildAgent-03\work\8d1373c869590c5b\src\MassTransit\RequestResponseExtensions.cs:line 31 at Producer.Website.Controllers.AccountController..ctor() in c:\Users\rick\Documents\Visual Studio 2012\Projects\ConsumerTest1\Producer.Website\Controllers\AccountController.cs:line 56</p> </blockquote> <p>Producer setup:</p> <pre><code> _bus = ServiceBusFactory.New(sbc =&gt; { sbc.UseMsmq(); sbc.VerifyMsmqConfiguration(); sbc.UseMulticastSubscriptionClient(); sbc.SetNetwork("Test"); sbc.ReceiveFrom("msmq://localhost/consumer_test_1"); }); </code></pre> <p>Producer send message:</p> <pre><code> var message = new AccountNewMessage() { CorrelationId = CombGuid.Generate(), UserName = “blah blah”, Password = “yada yada” }; this._bus.PublishRequest(message, r =&gt; { r.SetTimeout(30.Seconds()); r.Handle&lt;AccountNewMessageResponse&gt;(m =&gt; { var response = m; }); }); </code></pre> <p>Consumer setup:</p> <pre><code> this.bus = ServiceBusFactory.New(sbc =&gt; { sbc.UseMsmq(); sbc.VerifyMsmqConfiguration(); sbc.UseMulticastSubscriptionClient(); sbc.SetNetwork("Test"); sbc.ReceiveFrom("msmq://localhost/consumer_test_2"); sbc.Subscribe(subs =&gt; subs.Instance(new AccountNewMessageConsumer())); }); </code></pre> <p>Consumer:</p> <pre><code>public class AccountNewMessageConsumer : Consumes&lt;AccountNewMessage&gt;.Context { public void Consume(IConsumeContext&lt;AccountNewMessage&gt; context) { context.Respond(new AccountNewMessageResponse() { CorrelationId = context.Message.CorrelationId, ErrorCode = "1", UserId = new Random().Next(1, 10000).ToString() }); } } </code></pre> <p>Messages:</p> <pre><code>[Serializable] public class AccountNewMessage : CorrelatedBy&lt;Guid&gt; { public Guid CorrelationId { get; set; } public string UserName { get; set; } public string Password { get; set; } } [Serializable] public class AccountNewMessageResponse : CorrelatedBy&lt;Guid&gt; { public Guid CorrelationId { get; set; } public string UserId { get; set; } public string ErrorCode { get; set; } } </code></pre> <p>What am I doing wrong? Thank you.</p>
    singulars
    1. This table or related slice is empty.
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
 

Querying!

 
Guidance

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload