Продажи: 1-800-867-1389

Класс SubscriptionClient

Представляет класс привязки, используемый в операциях среды выполнения, связанных с подпиской на раздел.

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

public abstract class SubscriptionClient : MessageClientEntity

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

  ИмяОписание
Открытое свойствоIsClosed (Производный от ClientEntity.)
Открытое свойствоMessagingFactoryПолучает фабрику сообщений, использованную для создания этого клиента подписки.
Открытое свойствоModeВозвращает режим получения сообщений при обработке полученного сообщения.
Открытое свойствоNameВозвращает имя подписки.
Открытое свойствоPrefetchCountВозвращает или задает количество сообщений, которые получатель сообщений может одновременно запросить.
Открытое свойствоRetryPolicy (Производный от ClientEntity.)
Защищенное свойствоThisLock (Производный от ClientEntity.)
Открытое свойствоTopicPathВозвращает полный путь к разделу.
В начало

  ИмяОписание
Открытый методAbandon(Guid)Выполняет отказ от сообщения и освобождает его блокировку.
Открытый методAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Выполняет отказ от сообщения и освобождает его блокировку.
Открытый методAbandonAsync(Guid)Асинхронно отклоняет сообщение и снимает его блокировку.
Открытый методAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Асинхронно отклоняет сообщение и снимает его блокировку.
Открытый методAbortPerforms abort functionality on the messaging entity. (Производный от ClientEntity.)
Открытый методAcceptMessageSession()()()()Принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию.
Открытый методAcceptMessageSession(String)Принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному идентификатору сеанса.
Открытый методAcceptMessageSession(TimeSpan)Принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному времени ожидания сервера.
Открытый методAcceptMessageSession(String, TimeSpan)Принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному идентификатору сеанса и времени ожидания.
Открытый методAcceptMessageSessionAsync()()()()Асинхронно принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному времени ожидания сервера.
Открытый методAcceptMessageSessionAsync(String)Асинхронно принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному времени ожидания сервера.
Открытый методAcceptMessageSessionAsync(TimeSpan)Асинхронно принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному времени ожидания сервера.
Открытый методAcceptMessageSessionAsync(String, TimeSpan)Асинхронно принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному времени ожидания сервера.
Открытый методAddRule(RuleDescription)Добавляет новое правило в Subscription с использованием указанного описания правила.
Открытый методAddRule(String, Filter)Добавляет правило к текущей подписке с использованием указанного имени и выражения фильтра.
Открытый методAddRuleAsync(RuleDescription)Асинхронно добавляет новое правило в Subscription с использованием указанного описания правила.
Открытый методAddRuleAsync(String, Filter)Асинхронно добавляет правило к текущей подписке с использованием указанного имени и выражения фильтра.
Открытый методBeginAbandon(Guid, AsyncCallback, Object)Начинает асинхронную операцию отказа от сообщения и освобождения его блокировки.
Открытый методBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Начинает асинхронную операцию отказа от сообщения и освобождения его блокировки.
Открытый методBeginAcceptMessageSession(AsyncCallback, Object)Начинает асинхронную операцию приема сеанса обмена сообщениями.
Открытый методBeginAcceptMessageSession(String, AsyncCallback, Object)Начинает асинхронную операцию приема сеанса обмена сообщениями.
Открытый методBeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)Начинает асинхронную операцию приема сеанса обмена сообщениями.
Открытый методBeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)Начинает асинхронную операцию приема сеанса обмена сообщениями.
Открытый методBeginAddRule(RuleDescription, AsyncCallback, Object)Начинает асинхронную операцию для добавления нового правила в подписку.
Открытый методBeginAddRule(String, Filter, 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)Начинает асинхронную операцию приостановки обработки сообщения.
Открытый методBeginGetMessageSessions(AsyncCallback, Object)Начинает асинхронную операцию получения сеанса обмена сообщениями.
Открытый методBeginGetMessageSessions(DateTime, 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)Начинает асинхронную операцию получения пакета.
Открытый методBeginRemoveRuleНачинает асинхронное действие удаления правила.
Открытый методCloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (Производный от ClientEntity.)
Открытый методCloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (Производный от ClientEntity.)
Открытый методCompleteЗавершает обработку сообщения.
Открытый методCompleteAsyncАсинхронно завершает обработку сообщения.
Открытый методCompleteBatchЗавершает обработку пакета.
Открытый методCompleteBatchAsyncАсинхронно завершает обработку пакета.
Открытый методСтатический элементCreate(String, String)Создает новую копию SubscriptionClient с указанным именем и путем раздела.
Открытый методСтатический элементCreate(String, String, ReceiveMode)Создает новую копию SubscriptionClient с указанным именем, режимом и путем раздела.
Открытый методСтатический элементCreateFromConnectionString(String, String, String)Создает новую копию SubscriptionClient по строке подключения с указанным именем и путем раздела.
Открытый методСтатический элементCreateFromConnectionString(String, String, String, ReceiveMode)Создает новую копию SubscriptionClient по строке подключения с указанным именем, режимом и путем раздела.
Открытый метод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Завершает асинхронную операцию отказа от сообщения и освобождения его блокировки.
Открытый методEndAcceptMessageSessionЗавершает асинхронную операцию приема сеанса обмена сообщениями, допускающего возможность группирования связанных сообщений для обработки в одну транзакцию.
Открытый методEndAddRuleЗавершает асинхронную операцию добавления правила.
Открытый методEndCloseЗавершает асинхронную операцию для закрытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытый методEndCompleteЗавершает асинхронную операцию завершения обработки сообщения.
Открытый методEndCompleteBatchЗавершает асинхронную операцию завершения обработки пакета.
Открытый методEndDeadLetterЗавершает асинхронную операцию перемещения сообщения в очередь недоставленных сообщений.
Открытый методEndDeferЗавершает асинхронную операцию приостановки обработки сообщения.
Открытый методEndGetMessageSessionsЗавершает асинхронную операцию получения обработки сообщения.
Открытый методEndPeekЗаканчивает асинхронную операцию считывания.
Открытый методEndPeekBatchЗаканчивает асинхронную операцию считывания пакета сообщений.
Открытый методEndReceiveЗавершает асинхронную операцию получения сообщения.
Открытый методEndReceiveBatchЗавершает асинхронную операцию получения пакета.
Открытый методEndRemoveRuleЗавершает асинхронную операцию удаления правила.
Открытый методEquals (Производный от Object.)
Защищенный методFaultFor internal use only. Do not inherit from this class. (Производный от ClientEntity.)
Защищенный методFinalize (Производный от Object.)
Открытый методСтатический элементFormatDeadLetterPathСоздает путь очереди недоставленных сообщений с форматом имени по указанному пути раздела и имени подписки.
Открытый методСтатический элементFormatSubscriptionPathСоздает путь подписки с форматом имени по указанному пути раздела и имени подписки.
Открытый методGetHashCode (Производный от Object.)
Открытый методGetMessageSessions()()()()Получает сеанс сообщений, допускающий возможность группирования связанных сообщений для обработки за одну транзакцию.
Открытый методGetMessageSessions(DateTime)Извлекает все сеансы сообщений, состояние сеансов которых было обновлено после lastUpdatedTime.
Открытый методGetMessageSessionsAsync()()()()Асинхронно получает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию.
Открытый методGetMessageSessionsAsync(DateTime)Асинхронно получает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию.
Открытый методGetType (Производный от Object.)
Защищенный методMemberwiseClone (Производный от Object.)
Защищенный методOnAbortВыполняет действие прерывания. (Переопределяет ClientEntity..::..OnAbort()()()().)
Защищенный методOnBeginAcceptMessageSessionВыполняется после вызова операции BeginAcceptMessageSession.
Защищенный методOnBeginAddRuleВыполняется после вызова операции BeginAddRule.
Защищенный методOnBeginCloseВыполняет действие начала закрытия. (Переопределяет ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object).)
Защищенный методOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)Выполняет действие начала создания получателя.
Защищенный методOnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object)Выполняет действие начала создания получателя.
Защищенный методOnBeginGetMessageSessionsВыполняется после вызова операции BeginGetMessageSessions.
Защищенный методOnBeginOpen (Производный от ClientEntity.)
Защищенный методOnBeginRemoveRuleНачинает удаление Rule из Subscription через клиентский протокол времени выполнения.
Защищенный методOnBeginRemoveRulesByTagНачинает удаление Rule из Subscription через клиентский протокол среды выполнения, используя тег.
Защищенный методOnCloseВыполняет действие закрытия. (Переопределяет ClientEntity..::..OnClose(TimeSpan).)
Защищенный методOnClosed (Производный от ClientEntity.)
Защищенный методOnEndAcceptMessageSessionВыполняется после вызова операции EndAcceptMessageSession.
Защищенный методOnEndAddRuleЗавершает асинхронный вызов OnBeginAddRule.
Защищенный методOnEndCloseВыполняет действие завершения закрытия. (Переопределяет ClientEntity..::..OnEndClose(IAsyncResult).)
Защищенный методOnEndCreateReceiverВыполняет действие завершения создания получателя.
Защищенный методOnEndGetMessageSessionsВыполняет действие завершения получения сообщения.
Защищенный методOnEndOpen (Производный от ClientEntity.)
Защищенный методOnEndRemoveRuleЗавершает асинхронный вызов OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Защищенный методOnEndRemoveRulesЗавершает асинхронный вызов OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Защищенный методOnFaulted (Производный от ClientEntity.)
Открытый методOnMessage(Action<(Of <<'(BrokeredMessage>)>>))Обрабатывает сообщение в конвейере сообщений, управляемом событиями.
Открытый методOnMessage(Action<(Of <<'(BrokeredMessage>)>>), OnMessageOptions)Обрабатывает сообщение в конвейере сообщений, управляемом событиями, с заданным набором параметров OnMessageOptions.
Открытый методOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>))Асинхронно обрабатывает сообщение.
Открытый методOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>), OnMessageOptions)Асинхронно обрабатывает сообщение.
Защищенный методOnOpen (Производный от ClientEntity.)
Защищенный методOnOpened (Производный от ClientEntity.)
Открытый методPeek()()()()Возвращает значение, не перемещая первое сообщение в очереди.
Открытый методPeek(Int64)Возвращает значение, не перемещая первое сообщение в очереди.
Открытый методPeekAsync()()()()Асинхронно возвращает значение, не перемещая первое сообщение в очереди.
Открытый методPeekAsync(Int64)Асинхронно возвращает значение, не перемещая первое сообщение в очереди.
Открытый методPeekBatch(Int32)Возвращает значение, не перемещая первое сообщение в пакете.
Открытый методPeekBatch(Int64, Int32)Возвращает значение, не перемещая первое сообщение в пакете.
Открытый методPeekBatchAsync(Int32)Асинхронно возвращает значение, не перемещая первое сообщение в пакете.
Открытый методPeekBatchAsync(Int64, Int32)Асинхронно возвращает значение, не перемещая первое сообщение в пакете.
Открытый методReceive()()()()Получает сообщение через InternalReceiver()()()().
Открытый методReceive(Int64)Получает сообщение через InternalReceiver()()()().
Открытый методReceive(TimeSpan)Получает сообщение через InternalReceiver()()()().
Открытый методReceiveAsync()()()()Асинхронно получает сообщение посредством InternalReceiver()()()().
Открытый методReceiveAsync(Int64)Асинхронно получает сообщение посредством InternalReceiver()()()().
Открытый методReceiveAsync(TimeSpan)Асинхронно получает сообщение посредством InternalReceiver()()()().
Открытый методReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Получает пакет после асинхронной операции.
Открытый методReceiveBatch(Int32)Получает пакет после асинхронной операции.
Открытый методReceiveBatch(Int32, TimeSpan)Получает пакет после асинхронной операции.
Открытый методReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Асинхронно получает набор сообщений (для пакетной обработки).
Открытый методReceiveBatchAsync(Int32)Асинхронно получает набор сообщений (для пакетной обработки).
Открытый методReceiveBatchAsync(Int32, TimeSpan)Асинхронно получает набор сообщений (для пакетной обработки).
Открытый методRegisterSessionHandler(Type)Регистрирует обработчик сеанса клиента.
Открытый методRegisterSessionHandler(Type, SessionHandlerOptions)Регистрирует обработчик сеанса клиента.
Открытый методRegisterSessionHandlerAsync(Type)Асинхронно регистрирует обработчик сеанса клиента.
Открытый методRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Асинхронно регистрирует обработчик сеанса клиента.
Открытый методRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Регистрирует фабрику обработчика сеанса клиента.
Открытый методRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Регистрирует фабрику обработчика сеанса клиента.
Открытый методRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Асинхронно регистрирует фабрику обработчика сеанса клиента.
Открытый методRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Асинхронно регистрирует фабрику обработчика сеанса клиента.
Открытый методRemoveRuleУдаляет правило, указанное ruleName.
Открытый методRemoveRuleAsyncАсинхронно удаляет правило, описанное ruleName.
Защищенный методThrowIfClosed (Производный от ClientEntity.)
Защищенный методThrowIfDisposed (Производный от ClientEntity.)
Защищенный методThrowIfDisposedOrImmutable (Производный от ClientEntity.)
Защищенный методThrowIfDisposedOrNotOpen (Производный от ClientEntity.)
Защищенный методThrowIfFaulted (Производный от ClientEntity.)
Открытый методToString (Производный от Object.)
В начало

This abstract class is not meant to be inherited, so protected members of this class should be ignored.

// Create subscription client
SubscriptionClient mySubscriptionClient = 
factory.CreateSubscriptionClient(topicName, subscriptionName);

// Create a receiver
MessageReceiver myMessageReceiver = mySubscriptionClient.CreateReceiver(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count &lt; MsgCount; count++)
{
    var message = subscriptionClient.Receive();
    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.

Была ли вам полезна эта информация?
(1500 символов осталось)
Спасибо за ваш отзыв

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

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