私は、Microsoft Storage Emulator で MassTransit を使用して、動作する構成を起動して実行しようとしています。しかし、私が何をしようとしても、それを機能させることはできません。
このセットアップに関する詳細は、http://docs.masstransit-project.com/en/latest/configuration/transports/azure.htmlのみです。
設定
- エミュレーターは実行中です
- キューの設定があります
- アクセスポリシーを作成しました
- SAS を作成しました
SAS を作成すると、http://127.0.0.1:10001/devstoreaccount1/validation? sv=2015-12-11&si=validation-1574305821E&sig=dM8amgmEXM8ykQwLpnrBI2AJmBS3agOvtR%2FskAJJqec%3Dのような URL を取得します。
しかし、Masstransitがプロトコルを「http://」ではなく「sb://」にする必要があると不平を言うので、私はそれを使用できません
現時点で持っているコードは
void Main()
{
var busControl = Bus.Factory.CreateUsingAzureServiceBus(sbc =>
{
var host = sbc.Host("sb://127.0.0.1", h =>
{
h.TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider("devstoreaccount1", "Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==");
});
sbc.ReceiveEndpoint("validation", a =>
{
}
);
});
var o = new Person(){Name = "Bob", DOB = new DateTime(1978, 10, 20) };
busControl.Start();
busControl.Publish(o);
busControl.Stop();
}
public class Person
{
public string Name {get;set;}
public DateTime DOB {get;set;}
}
でトークンを試しました
- アカウント名: devstoreaccount1
- アカウント キー: Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==
エラーが発生するコード行は、busControl.Start(); です。
私は何を間違っていますか?