VENDAS: 1-800-867-1389

Classe QueueClient

Representa o objeto de cliente da fila.

Namespace:  Microsoft.ServiceBus.Messaging
Assembly:  Microsoft.ServiceBus (em Microsoft.ServiceBus.dll)

public abstract class QueueClient : MessageClientEntity

O tipo QueueClient expõe os membros a seguir.

  NomeDescrição
Propriedade públicaIsClosed (Herdado de ClientEntity.)
Propriedade públicaMessagingFactoryObtém ou define a fábrica do sistema de mensagens.
Propriedade públicaModeObtém o modo de recepção de mensagem ao processar a mensagem recebida.
Propriedade públicaPathObtém ou define o nome de caminho completo da fila.
Propriedade públicaPrefetchCountObtém ou define a quantidade de mensagens que o receptor da fila pode solicitar simultaneamente.
Propriedade públicaRetryPolicy (Herdado de ClientEntity.)
Propriedade protegidaThisLock (Herdado de ClientEntity.)
Início

  NomeDescrição
Método públicoAbandon(Guid)Descarta a mensagem e renuncia à propriedade de bloqueio da mensagem.
Método públicoAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Descarta a mensagem e renuncia à propriedade de bloqueio da mensagem.
Método públicoAbandonAsync(Guid)Descarta a mensagem de modo assíncrono e renuncia à propriedade de bloqueio da mensagem.
Método públicoAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Descarta a mensagem de modo assíncrono e renuncia à propriedade de bloqueio da mensagem.
Método públicoAbortPerforms abort functionality on the messaging entity. (Herdado de ClientEntity.)
Método públicoAcceptMessageSession()()()()Aceita uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação.
Método públicoAcceptMessageSession(String)Aceita uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação usando o identificador de sessão fornecido.
Método públicoAcceptMessageSession(TimeSpan)Aceita uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação usando o tempo de espera do servidor especificado.
Método públicoAcceptMessageSession(String, TimeSpan)Aceita uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação usando o identificador de sessão e o tempo de espera fornecidos.
Método públicoAcceptMessageSessionAsync()()()()Aceita de modo assíncrono uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação.
Método públicoAcceptMessageSessionAsync(String)Aceita de modo assíncrono uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação usando o identificador de sessão fornecido.
Método públicoAcceptMessageSessionAsync(TimeSpan)Aceita de modo assíncrono uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação usando o tempo de espera do servidor especificado.
Método públicoAcceptMessageSessionAsync(String, TimeSpan)Aceita de modo assíncrono uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação usando o identificador de sessão e o tempo de espera fornecidos.
Método públicoBeginAbandon(Guid, AsyncCallback, Object)Inicia uma operação assíncrona para abandonar a mensagem e renunciar ao seu bloqueio.
Método públicoBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Inicia uma operação assíncrona para abandonar a mensagem e renunciar ao seu bloqueio.
Método públicoBeginAcceptMessageSession(AsyncCallback, Object)Inicia uma operação assíncrona para aceitar uma sessão de mensagem.
Método públicoBeginAcceptMessageSession(String, AsyncCallback, Object)Inicia uma operação assíncrona para aceitar uma sessão de mensagem.
Método públicoBeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)Inicia uma operação assíncrona para aceitar uma sessão de mensagem.
Método públicoBeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)Inicia uma operação assíncrona para aceitar uma sessão de mensagem.
Método públicoBeginCloseInicia uma operação assíncrona para fechar a entidade de cliente de mensagem. (Herdado de MessageClientEntity.)
Método públicoBeginCompleteInicia uma operação assíncrona para concluir o processamento de uma mensagem.
Método públicoBeginCompleteBatchInicia uma operação assíncrona para concluir o processamento de uma mensagem.
Método públicoBeginDeadLetter(Guid, AsyncCallback, Object)Inicia uma operação assíncrona para mover uma mensagem para a fila de mensagens mortas.
Método públicoBeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Inicia uma operação assíncrona para mover uma mensagem para a fila de mensagens mortas.
Método públicoBeginDeadLetter(Guid, String, String, AsyncCallback, Object)Inicia uma operação assíncrona para mover uma mensagem para a fila de mensagens mortas.
Método públicoBeginDefer(Guid, AsyncCallback, Object)Inicia uma operação assíncrona para suspender o processamento de uma mensagem.
Método públicoBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Inicia uma operação assíncrona para suspender o processamento de uma mensagem.
Método públicoBeginGetMessageSessions(AsyncCallback, Object)Inicia uma operação assíncrona para obter as sessões de mensagem.
Método públicoBeginGetMessageSessions(DateTime, AsyncCallback, Object)Inicia uma operação assíncrona para obter as sessões de mensagem.
Método públicoBeginPeek(AsyncCallback, Object)Inicia uma operação assíncrona para espiar uma mensagem.
Método públicoBeginPeek(Int64, AsyncCallback, Object)Inicia uma operação assíncrona para espiar uma mensagem.
Método públicoBeginPeekBatch(Int32, AsyncCallback, Object)Inicia uma operação assíncrona para espiar um lote de mensagens.
Método públicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Inicia uma operação assíncrona para espiar um lote de mensagens.
Método públicoBeginReceive(AsyncCallback, Object)Inicia uma operação assíncrona para receber uma mensagem.
Método públicoBeginReceive(Int64, AsyncCallback, Object)Inicia uma operação assíncrona para receber uma mensagem.
Método públicoBeginReceive(TimeSpan, AsyncCallback, Object)Inicia uma operação assíncrona para receber uma mensagem.
Método públicoBeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote de mensagens.
Método públicoBeginReceiveBatch(Int32, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote de mensagens.
Método públicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote de mensagens.
Método públicoBeginSendInicia uma operação assíncrona para enviar uma mensagem.
Método públicoBeginSendBatchInicia uma operação assíncrona para enviar uma mensagem.
Método públicoCloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (Herdado de ClientEntity.)
Método públicoCloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (Herdado de ClientEntity.)
Método públicoCompleteConclui o processamento de uma mensagem.
Método públicoCompleteAsyncConclui o processamento de uma mensagem de modo assíncrono.
Método públicoCompleteBatchConclui o processamento de uma mensagem.
Método públicoCompleteBatchAsyncConclui o processamento de um lote de mensagens de modo assíncrono.
Método públicoMembro estáticoCreate(String)Cria uma nova cópia de QueueClient com o caminho especificado.
Método públicoMembro estáticoCreate(String, ReceiveMode)Cria uma nova cópia de QueueClient com o caminho e modo especificado.
Método públicoMembro estáticoCreateFromConnectionString(String, String)Cria uma nova cópia de QueueClient a partir da cadeia de conexão com o caminho especificado.
Método públicoMembro estáticoCreateFromConnectionString(String, String, ReceiveMode)Cria uma nova cópia de QueueClient a partir da cadeia de conexão com o caminho e modo especificado.
Método públicoDeadLetter(Guid)Move a mensagem não entregue para a fila de mensagens mortas.
Método públicoDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))Move a mensagem não entregue para a fila de mensagens mortas.
Método públicoDeadLetter(Guid, String, String)Move a mensagem não entregue para a fila de mensagens mortas.
Método públicoDeadLetterAsync(Guid)Move de modo assíncrono a mensagem não entregue para a fila de mensagens mortas.
Método públicoDeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Move de modo assíncrono a mensagem não entregue para a fila de mensagens mortas.
Método públicoDeadLetterAsync(Guid, String, String)Move de modo assíncrono a mensagem não entregue para a fila de mensagens mortas.
Método públicoDefer(Guid)Suspende o processamento de uma mensagem.
Método públicoDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Suspende o processamento de uma mensagem.
Método públicoDeferAsync(Guid)Suspende o processamento de uma mensagem de modo assíncrono.
Método públicoDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Suspende o processamento de uma mensagem de modo assíncrono.
Método públicoEndAbandonTermina uma operação assíncrona para abandonar a mensagem e renunciar a seu bloqueio.
Método públicoEndAcceptMessageSessionTermina uma operação assíncrona para aceitar uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação.
Método públicoEndCloseTermina uma operação assíncrona para fechar a entidade de cliente de mensagem. (Herdado de MessageClientEntity.)
Método públicoEndCompleteTermina uma operação assíncrona para concluir o processamento de uma mensagem.
Método públicoEndCompleteBatchTermina uma operação assíncrona para concluir o processamento de uma mensagem.
Método públicoEndDeadLetterTermina uma operação assíncrona para mover uma mensagem para a fila de mensagens mortas.
Método públicoEndDeferTermina uma operação assíncrona para suspender o processamento de uma mensagem.
Método públicoEndGetMessageSessionsEncerra uma operação assíncrona para obter as sessões de mensagem.
Método públicoEndPeekTermina uma operação assíncrona para espiar uma mensagem.
Método públicoEndPeekBatchTermina uma operação assíncrona para espiar um lote de mensagens.
Método públicoEndReceiveTermina uma operação assíncrona para receber uma mensagem.
Método públicoEndReceiveBatchTermina uma operação assíncrona para receber uma mensagem.
Método públicoEndSendTermina uma operação assíncrona para enviar uma mensagem.
Método públicoEndSendBatchTermina uma operação assíncrona para enviar uma mensagem.
Método públicoEquals (Herdado de Object.)
Método protegidoFaultFor internal use only. Do not inherit from this class. (Herdado de ClientEntity.)
Método protegidoFinalize (Herdado de Object.)
Método públicoMembro estáticoFormatDeadLetterPathCria um nome de formato a partir do caminho da fila de mensagens mortas especificado.
Método públicoGetHashCode (Herdado de Object.)
Método públicoGetMessageSessions()()()()Obtém as sessões de mensagens, permitindo navegar nas sessões em filas.
Método públicoGetMessageSessions(DateTime)Recupera todas as sessões de mensagens cujo estado de sessão estava atualizado desde lastUpdatedTime.
Método públicoGetMessageSessionsAsync()()()()Obtém as sessões de mensagens de modo assíncrono, permitindo navegar nas sessões em filas.
Método públicoGetMessageSessionsAsync(DateTime)Recupera de modo assíncrono todas as sessões de mensagens cujo estado de sessão estava atualizado desde lastUpdatedTime.
Método públicoGetType (Herdado de Object.)
Método protegidoMemberwiseClone (Herdado de Object.)
Método protegidoOnAbortExecuta ao chamar o evento Anular. (Substitui ClientEntity..::..OnAbort()()()().)
Método protegidoOnBeginAcceptMessageSessionExecuta ao chamar a operação BeginAcceptMessageSession.
Método protegidoOnBeginCloseExecuta quando a operação Fechar é chamada. (Substitui ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object).)
Método protegidoOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)Executa a ação de início de criação do receptor.
Método protegidoOnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)Executa a ação de início de criação do receptor.
Método protegidoOnBeginCreateSenderExecuta a ação de início de criação do remetente.
Método protegidoOnBeginGetMessageSessionsExecuta a ação de BeginGetMessageSessions.
Método protegidoOnBeginOpen (Herdado de ClientEntity.)
Método protegidoOnCloseExecuta ao chamar a ação Fechar. (Substitui ClientEntity..::..OnClose(TimeSpan).)
Método protegidoOnClosed (Herdado de ClientEntity.)
Método protegidoOnEndAcceptMessageSessionExecuta ao chamar a operação EndAcceptMessageSession.
Método protegidoOnEndCloseExecuta o término da ação de fechamento. (Substitui ClientEntity..::..OnEndClose(IAsyncResult).)
Método protegidoOnEndCreateReceiverExecuta a ação de término de criação do receptor.
Método protegidoOnEndCreateSenderExecuta a ação de término de criação do remetente.
Método protegidoOnEndGetMessageSessionsExecuta a ação de término de obtenção de mensagem.
Método protegidoOnEndOpen (Herdado de ClientEntity.)
Método protegidoOnFaulted (Herdado de ClientEntity.)
Método públicoOnMessage(Action<(Of <<'(BrokeredMessage>)>>))Processa uma mensagem em uma bomba de mensagens direcionada a eventos.
Método públicoOnMessage(Action<(Of <<'(BrokeredMessage>)>>), OnMessageOptions)Processa uma mensagem em uma bomba de mensagens direcionada a eventos, com o conjunto especificado de opções OnMessageOptions.
Método públicoOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>))Processa uma mensagem de modo assíncrono.
Método públicoOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>), OnMessageOptions)Processa uma mensagem de modo assíncrono.
Método protegidoOnOpen (Herdado de ClientEntity.)
Método protegidoOnOpened (Herdado de ClientEntity.)
Método públicoPeek()()()()Retorna sem remover a primeira mensagem na fila.
Método públicoPeek(Int64)Retorna sem remover a primeira mensagem na fila.
Método públicoPeekAsync()()()()Retorna de modo assíncrono, sem remover a primeira mensagem na fila.
Método públicoPeekAsync(Int64)Retorna de modo assíncrono, sem remover a primeira mensagem na fila.
Método públicoPeekBatch(Int32)Espia um lote de mensagens.
Método públicoPeekBatch(Int64, Int32)Espia um lote de mensagens.
Método públicoPeekBatchAsync(Int32)Espia um lote de mensagens de modo assíncrono.
Método públicoPeekBatchAsync(Int64, Int32)Espia um lote de mensagens de modo assíncrono.
Método públicoReceive()()()()Recebe uma mensagem usando o InternalReceiver()()()().
Método públicoReceive(Int64)Recebe uma mensagem usando o InternalReceiver()()()().
Método públicoReceive(TimeSpan)Recebe uma mensagem usando o InternalReceiver()()()().
Método públicoReceiveAsync()()()()Recebe uma mensagem de modo assíncrono usando o InternalReceiver()()()().
Método públicoReceiveAsync(Int64)Recebe uma mensagem de modo assíncrono usando o InternalReceiver()()()().
Método públicoReceiveAsync(TimeSpan)Recebe uma mensagem de modo assíncrono usando o InternalReceiver()()()().
Método públicoReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Recebe um lote de mensagens.
Método públicoReceiveBatch(Int32)Recebe um lote de mensagens.
Método públicoReceiveBatch(Int32, TimeSpan)Recebe um lote de mensagens.
Método públicoReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Recebe um lote de mensagens de modo assíncrono.
Método públicoReceiveBatchAsync(Int32)Recebe um lote de mensagens de modo assíncrono.
Método públicoReceiveBatchAsync(Int32, TimeSpan)Recebe um lote de mensagens de modo assíncrono.
Método públicoRegisterSessionHandler(Type)Registra o manipulador de sessão com o tipo específico.
Método públicoRegisterSessionHandler(Type, SessionHandlerOptions)Registra o manipulador de sessão com o tipo específico e as opções de manipulador.
Método públicoRegisterSessionHandlerAsync(Type)Registra de forma assíncrona o manipulador de sessão com o tipo específico.
Método públicoRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Registra de forma assíncrona o manipulador de sessão com o tipo específico e as opções de manipulador.
Método públicoRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra uma fábrica de manipuladores de sessão de mensagem com opções específicas.
Método públicoRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra uma fábrica de manipuladores de sessão de mensagem com opções específicas.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra de forma assíncrona uma fábrica de manipuladores de sessão de mensagem.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra de forma assíncrona uma fábrica de manipuladores de sessão de mensagem.
Método públicoSendEnvia uma mensagem usando o InternalSender()()()().
Método públicoSendAsyncEnvia uma mensagem de modo assíncrono usando o InternalSender()()()().
Método públicoSendBatchEnvia um conjunto de mensagens agenciadas (para processamento em lotes).
Método públicoSendBatchAsyncEnvia um conjunto de mensagens agenciadas de modo assíncrono (para processamento em lotes).
Método protegidoThrowIfClosed (Herdado de ClientEntity.)
Método protegidoThrowIfDisposed (Herdado de ClientEntity.)
Método protegidoThrowIfDisposedOrImmutable (Herdado de ClientEntity.)
Método protegidoThrowIfDisposedOrNotOpen (Herdado de ClientEntity.)
Método protegidoThrowIfFaulted (Herdado de ClientEntity.)
Método públicoToString (Herdado de Object.)
Início

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.

Isso foi útil para você?
(1500 caracteres restantes)
Agradecemos os seus comentários

Contribuições da comunidade

ADICIONAR
Mostrar:
© 2014 Microsoft