c# - Messages do not reach subscriber in masstransit -


I have projects in two different processes and are RMQA posted on a separate machine.

Publisher Code 

  Bus.Initialize (config = & gt; {config.UseRabbitMq (); config.UseRabbitMqRouting (); config.UseControlBus (); config.EnableMessageTracing (); Config.EnableRemoteIntrospection (); Config.ReceiveFrom ("rabbitmq: // debug: debug@data.sampleserver.com: 5672 / bus / response-queue");}); Console.ReadLine (); Int i = 0; While (i & lt; 20) {i + = 1; Console.WriteLine ("publication ..."); Bus.Instance.Publish (new message {body = string.format ("body = {0}", i)}); Console.ReadLine (); } Console. Readline ();   
 Here is my customer code:  
  Bus.Initialize (config = & gt; {config.UseRabbitMq (); config.UseRabbitMqRouting (); config . ReceiveFrom ("RabbitMQ: // debug: debug@data.sampleserver.com: 5672 / bus / response-line"); config.UseControlBus (); config.EnableMessageTracing (); config.UseHealthMonitoring (10);}); Service = HostFactory.New (config = & gt; {config.SetServiceName ("survey"); config.SetDisplayName ("survey"); config.SetDescription ("survey service"); config.Service & lt; service & gt; ; (S => {s.ConstructUsing (sv = & gt; New Bus.Instance); s.WhenStarted (sv = & gt; sv.Start ()); s.WhenStopped (sv = & gt; ; Sv.Stop ());});}); Work. Resource. Start (+) => {{service.Run ()}} Capture (Exception e) {console. WrightLine (e);}}); In the server, I have the following subscription:  
  Public service (IServiceBus serviceBus) {_serviceBus = serviceBus; _serviceBus.SubscribeHandler & LT; Message & gt; (the handle); } Zero handle (message message) {Console.WriteLine ("Get a new message with body", message body); }   
 When I send a set of messages by publishers, some of them successfully reach the customer. Most of them come in response-queue error  
 I'm new to the mastist and I do not understand what's going on inside and do not understand how I understand it I can.  
 Whatever you can recommend in this situation 
 
 
 I have noticed that your example In the publisher and client are listening on the same queue. In general, you should have each end point on a separate line. Based on the Mastrancit type, it will take care to routing the message.

Comments

Post a Comment