Шаг 3. Отправка сообщений в очередь
Это третий шаг в учебнике по возможностям обмена сообщениями в Service Bus. В данном шаге вы создаете очередь, а затем отправляете в нее сообщения из списка сообщений с посредническими отношениями.
Создание сообщений и отправка их в очередь
-
Прежде всего, создайте очередь. Например, назовите ее
myQueueи объявите непосредственно после операций по управлению, добавленных в предыдущем шаге:QueueDescription myQueue; myQueue = namespaceClient.CreateQueue("IssueTrackingQueue"); -
В методе
Queue()создайте объект фабрики обмена сообщениями, используя новый созданный URI Service Bus в качестве аргумента. Добавьте следующий код непосредственно после операций по управлению, добавленных в предыдущем шаге:MessagingFactory factory = MessagingFactory.Create(ServiceBusEnvironment.CreateServiceUri("sb", ServiceNamespace, string.Empty), credentials);
-
После этого создайте объект очереди с помощью класса QueueClient. Добавьте следующий код непосредственно после кода, добавленного в предыдущем шаге:
QueueClient myQueueClient = factory.CreateQueueClient("IssueTrackingQueue"); -
После этого добавьте код, который выполняет цикл по списку сообщений с посредническими отношениями, созданных и заполненных вами в шаге 1 данного учебника, и отправляет каждое из них в очередь. Добавьте следующий код непосредственно после оператора
CreateQueueClient()в предыдущем шаге:// Send messages Console.WriteLine("Now sending messages to the Queue."); for (int count = 0; count < 6; count++) { var issue = MessageList[count]; issue.Label = issue.Properties["IssueTitle"].ToString(); myQueueClient.Send(issue); Console.WriteLine(string.Format("Message sent: {0}, {1}", issue.Label, issue.MessageId)); }