Экспорт (0) Печать
Развернуть все

Класс MessageSender

Класс MessageSender используется для отправки сообщений из Service Bus. Хотя можно использовать класс QueueClient для отправки и получения сообщений без создания объекта MessageSender, можно также использовать MessageSender и MessageReceiver для создания отправителя и получателя для сущности без знания того, является она разделом или очередью.

Пространство имен:  Microsoft.ServiceBus.Messaging
Сборка:  Microsoft.ServiceBus (в Microsoft.ServiceBus.dll)

[<AbstractClassAttribute>]
type MessageSender =  
    class
        inherit MessageClientEntity
    end

Тип MessageSender обеспечивает доступ к следующим элементам.

  ИмяОписание
Открытое свойствоBatchFlushIntervalПолучает интервал сброса пакетов.
Защищенное свойствоBatchingEnabledПолучает значение, указывающее, включена ли пакетная обработка.
Открытое свойствоIsClosedПолучает или задает значение, указывающее закрыта ли сущность клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытое свойствоPathВозвращает путь очереди или раздела относительно базового адреса MessagingFactory.
Открытое свойствоRetryPolicyПолучает или задает политику повтора операций, связанную с этим экземпляром, которая определяет, следует ли повторять попытку выполнить запрос. (Производный от MessageClientEntity.)
Защищенное свойствоThisLockПолучает объект, использованный для блокировки экземпляра MessageClientEntity. (Производный от MessageClientEntity.)
В начало

  ИмяОписание
Открытый методAbortПрерывает работу сущности клиента обмена сообщениями и переводит ее в состояние закрытия. (Производный от MessageClientEntity.)
Открытый методBeginCloseНачинает асинхронную операцию для закрытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытый методBeginSendНачинает асинхронный запрос для отправки сообщения-посредника.
Открытый методBeginSendBatchНачинает асинхронный запрос для отправки сообщения-посредника пакетом.
Открытый методCloseЗакрывает сущность клиента обмена сообщениями и переводит ее в состояние закрытия. (Производный от MessageClientEntity.)
Открытый методCloseAsyncАсинхронно закрывает сущность клиента обмена сообщениями и переводит ее в закрытое состояние. (Производный от MessageClientEntity.)
Открытый методEndCloseЗавершает асинхронную операцию для закрытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытый методEndSendЗаканчивает асинхронный запрос для отправки сообщения.
Открытый методEndSendBatchЗаканчивает асинхронный запрос для отправки сообщения пактом.
Открытый методEquals (Производный от Object.)
Защищенный методFaultПомещает сущность клиента обмена сообщениями в состояние сбоя. (Производный от MessageClientEntity.)
Защищенный методFinalize (Производный от Object.)
Открытый методGetHashCode (Производный от Object.)
Открытый методGetType (Производный от Object.)
Защищенный методMemberwiseClone (Производный от Object.)
Защищенный методOnAbortВыполняется после вызова операции Abort. (Производный от MessageClientEntity.)
Защищенный методOnBeginCloseВыполняется после вызова операции BeginClose. (Производный от MessageClientEntity.)
Защищенный методOnBeginOpenВыполняется после вызова операции для начала открытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnBeginSendПозволяет конкретным реализациям определять действия при отправке сообщений. Этот метод не может быть реализован пользователем в конкретном классе.
Защищенный методOnCloseВыполняется после вызова операции Close. (Производный от MessageClientEntity.)
Защищенный методOnClosedПроисходит, когда сущность клиента обмена сообщениями переходит в состояние закрытия. (Производный от MessageClientEntity.)
Защищенный методOnEndCloseВыполняется после вызова операции EndClose. (Производный от MessageClientEntity.)
Защищенный методOnEndOpenВыполняется после вызова операции для завершения открытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnEndSendВыполняет действие завершения отправки. Этот метод не может быть реализован пользователем в конкретном классе.
Защищенный методOnFaultedВыполняется после вызова операции Fault. (Производный от MessageClientEntity.)
Защищенный методOnOpenВыполняется после вызова операции для открытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnOpenedВыполняется при открытии сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnRuntimeDescriptionChangedПорождает событие при изменении описания среды выполнения. (Производный от MessageClientEntity.)
Защищенный методOnSendПозволяет конкретным реализациям при необходимости переопределять действия при синхронной отправке сообщений.
Открытый методSendОтправляет указанное сообщение-посредник.
Открытый методSendAsyncАсинхронно отправляет указанное сообщение-посредник.
Открытый методSendBatchОтсылает набор сообщений для обмена через посредника (для пакетной обработки).
Открытый методSendBatchAsyncАсинхронно отправляет набор сообщений-посредников (для пакетной обработки).
Защищенный методThrowIfClosedСоздает исключение, если сущность клиента обмена сообщениями закрыта. (Производный от MessageClientEntity.)
Защищенный методThrowIfDisposedСоздает исключение, если сущность клиента обмена сообщениями освобождена. (Производный от MessageClientEntity.)
Защищенный методThrowIfDisposedOrImmutableСоздает исключение, если сущность клиента обмена сообщениями освобождена или неизменяема. (Производный от MessageClientEntity.)
Защищенный методThrowIfDisposedOrNotOpenСоздает исключение, если сущность клиента обмена сообщениями освобождена или не открыта. (Производный от MessageClientEntity.)
Защищенный методThrowIfFaultedСоздает исключение, если клиент находится в состоянии сбоя. (Производный от MessageClientEntity.)
Открытый методToString (Производный от Object.)
В начало

Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

The following example sends messages to a queue.

Uri serviceUri = ServiceBusEnvironment.CreateServiceUri("sb", ServiceNamespace, string.Empty); 

MessagingFactory factory = MessagingFactory.Create(serviceUri, credentials); 

MessageSender myMessageSender = factory.CreateMessageSender(queueName); 

List<BrokeredMessage> messageList = new List<BrokeredMessage>();
messageList.Add(CreateIssueMessage("1", "Package lost"));
messageList.Add(CreateIssueMessage("2", "Package damaged"));
messageList.Add(CreateIssueMessage("3", "Package defective"));

foreach (BrokeredMessage message in messageList)
{
    myMessageSender.Send(message);
    Console.WriteLine(
    string.Format("Message sent: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
}

Any public static (Shared in Visual Basic) members of this type are thread safe. Instance members are also guaranteed to be thread safe.

Добавления сообщества

ДОБАВИТЬ
Показ:
© 2014 Microsoft