QueueClient Classe

Definição

Representa o objeto de cliente de fila.

public abstract class QueueClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type QueueClient = class
    inherit MessagingEntityClient
Public MustInherit Class QueueClient
Inherits MessagingEntityClient
Herança

Propriedades

IsClosed

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
MessagingFactory

Obtém ou define a fábrica de mensagens.

Mode

Obtém o modo de recebimento da mensagem ao processar a mensagem recebida.

Path

Obtém o caminho da fila, do tópico ou da assinatura em relação ao MessagingFactory endereço base.

(Herdado de MessagingEntityClient)
PrefetchCount

Obtém ou define o número de mensagens que o receptor da fila pode solicitar simultaneamente.

RetryPolicy

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
ThisLock

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)

Métodos

Abandon(Guid)

Descarta a mensagem e abre mão da propriedade do bloqueio de mensagem.

Abandon(Guid, IDictionary<String,Object>)

Descarta a mensagem e abre mão da propriedade do bloqueio de mensagem.

AbandonAsync(Guid)

Descarta a mensagem de forma assíncrona e renuncia à propriedade do bloqueio de mensagem.

AbandonAsync(Guid, IDictionary<String,Object>)

Descarta a mensagem de forma assíncrona e renuncia à propriedade do bloqueio de mensagem.

Abort()

Executa a funcionalidade de anulação na entidade de mensagens.

(Herdado de ClientEntity)
AcceptMessageSession()

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação.

AcceptMessageSession(Boolean)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação, seja no modo exclusivo.

AcceptMessageSession(Boolean, TimeSpan)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação, seja no modo exclusivo.

AcceptMessageSession(String)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão especificado.

AcceptMessageSession(String, Boolean)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação com o modo exclusivo.

AcceptMessageSession(String, Boolean, TimeSpan)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão fornecido com o modo exclusivo.

AcceptMessageSession(String, Guid)

Aceita uma sessão bloqueada não exclusiva de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão e o token de bloqueio de sessão fornecidos.

AcceptMessageSession(String, Guid, TimeSpan)

Aceita uma sessão bloqueada não exclusiva de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão e o token de bloqueio de sessão fornecidos.

AcceptMessageSession(String, TimeSpan)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão especificado e o tempo de espera.

AcceptMessageSession(TimeSpan)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o tempo de espera do servidor especificado.

AcceptMessageSessionAsync()

Aceita de forma assíncrona uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação.

AcceptMessageSessionAsync(Boolean)

Aceita de forma assíncrona uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação, seja no modo exclusivo e no tempo de espera.

AcceptMessageSessionAsync(Boolean, TimeSpan)

Aceita de forma assíncrona uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação, seja no modo exclusivo e no tempo de espera.

AcceptMessageSessionAsync(String)

Aceita de forma assíncrona uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão especificado.

AcceptMessageSessionAsync(String, Boolean)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão fornecido com o modo exclusivo.

AcceptMessageSessionAsync(String, Boolean, TimeSpan)

Aceita uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão fornecido com o modo exclusivo.

AcceptMessageSessionAsync(String, Guid)

Aceita uma sessão bloqueada não exclusiva de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão e o token de bloqueio de sessão fornecidos.

AcceptMessageSessionAsync(String, Guid, TimeSpan)

Aceita uma sessão bloqueada não exclusiva de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão e o token de bloqueio de sessão fornecidos.

AcceptMessageSessionAsync(String, TimeSpan)

Aceita de forma assíncrona uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o identificador de sessão e o tempo de espera especificados.

AcceptMessageSessionAsync(TimeSpan)

Aceita de forma assíncrona uma sessão de mensagem que permite o agrupamento de mensagens relacionadas para processamento em uma única transação usando o tempo de espera do servidor especificado.

CancelScheduledMessageAsync(Int64)

Cancela uma mensagem agendada

Close()

Envia uma mensagem de limpeza para o Barramento de Serviço para sinalizar a conclusão do uso de uma entidade.

(Herdado de ClientEntity)
CloseAsync()

Envia uma mensagem de limpeza de forma assíncrona para o Barramento de Serviço para sinalizar a conclusão do uso de uma entidade.

(Herdado de ClientEntity)
Complete(Guid)

Conclui o processamento de uma mensagem.

CompleteAsync(Guid)

Conclui de forma assíncrona o processamento de uma mensagem.

CompleteBatch(IEnumerable<Guid>)

Conclui o processamento de um lote de mensagens.

CompleteBatchAsync(IEnumerable<Guid>)

Conclui de forma assíncrona o processamento de um lote de mensagens.

Create(String)

Cria uma nova cópia de QueueClient com o caminho especificado.

Create(String, ReceiveMode)

Cria uma nova cópia de QueueClient com o caminho e o modo especificados.

CreateFromConnectionString(String)

Cria uma nova instância de usando a cadeia de QueueClient conexão especificada.

CreateFromConnectionString(String, ReceiveMode)

Cria uma nova instância de usando a cadeia de QueueClient conexão especificada e o modo de recebimento.

CreateFromConnectionString(String, String)

Cria uma nova cópia de de uma cadeia de QueueClient conexão com o caminho da fila especificado. Use essa sobrecarga somente quando a cadeia de conexão não usar a EntityPath propriedade .

CreateFromConnectionString(String, String, ReceiveMode)

Cria uma nova instância de de de uma cadeia de QueueClient conexão com o caminho e o modo especificados. Use essa sobrecarga somente quando a cadeia de conexão não usar a EntityPath propriedade .

CreateWithAzureActiveDirectory(Uri, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Cria uma nova instância do usando o QueueClient contexto de autenticação do Azure Active Directory.

CreateWithManagedIdentity(Uri, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Cria uma nova instância do usando a QueueClient autenticação de Identidade Gerenciada do Azure.

DeadLetter(Guid)

Move a mensagem não entregue para a fila de mensagens mortas.

DeadLetter(Guid, IDictionary<String,Object>)

Move a mensagem não entregue para a fila de mensagens mortas.

DeadLetter(Guid, String, String)

Move a mensagem não entregue para a fila de mensagens mortas.

DeadLetterAsync(Guid)

Move de forma assíncrona a mensagem não entregue para a fila de mensagens mortas.

DeadLetterAsync(Guid, IDictionary<String,Object>)

Move de forma assíncrona a mensagem não entregue para a fila de mensagens mortas.

DeadLetterAsync(Guid, String, String)

Move de forma assíncrona a mensagem não entregue para a fila de mensagens mortas.

Defer(Guid)

Suspende o processamento de uma mensagem.

Defer(Guid, IDictionary<String,Object>)

Suspende o processamento de uma mensagem.

DeferAsync(Guid)

Suspende de forma assíncrona o processamento de uma mensagem.

DeferAsync(Guid, IDictionary<String,Object>)

Suspende de forma assíncrona o processamento de uma mensagem.

Fault()

Apenas para uso interno. Não herde dessa classe.

(Herdado de ClientEntity)
FormatDeadLetterPath(String)

Cria um nome de formato do caminho da fila de mensagens mortas especificado.

FormatTransferDeadLetterPath(String)

Representa o objeto de cliente de fila.

GetMessageSessions()

Obtém as sessões de mensagem, permitindo que você navegue por sessões em filas. Somente sessões com mensagens ativas na fila são retornadas. As sessões na fila ou sessões de deadletter que têm um SessionState como "ativo" e nenhuma mensagem não são retornadas com essa chamada.

GetMessageSessions(DateTime)

Recupera todas as sessões de mensagem cujo estado de sessão foi atualizado desde lastUpdatedTime.

GetMessageSessionsAsync()

Obtém as sessões de mensagem de forma assíncrona, permitindo que você navegue por sessões em filas. Somente sessões com mensagens ativas na fila são retornadas. As sessões na fila ou sessões de deadletter que têm um SessionState como "ativo" e nenhuma mensagem não são retornadas com essa chamada.

GetMessageSessionsAsync(DateTime)

Recupera de forma assíncrona todas as sessões de mensagem cujo estado de sessão foi atualizado desde lastUpdatedTime.

OnAbort()

Executa ao chamar o evento Abort.

OnBeginAcceptMessageSession(String, ReceiveMode, Int32, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object)

Representa o objeto de cliente de fila.

OnBeginClose(TimeSpan, AsyncCallback, Object)

Executa quando a operação Fechar é chamada.

OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)

Executa a ação iniciar a criação do receptor.

OnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)

Executa a ação iniciar a criação do receptor.

OnBeginCreateSender(TimeSpan, AsyncCallback, Object)

Executa a ação iniciar criar remetente.

OnBeginGetMessageSessions(DateTime, AsyncCallback, Object)

Executa a ação BeginGetMessageSessions.

OnBeginOpen(TimeSpan, AsyncCallback, Object)

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
OnClose(TimeSpan)

Executa ao chamar a ação Fechar.

OnClosed()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
OnEndAcceptMessageSession(IAsyncResult)

Executa ao chamar a operação EndAcceptMessageSession.

OnEndClose(IAsyncResult)

Executa a ação de fechamento final.

OnEndCreateReceiver(IAsyncResult)

Executa a ação do receptor de criação final.

OnEndCreateSender(IAsyncResult)

Executa a ação de criação final do remetente.

OnEndGetMessageSessions(IAsyncResult)

Executa a ação end get message.

OnEndOpen(IAsyncResult)

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
OnFaulted()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
OnMessage(Action<BrokeredMessage>)

Processa uma mensagem em uma bomba de mensagem controlada por eventos.

OnMessage(Action<BrokeredMessage>, OnMessageOptions)

Processa uma mensagem em uma bomba de mensagem controlada por eventos, com o conjunto de OnMessageOptions opções fornecido.

OnMessageAsync(Func<BrokeredMessage,Task>)

Processa de forma assíncrona uma mensagem.

OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)

Processa de forma assíncrona uma mensagem.

OnOpen(TimeSpan)

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
OnOpened()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
Peek()

Retorna sem remover a primeira mensagem na fila.

Peek(Int64)

Retorna sem remover a primeira mensagem na fila.

PeekAsync()

Retorna de forma assíncrona sem remover a primeira mensagem na fila.

PeekAsync(Int64)

Retorna de forma assíncrona sem remover a primeira mensagem na fila.

PeekBatch(Int32)

Espia um lote de mensagens.

PeekBatch(Int64, Int32)

Espia um lote de mensagens.

PeekBatchAsync(Int32)

Espia de forma assíncrona um lote de mensagem.

PeekBatchAsync(Int64, Int32)

Espia de forma assíncrona um lote de mensagem.

Receive()

Recebe uma mensagem usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

Receive(Int64)

Recebe uma mensagem adiada usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver. Esse método funciona apenas para mensagens adiadas, não regulares.

Receive(TimeSpan)

Recebe uma mensagem usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveAsync()

Recebe de forma assíncrona uma mensagem usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveAsync(Int64)

Recebe de forma assíncrona uma mensagem adiada usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver. Esse método só funciona para mensagens adiadas, não regulares.

ReceiveAsync(TimeSpan)

Recebe de forma assíncrona uma mensagem usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveBatch(IEnumerable<Int64>)

Recebe um lote de mensagens.

ReceiveBatch(Int32)

Recebe um lote de mensagens.

ReceiveBatch(Int32, TimeSpan)

Recebe um lote de mensagens.

ReceiveBatchAsync(IEnumerable<Int64>)

Recebe de forma assíncrona um lote de mensagens.

ReceiveBatchAsync(Int32)

Recebe de forma assíncrona um lote de mensagens.

ReceiveBatchAsync(Int32, TimeSpan)

Recebe de forma assíncrona um lote de mensagens.

RegisterSessionHandler(Type)

Registra o manipulador de sessão com um tipo específico.

RegisterSessionHandler(Type, SessionHandlerOptions)

Registra o manipulador de sessão com opções específicas de tipo e manipulador.

RegisterSessionHandlerAsync(Type)

Registra de forma assíncrona o manipulador de sessão com um tipo específico.

RegisterSessionHandlerAsync(Type, SessionHandlerOptions)

Registra de forma assíncrona o manipulador de sessão com opções específicas de tipo e manipulador.

RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Registra uma fábrica de manipuladores de sessão de mensagens com as opções especificadas.

RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)

Registra uma fábrica de manipuladores de sessão de mensagens com as opções especificadas.

RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Registra de forma assíncrona um alocador de manipuladores de sessão de mensagens.

RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)

Registra de forma assíncrona um alocador de manipuladores de sessão de mensagens.

RenewMessageLock(Guid)

Representa o objeto de cliente de fila.

RenewMessageLockAsync(Guid)

Representa o objeto de cliente de fila.

ScheduleMessageAsync(BrokeredMessage, DateTimeOffset)

Envia uma mensagem agendada

Send(BrokeredMessage)

Envia uma mensagem usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalSender.

SendAsync(BrokeredMessage)

Envia uma mensagem de forma assíncrona usando o Microsoft.ServiceBus.Messaging.QueueClient.InternalSender.

SendBatch(IEnumerable<BrokeredMessage>)

Envia um conjunto de mensagens agenciadas (para processamento em lote).

SendBatchAsync(IEnumerable<BrokeredMessage>)

Envia de forma assíncrona um conjunto de mensagens agenciadas (para processamento em lote).

ThrowIfClosed()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
ThrowIfDisposed()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
ThrowIfDisposedOrImmutable()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
ThrowIfDisposedOrNotOpen()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)
ThrowIfFaulted()

Representa o objeto de cliente de fila.

(Herdado de ClientEntity)

Aplica-se a