以下のコードで InvalidOperationException が発生します。autofac IoC と Rebus に関する知識が不足しているため、このエラーが発生していると確信しています。
System.InvalidOperationException が処理されませんでした
Message=No message context available - MessageContext インスタンスはメッセージの処理中にのみ設定され、ワーカー スレッドでのみ使用できます。
スタックトレースの一部:
at Rebus.MessageContext.GetCurrent()
at Rebus.Autofac.AutofacContainerAdapter.GetHandlerInstancesFor[T]()
at RebusAutofacDemo.Program.Main(String[] args) in c:\RebusAutofacDemo\Program.cs:line 45
[cut]
そのため、コンソール アプリケーションで以下のコードを使用すると、上記のエラーが発生します。
class Program
{
static void Main(string[] args)
{
var builder = new Autofac.ContainerBuilder();
builder.RegisterType<MyHandler>();
var container = builder.Build();
var adapter = new AutofacContainerAdapter(container);
var bus = Configure.With(adapter)
.Transport(t => t.UseAzureServiceBus("myConnectionstring", "my_input_queue", "error"))
.CreateBus()
.Start();
adapter.GetHandlerInstancesFor<MyHandler>(); // THIS IS THE LINE WITH THE ERROR
var timer = new System.Timers.Timer();
timer.Elapsed += delegate { bus.SendLocal(new MyMessage{ Body = DateTime.Now.ToString()}); };
timer.Interval = 1000;
timer.Start();
Console.ReadLine();
}
}
public class MyMessage
{
public string Body { get; set; }
}
public class MyHandler : IHandleMessages<MyMessage>
{
private readonly IBus _bus;
public MyHandler(IBus bus)
{
_bus = bus;
}
public void Handle(MyMessage message)
{
Console.WriteLine(message);
}
}
完全を期すために、これは app.config に追加されました。
<configSections>
<section name="rebus" type="Rebus.Configuration.RebusConfigurationSection, Rebus" />
</configSections>
<rebus inputQueue="my-app.input" errorQueue="my-app.error" workers="1">
<endpoints>
<!-- <add messages="SomeAssembly" endpoint="another-app.input"/> -->
</endpoints>
</rebus>