Мое приложение состоит из приложения ASP.NET MVC 3 и службы Windows, находящихся в одном и том же устройстве. Приложение MVC использует MassTransit для размещения сообщений в очереди MSMQ. Служба использует MassTransit для чтения этих сообщений из MSMQ и выполнения некоторых действий. Когда я загружаю службу и приложение и запускаю их одновременно, кажется, что все работает нормально. Однако, если я загружаю только веб-приложение, мои сообщения не добавляются в MSMQ и практически исчезают. Странно то, что если я загружаю свое веб-приложение, а затем запускаю и немедленно останавливаю указанную службу, последующие сообщения, отправленные из веб-приложения, добавляются в очередь.
Было не так много хороших/современных примеров использования MassTransit со StructureMap и/или MVC, так что это может быть проблема с моей конфигурацией, но после нескольких часов проб и ошибок я не уверен, что делать дальше. Я также могу неправильно использовать MassTransit — на самом деле то, что мне нужно, — это быстрое решение от веб-приложения...
Мой сервис выглядит так:
class Program
{
static void Main(string[] args)
{
Bus.Initialize(sbc =>
{
sbc.UseMsmq();
sbc.VerifyMsmqConfiguration();
sbc.UseMulticastSubscriptionClient();
sbc.ReceiveFrom("msmq://localhost/receiver");
});
ObjectFactory.Initialize(x =>
{
x.AddRegistry(new EmailSenderRegistry());
});
var host = HostFactory.New(c =>
{
c.SetServiceName("MyApp.EmailMessageReader");
c.SetDisplayName("MyApp.EmailMessageReader");
c.SetDescription("MyApp.EmailMessageReader");
c.Service<ClientService>(a =>
{
a.ConstructUsing(service => new ClientService());
a.WhenStarted(o => o.Start());
a.WhenStopped(x=>x.Stop());
});
});
host.Run();
}
}
internal class ClientService
{
public void Start()
{
Bus.Instance.SubscribeConsumer<EmailPrepService>();
}
public void Stop()
{
// do nothing
}
}
public class EmailPrepService : Consumes<EmailMessage>.All
{
public void Consume(EmailMessage message)
{
PrepareEmailForSending(message);
var emailService = ObjectFactory.GetInstance<IEmailSender>();
emailService.SendEmail(message);
}
}
Мое веб-приложение выглядит так:
public class BusRegistry : Registry
{
public BusRegistry()
{
For<IServiceBus>().Singleton().Use(context => ServiceBusFactory.New(sbc =>
{
sbc.ReceiveFrom("msmq://localhost/sender");
sbc.UseMsmq();
sbc.UseMulticastSubscriptionClient();
sbc.UseControlBus();
sbc.Subscribe(subs => { subs.LoadFrom(context.GetInstance<IContainer>()); });
}));
}
}
Любая помощь будут оценены!