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

Класс MessageReceiver

Получает сообщения из контейнера сообщений и подтверждает их.

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

'Декларация
Public MustInherit Class MessageReceiver _
	Inherits MessageClientEntity
'Применение
Dim instance As MessageReceiver

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

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

  ИмяОписание
Открытый методAbandon(Guid)Выполняет отказ от сообщения и освобождает его блокировку.
Открытый методAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Выполняет отказ от сообщения и освобождает его блокировку.
Открытый методAbandonAsync(Guid)Асинхронно отклоняет сообщение и снимает его блокировку.
Открытый методAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Асинхронно отклоняет сообщение и снимает его блокировку.
Открытый методAbortПрерывает работу сущности клиента обмена сообщениями и переводит ее в состояние закрытия. (Производный от MessageClientEntity.)
Открытый методBeginAbandon(Guid, AsyncCallback, Object)Начинает асинхронную операцию отказа от сообщения и освобождения его блокировки.
Открытый методBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Начинает асинхронную операцию отказа от сообщения и освобождения его блокировки.
Открытый методBeginCloseНачинает асинхронную операцию для закрытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытый методBeginCompleteНачинает асинхронную операцию завершения получения сообщения.
Открытый методBeginCompleteBatchНачинает асинхронную операцию завершения пакетной обработки сообщений.
Открытый методBeginDeadLetter(Guid, AsyncCallback, Object)Начинает асинхронную операцию перемещения сообщения в очередь недоставленных сообщений.
Открытый методBeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Начинает асинхронную операцию перемещения сообщения в очередь недоставленных сообщений.
Открытый методBeginDeadLetter(Guid, String, String, AsyncCallback, Object)Начинает асинхронную операцию перемещения сообщения в очередь недоставленных сообщений.
Открытый методBeginDefer(Guid, AsyncCallback, Object)Начинает асинхронную операцию приостановки получения сообщения.
Открытый методBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Начинает асинхронную операцию приостановки получения сообщения.
Открытый методBeginPeek(AsyncCallback, Object)Начинает операцию считывания сообщения.
Открытый методBeginPeek(Int64, AsyncCallback, Object)Начинает операцию считывания сообщения.
Открытый методBeginPeekBatch(Int32, AsyncCallback, Object)Начинает операцию считывания пакета сообщений.
Открытый методBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Начинает операцию считывания пакета сообщений.
Открытый методBeginReceive(AsyncCallback, Object)Начинает асинхронную операцию получения сообщения.
Открытый методBeginReceive(Int64, AsyncCallback, Object)Начинает асинхронную операцию получения сообщения.
Открытый методBeginReceive(TimeSpan, AsyncCallback, Object)Начинает асинхронную операцию получения сообщения.
Открытый методBeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)Начинает асинхронную операцию получения пакета сообщений.
Открытый методBeginReceiveBatch(Int32, AsyncCallback, Object)Начинает асинхронную операцию получения пакета сообщений.
Открытый методBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Начинает асинхронную операцию получения пакета сообщений.
Открытый методCloseЗакрывает сущность клиента обмена сообщениями и переводит ее в состояние закрытия. (Производный от MessageClientEntity.)
Открытый методCloseAsyncАсинхронно закрывает сущность клиента обмена сообщениями и переводит ее в закрытое состояние. (Производный от MessageClientEntity.)
Открытый методCompleteЗавершает операцию получения сообщения.
Открытый методCompleteAsyncАсинхронно завершает операцию получения сообщения.
Открытый методCompleteBatchЗавершает операцию получения пакета сообщений.
Открытый методCompleteBatchAsyncАсинхронно завершает операцию получения пакета сообщений.
Открытый методDeadLetter(Guid)Перемещает недоставленное сообщение в очередь недоставленных сообщений.
Открытый методDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))Перемещает недоставленное сообщение в очередь недоставленных сообщений.
Открытый методDeadLetter(Guid, String, String)Перемещает недоставленное сообщение в очередь недоставленных сообщений.
Открытый методDeadLetterAsync(Guid)Асинхронно перемещает недоставленное сообщение в очередь недоставленных сообщений.
Открытый методDeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Асинхронно перемещает недоставленное сообщение в очередь недоставленных сообщений.
Открытый методDeadLetterAsync(Guid, String, String)Асинхронно перемещает недоставленное сообщение в очередь недоставленных сообщений.
Открытый методDefer(Guid)Указывает, что получатель хочет отложить обработку этого сообщения.
Открытый методDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Указывает, что получатель хочет отложить обработку этого сообщения.
Открытый методDeferAsync(Guid)Асинхронно отсрочивает обработку сообщения.
Открытый методDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Асинхронно отсрочивает обработку сообщения.
Открытый методEndAbandonЗавершает асинхронную операцию отказа от сообщения и освобождения его блокировки.
Открытый методEndCloseЗавершает асинхронную операцию для закрытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытый методEndCompleteЗаканчивает асинхронную операцию для выполнения получения сообщения.
Открытый методEndCompleteBatchЗавершает асинхронную операцию завершения получения пакета сообщений.
Открытый методEndDeadLetterЗавершает асинхронную операцию для перемещения сообщения в очередь недоставленных сообщений.
Открытый методEndDeferЗаканчивает асинхронную операцию для отсрочки получения сообщения.
Открытый методEndPeekЗаканчивает асинхронную операцию считывания сообщения.
Открытый методEndPeekBatchЗаканчивает асинхронную операцию считывания пакета сообщений.
Открытый методEndReceiveЗаканчивает асинхронную операцию получения сообщения.
Открытый методEndReceiveBatchЗавершает асинхронную операцию получения пакета сообщений.
Открытый методEquals (Производный от Object.)
Защищенный методFaultПомещает сущность клиента обмена сообщениями в состояние сбоя. (Производный от MessageClientEntity.)
Защищенный методFinalize (Производный от Object.)
Открытый методGetHashCode (Производный от Object.)
Защищенный методСтатический элементGetLockTokenПолучает маркер блокировки сообщения.
Защищенный методСтатический элементGetLockTokensПолучает коллекцию маркеров блокировки по заданной коллекции сообщений.
Открытый методGetType (Производный от Object.)
Защищенный методMemberwiseClone (Производный от Object.)
Защищенный методOnAbandonВыполняется после вызова операции Abandon.
Защищенный методOnAbortВыполняется после вызова операции Abort. (Производный от MessageClientEntity.)
Защищенный методOnBeginAbandonВызывается после операции OnAbandon или BeginAbandon.
Защищенный методOnBeginCloseВыполняется после вызова операции BeginClose. (Производный от MessageClientEntity.)
Защищенный методOnBeginCompleteВызывается после операции OnComplete или BeginComplete.
Защищенный методOnBeginDeadLetterВызывается после операции OnDeadLetter или BeginDeadLetter.
Защищенный методOnBeginDeferВызывается после операции OnDefer или BeginDefer.
Защищенный методOnBeginOpenВыполняется после вызова операции для начала открытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnBeginPeekВыполняется после вызова операции BeginPeek.
Защищенный методOnBeginRenewMessageLocksВыполняется после вызова операции OnBegin для блокировки сообщений.
Защищенный методOnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)Вызывается после операции OnTryReceive или BeginTryReceive.
Защищенный методOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)Вызывается после операции OnTryReceive или BeginTryReceive.
Защищенный методOnBeginTryReceive2Вызывается после операции OnTryReceive или BeginTryReceive.
Защищенный методOnCloseВыполняется после вызова операции Close. (Производный от MessageClientEntity.)
Защищенный методOnClosedПроисходит, когда сущность клиента обмена сообщениями переходит в состояние закрытия. (Производный от MessageClientEntity.)
Защищенный методOnCompleteВыполняется после вызова операции Complete.
Защищенный методOnDeadLetterВыполняется после вызова операции DeadLetter.
Защищенный методOnDeferВыполняется после вызова операции Defer.
Защищенный методOnEndAbandonВыполняет действие завершения отказа.
Защищенный методOnEndCloseВыполняется после вызова операции EndClose. (Производный от MessageClientEntity.)
Защищенный методOnEndCompleteВыполняет действие завершения выполнения.
Защищенный методOnEndDeadLetterВыполняет действие завершения перемещения сообщения в очередь недоставленных сообщений.
Защищенный методOnEndDeferВыполняет действие завершения отсрочки.
Защищенный методOnEndOpenВыполняется после вызова операции для завершения открытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnEndPeekВыполняет операцию EndPeek.
Защищенный методOnEndRenewMessageLocksВыполняет действие EndRenew для блокировки сообщений.
Защищенный методOnEndTryReceiveВыполняет действие завершения попытки получения.
Защищенный методOnEndTryReceive2Выполняет действие завершения попытки получения.
Защищенный методOnFaultedВыполняется после вызова операции Fault. (Производный от MessageClientEntity.)
Открытый методOnMessageОбрабатывает сообщение в конвейере сообщений, управляемом событиями.
Открытый методOnMessageAsyncАсинхронно обрабатывает сообщение в конвейере сообщений, управляемом событиями.
Защищенный методOnOpenВыполняется после вызова операции для открытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnOpenedВыполняется при открытии сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Защищенный методOnPeekВыполняется после вызова операции Peek.
Защищенный методOnRenewMessageLocksВыполняет действие Renew для блокировки сообщений.
Защищенный методOnRuntimeDescriptionChangedПорождает событие при изменении описания среды выполнения. (Производный от MessageClientEntity.)
Защищенный методOnTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Выполняется после вызова операции TryReceive.
Защищенный методOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Выполняется после вызова операции TryReceive.
Открытый методPeek()()()()Читает следующее сообщение, не изменяя состояние получателя или источника сообщения.
Открытый методPeek(Int64)Читает следующее сообщение, не изменяя состояние получателя или источника сообщения.
Открытый методPeekAsync()()()()Асинхронно читает следующее сообщение, не изменяя состояние получателя или источника сообщения.
Открытый методPeekAsync(Int64)Асинхронно читает следующее сообщение, не изменяя состояние получателя или источника сообщения.
Открытый методPeekBatch(Int32)Читает следующий пакет сообщений, не изменяя состояние получателя или источника сообщения.
Открытый методPeekBatch(Int64, Int32)Читает следующий пакет сообщений, не изменяя состояние получателя или источника сообщения.
Открытый методPeekBatchAsync(Int32)Асинхронно читает следующий пакет сообщений, не изменяя состояние получателя или источника сообщения.
Открытый методPeekBatchAsync(Int64, Int32)Асинхронно читает следующий пакет сообщений, не изменяя состояние получателя или источника сообщения.
Открытый методReceive()()()()Получает BrokeredMessage из текущей очереди или раздела.
Открытый методReceive(Int64)Получает сообщение из текущей очереди или раздела.
Открытый методReceive(TimeSpan)Получает BrokeredMessage из текущей очереди или раздела.
Открытый методReceiveAsync()()()()Асинхронно получает сообщение из текущей очереди или раздела.
Открытый методReceiveAsync(Int64)Асинхронно получает сообщение из текущей очереди или раздела.
Открытый методReceiveAsync(TimeSpan)Асинхронно получает сообщение из текущей очереди или раздела.
Открытый методReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Получает пакет сообщений.
Открытый методReceiveBatch(Int32)Получает пакет сообщений.
Открытый методReceiveBatch(Int32, TimeSpan)Получает пакет сообщений.
Открытый методReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Асинхронно получает пакет сообщений.
Открытый методReceiveBatchAsync(Int32)Асинхронно получает пакет сообщений.
Открытый методReceiveBatchAsync(Int32, TimeSpan)Асинхронно получает пакет сообщений.
Защищенный методThrowIfClosedСоздает исключение, если сущность клиента обмена сообщениями закрыта. (Производный от MessageClientEntity.)
Защищенный методThrowIfDisposedСоздает исключение, если сущность клиента обмена сообщениями освобождена. (Производный от MessageClientEntity.)
Защищенный методThrowIfDisposedOrImmutableСоздает исключение, если сущность клиента обмена сообщениями освобождена или неизменяема. (Производный от MessageClientEntity.)
Защищенный методThrowIfDisposedOrNotOpenСоздает исключение, если сущность клиента обмена сообщениями освобождена или не открыта. (Производный от MessageClientEntity.)
Защищенный методThrowIfFaultedСоздает исключение, если клиент находится в состоянии сбоя. (Производный от MessageClientEntity.)
Открытый методToString (Производный от Object.)
В начало

Although you can use the QueueClient class to send and receive messages without creating a MessageReceiver object, you can also use MessageSender and MessageReceiver to create a sender and receiver on an entity. However, note that you can only use a MessageReceiver to receive messages from a queue or subscription; you cannot receive messages or listen for messages from a topic. Similarly, you can only use a MessageSender to send messages to a queue or topic; you cannot send messages to a subscription. Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

When you create a MessageReceiver for subscriptions, the entityPath parameter is of the form topicPath/subscriptions/subscriptionName.

The following example receives a message from the queue created in the MessageSender example:

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

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

MessageReceiver myMessageReceiver = factory.CreateMessageReceiver(queueName);

BrokeredMessage message;
while ((message = myMessageReceiver.Receive(new TimeSpan(hours: 0, minutes: 1, seconds: 5))) != null)
{
    Console.WriteLine(
    string.Format(
    "Message received: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
    message.Complete();
}

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