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

Класс QueueClient

Представляет объект клиента очереди.

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

public abstract class QueueClient : MessageClientEntity

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

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

  ИмяОписание
Открытый метод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)Асинхронно принимает сеанс обмена сообщениями, допускающий возможность группирования связанных сообщений для обработки в одну транзакцию по указанному идентификатору сеанса и времени ожидания.
Открытый метод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)Начинает асинхронную операцию приема сеанса обмена сообщениями.
Открытый метод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)Начинает асинхронную операцию получения пакета сообщений.
Открытый методBeginSendНачинает асинхронную операцию отправки сообщения.
Открытый методBeginSendBatchНачинает асинхронную операцию отправки пакета сообщений.
Открытый метод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)Создает новую копию QueueClient с указанным путем.
Открытый методСтатический элементCreate(String, ReceiveMode)Создает новую копию QueueClient с указанным путем и режимом.
Открытый методСтатический элементCreateFromConnectionString(String, String)Создает новую копию QueueClient по строке подключения с указанным путем.
Открытый методСтатический элементCreateFromConnectionString(String, String, ReceiveMode)Создает новую копию QueueClient по строке подключения с указанным путем и режимом.
Открытый метод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Завершает асинхронную операцию приема сеанса обмена сообщениями, допускающего возможность группирования связанных сообщений для обработки в одну транзакцию.
Открытый методEndCloseЗавершает асинхронную операцию для закрытия сущности клиента обмена сообщениями. (Производный от MessageClientEntity.)
Открытый методEndCompleteЗавершает асинхронную операцию завершения обработки сообщения.
Открытый методEndCompleteBatchЗавершает асинхронную операцию завершения обработки пакета сообщений.
Открытый методEndDeadLetterЗавершает асинхронную операцию перемещения сообщения в очередь недоставленных сообщений.
Открытый методEndDeferЗавершает асинхронную операцию приостановки обработки сообщения.
Открытый методEndGetMessageSessionsЗавершает асинхронную операцию получения сеансов обмена сообщениями.
Открытый методEndPeekЗаканчивает асинхронную операцию считывания сообщения.
Открытый методEndPeekBatchЗаканчивает асинхронную операцию считывания пакета сообщений.
Открытый методEndReceiveЗавершает асинхронную операцию получения сообщения.
Открытый методEndReceiveBatchЗавершает асинхронную операцию получения пакета сообщений.
Открытый методEndSendЗавершает асинхронную операцию отправки сообщения.
Открытый методEndSendBatchЗавершает асинхронную операцию отправки пакета сообщений.
Открытый методEquals (Производный от Object.)
Защищенный методFaultFor internal use only. Do not inherit from this class. (Производный от ClientEntity.)
Защищенный методFinalize (Производный от Object.)
Открытый методСтатический элементFormatDeadLetterPathСоздает имя формата по указанному пути очереди недоставленных сообщений.
Открытый методGetHashCode (Производный от Object.)
Открытый методGetMessageSessions()()()()Возвращает сеансы обмена сообщениями, что позволяет просматривать сеансы в очередях.
Открытый методGetMessageSessions(DateTime)Извлекает все сеансы сообщений, состояние сеансов которых было обновлено после lastUpdatedTime.
Открытый методGetMessageSessionsAsync()()()()Асинхронно получает или задает сеансы обмена сообщениями, обеспечивая обзор сеансов в очередях.
Открытый методGetMessageSessionsAsync(DateTime)Асинхронно извлекает все сеансы обмена сообщениями, состояние которых было обновлено после lastUpdatedTime.
Открытый методGetType (Производный от Object.)
Защищенный методMemberwiseClone (Производный от Object.)
Защищенный методOnAbortВыполняется после события Abort. (Переопределяет ClientEntity..::..OnAbort()()()().)
Защищенный методOnBeginAcceptMessageSessionВыполняется после вызова операции BeginAcceptMessageSession.
Защищенный методOnBeginCloseВыполняется при вызове операции Close. (Переопределяет ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object).)
Защищенный методOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)Выполняет действие начала создания получателя.
Защищенный методOnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)Выполняет действие начала создания получателя.
Защищенный методOnBeginCreateSenderВыполняет действие начала создания отправителя.
Защищенный методOnBeginGetMessageSessionsВыполняет действие BeginGetMessageSessions.
Защищенный методOnBeginOpen (Производный от ClientEntity.)
Защищенный методOnCloseВыполняется после вызова действия Close. (Переопределяет ClientEntity..::..OnClose(TimeSpan).)
Защищенный методOnClosed (Производный от ClientEntity.)
Защищенный методOnEndAcceptMessageSessionВыполняется после вызова операции EndAcceptMessageSession.
Защищенный методOnEndCloseВыполняет действие завершения закрытия. (Переопределяет ClientEntity..::..OnEndClose(IAsyncResult).)
Защищенный методOnEndCreateReceiverВыполняет действие завершения создания получателя.
Защищенный методOnEndCreateSenderВыполняет действие завершения создания отправителя.
Защищенный методOnEndGetMessageSessionsВыполняет действие завершения получения сообщения.
Защищенный методOnEndOpen (Производный от ClientEntity.)
Защищенный метод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)Асинхронно регистрирует фабрику обработчика сеанса обмена сообщениями.
Открытый методSendОтправляет сообщение через InternalSender()()()().
Открытый методSendAsyncАсинхронно отправляет сообщение посредством InternalSender()()()().
Открытый методSendBatchОтсылает набор сообщений для обмена через посредника (для пакетной обработки).
Открытый методSendBatchAsyncАсинхронно отправляет набор сообщений-посредников (для пакетной обработки).
Защищенный методThrowIfClosed (Производный от ClientEntity.)
Защищенный методThrowIfDisposed (Производный от ClientEntity.)
Защищенный методThrowIfDisposedOrImmutable (Производный от ClientEntity.)
Защищенный методThrowIfDisposedOrNotOpen (Производный от ClientEntity.)
Защищенный методThrowIfFaulted (Производный от ClientEntity.)
Открытый методToString (Производный от Object.)
В начало

This class is mainly used for Service Bus run-time operations, such as sending and receiving messages.

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

// Create the MessagingFactory
     MessagingFactory factory = 
     MessagingFactory.Create(myServiceBusNamespaceUri, SharedSecretTokenProvider.CreateSharedSecretTokenProvider(issuerName, issuerKey));
    
     //********************************************************************************
     //                          Sending messages to a Queue
     //********************************************************************************
    
     // Create queue client
     QueueClient myQueueClient = factory.CreateQueueClient("myQueue");
    
     // Send messages
     List <object>; Issues = new List <object>();
     foreach (var issue in Issues)
     {
        myQueueClient.Send(new BrokeredMessage(issue));
     }
    
     // ... Recieve messages
     for (int count = 0; count < MsgCount; count++)
     {
         var message = myQueueClient.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 символов осталось)
Спасибо за ваш отзыв

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

ДОБАВИТЬ
Корпорация Майкрософт проводит интернет-опрос, чтобы выяснить ваше мнение о веб-сайте MSDN. Если вы желаете принять участие в этом интернет-опросе, он будет отображен при закрытии веб-сайта MSDN.

Вы хотите принять участие?
Показ:
© 2014 Microsoft