7
के साथ मास ट्रांजिट में प्रतिस्पर्धी उपभोक्ता मैंने मैसट्रांसिट के साथ एक साधारण प्रकाशक/उपभोक्ता सेट लागू किया है, और मैं उपभोक्ताओं को एक ही कतार से संदेश पढ़ना चाहता हूं। हालांकि, जब मैं इसे चलाता हूं, तो मुझे खपत के बजाय त्रुटि कतार में भेजे गए संदेशों का एक बड़ा हिस्सा दिखाई देता है। मैंने देखा है कि चर्चाओं से (SO, Forum), यह वास्तव में खरगोश एमक्यू (केवल उसी कतार को इंगित करें) के साथ वास्तव में सरल होना चाहिए, लेकिन यह काम नहीं कर रहा है। क्या कोई अतिरिक्त कॉन्फ़िगरेशन सेट किया जाना चाहिए?खरगोश एमक्यू
यहाँ मेरे प्रकाशक
public class YourMessage { public string Text { get; set; } }
public class Program
{
public static void Main()
{
Console.WriteLine("Publisher");
Bus.Initialize(sbc =>
{
sbc.UseRabbitMqRouting();
sbc.ReceiveFrom("rabbitmq://localhost/test_queue");
});
var x = Console.Read();
for (var i = 0; i <= 1000; i++)
{
Console.WriteLine("Message Number " + i);
Bus.Instance.Publish(new YourMessage { "Message Number " + i });
}
}
}
और मेरे उपभोक्ता
public class YourMessage { public string Text { get; set; } }
public class Program
{
public static void Main()
{
Console.WriteLine("Consumer");
Bus.Initialize(sbc =>
{
sbc.UseRabbitMqRouting();
sbc.ReceiveFrom("rabbitmq://localhost/test_queue");
sbc.Subscribe(subs =>
{
var del = new Action<IConsumeContext<YourMessage>,YourMessage>((context, msg) =>
{
Console.WriteLine(msg.Text);
});
subs.Handler<YourMessage>(del);
});
});
while (true) { }
}
}