紺碧とサービスバスをいじり始めたところです。複数のクライアントに同じメッセージを送信できるようにしようとしています。他のメッセージング ソリューションでは、トピックをリッスンしている複数のクライアントがあり、トピックにメッセージを送信すると、すべてのクライアントがメッセージを受信します。Azure では、サブスクライバーの 1 人だけがメッセージを受け取ります。私は誰かがポインタを提供できる何かが欠けていると確信していますか? 私のサンプルコードは以下です。
string connectionString =
"Endpoint=sb://xxx.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=xxxxxxxxxxxxxxxxxxxxxxxxxxxx=";
NamespaceManager namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
string topic = TestTopic.Replace("/", ".").Replace("{", "-").Replace("}", "-");
if (!namespaceManager.TopicExists(topic))
{
var td = new TopicDescription(topic)
{
MaxSizeInMegabytes = 5120,
DefaultMessageTimeToLive = new TimeSpan(0, 1, 0),
};
namespaceManager.CreateTopic(td);
}
var message = new {CurrencyCode = "AUD", EffectiveDate = DateTime.Today, Rate = .97M};
TopicClient publisher = TopicClient.CreateFromConnectionString(connectionString, topic);
var bm = new BrokeredMessage("fff");
bm.Properties["Topic"] = ".xxx.fxrates.aud";
int messagesReceived = 0;
int messagesReceived2 = 0;
if (namespaceManager.SubscriptionExists(topic, "test") == false)
{
SubscriptionDescription sub = namespaceManager.CreateSubscription(topic, "test");
}
SubscriptionClient subscriber = SubscriptionClient.CreateFromConnectionString(connectionString, topic,
"test",
ReceiveMode.ReceiveAndDelete);
SubscriptionClient subscriber2 = SubscriptionClient.CreateFromConnectionString(connectionString, topic,
"test",
ReceiveMode.ReceiveAndDelete);
subscriber.OnMessage(delegate { messagesReceived++; });
subscriber2.OnMessage(delegate { messagesReceived2++; });
publisher.Send(bm);
namespaceManager.DeleteTopic(topic);