VENDAS: 1-800-867-1389

Classe SubscriptionClient

Representa a classe âncora usada em operações de tempo de execução relacionadas a uma assinatura de tópico.

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

public abstract class SubscriptionClient : MessageClientEntity

O tipo SubscriptionClient expõe os membros a seguir.

  NomeDescrição
Propriedade públicaIsClosed (Herdado de ClientEntity.)
Propriedade públicaMessagingFactoryObtém a fábrica de sistema de mensagens usada para criar este cliente de assinatura.
Propriedade públicaModeObtém o modo de recepção de mensagem ao processar a mensagem recebida.
Propriedade públicaNameObtém o nome da assinatura.
Propriedade públicaPrefetchCountObtém ou define a quantidade de mensagens que o receptor da mensagem pode solicitar simultaneamente.
Propriedade públicaRetryPolicy (Herdado de ClientEntity.)
Propriedade protegidaThisLock (Herdado de ClientEntity.)
Propriedade públicaTopicPathObtém o nome de caminho completo do tópico.
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 usando o tempo de espera do servidor especificado.
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 tempo de espera do servidor especificado.
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 tempo de espera do servidor especificado.
Método públicoAddRule(RuleDescription)Adiciona uma nova regra à Subscription usando a descrição de regra especificada.
Método públicoAddRule(String, Filter)Adiciona uma regra à assinatura atual com o nome e a expressão de filtro especificados.
Método públicoAddRuleAsync(RuleDescription)Adiciona de modo assíncrono uma nova regra à Subscription usando a descrição de regra especificada.
Método públicoAddRuleAsync(String, Filter)Adiciona uma regra de modo assíncrono à assinatura atual com o nome e a expressão de filtro especificados.
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úblicoBeginAddRule(RuleDescription, AsyncCallback, Object)Inicia uma operação assíncrona para adicionar uma nova regra à assinatura.
Método públicoBeginAddRule(String, Filter, AsyncCallback, Object)Inicia uma operação assíncrona para adicionar uma nova regra à assinatura.
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 uma sessão de mensagem.
Método públicoBeginGetMessageSessions(DateTime, AsyncCallback, Object)Inicia uma operação assíncrona para obter uma sessão de mensagem.
Método públicoBeginPeek(AsyncCallback, Object)Inicia uma operação assíncrona de retorno sem remoção da primeira mensagem na fila.
Método públicoBeginPeek(Int64, AsyncCallback, Object)Inicia uma operação assíncrona de retorno sem remoção da primeira mensagem na fila.
Método públicoBeginPeekBatch(Int32, AsyncCallback, Object)Inicia uma operação assíncrona para espiar um lote.
Método públicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Inicia uma operação assíncrona para espiar um lote.
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.
Método públicoBeginReceiveBatch(Int32, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote.
Método públicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote.
Método públicoBeginRemoveRuleInicia uma ação de regra de remoção assíncrona.
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 um lote.
Método públicoCompleteBatchAsyncConclui o processamento de um lote de modo assíncrono.
Método públicoMembro estáticoCreate(String, String)Cria uma nova cópia do SubscriptionClient com nome e caminho de tópico especificados.
Método públicoMembro estáticoCreate(String, String, ReceiveMode)Cria uma nova cópia do SubscriptionClient com nome, caminho de tópico e modo especificados.
Método públicoMembro estáticoCreateFromConnectionString(String, String, String)Cria uma nova cópia do SubscriptionClient a partir de uma cadeia de conexão com o nome e o caminho de tópico especificados.
Método públicoMembro estáticoCreateFromConnectionString(String, String, String, ReceiveMode)Cria uma nova cópia do SubscriptionClient a partir de uma cadeia de conexão com o modo, o nome e o caminho de tópico especificados.
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úblicoEndAddRuleTermina uma operação de regra de adição assíncrona.
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 um lote.
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úblicoEndGetMessageSessionsTermina uma operação assíncrona para obter o processamento de uma mensagem.
Método públicoEndPeekConclui uma operação assíncrona de espiada.
Método públicoEndPeekBatchConclui uma operação assíncrona de espiada em 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 um lote.
Método públicoEndRemoveRuleTermina uma operação de regra de remoção assíncrona.
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 do caminho de definição de mensagens mortas usando o caminho do tópico e o nome de assinatura especificados.
Método públicoMembro estáticoFormatSubscriptionPathCria um nome de formato do caminho de assinatura usando o caminho do tópico e o nome de assinatura especificados.
Método públicoGetHashCode (Herdado de Object.)
Método públicoGetMessageSessions()()()()Obtém uma sessão de mensagem que possibilita o agrupamento de mensagens relacionadas para o processamento de uma única transação.
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 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úblicoGetMessageSessionsAsync(DateTime)Obtém 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úblicoGetType (Herdado de Object.)
Método protegidoMemberwiseClone (Herdado de Object.)
Método protegidoOnAbortExecuta a ação de anulação. (Substitui ClientEntity..::..OnAbort()()()().)
Método protegidoOnBeginAcceptMessageSessionExecuta ao chamar a operação BeginAcceptMessageSession.
Método protegidoOnBeginAddRuleExecuta ao chamar a operação BeginAddRule.
Método protegidoOnBeginCloseExecuta a ação de início de fechamento. (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, String, ReceiveMode, TimeSpan, AsyncCallback, Object)Executa a ação de início de criação do receptor.
Método protegidoOnBeginGetMessageSessionsExecuta ao chamar a operação BeginGetMessageSessions.
Método protegidoOnBeginOpen (Herdado de ClientEntity.)
Método protegidoOnBeginRemoveRuleInicia a remoção de uma Rule a partir de uma Subscription por meio de um protocolo do cliente de tempo de execução.
Método protegidoOnBeginRemoveRulesByTagInicia a remoção de uma Rule a partir de uma Subscription por meio de um protocolo do cliente de tempo de execução usando uma marca.
Método protegidoOnCloseExecuta a ação de fechamento. (Substitui ClientEntity..::..OnClose(TimeSpan).)
Método protegidoOnClosed (Herdado de ClientEntity.)
Método protegidoOnEndAcceptMessageSessionExecuta ao chamar a operação EndAcceptMessageSession.
Método protegidoOnEndAddRuleTermina a chamada assíncrona ao OnBeginAddRule.
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 protegidoOnEndGetMessageSessionsExecuta a ação de término de obtenção de mensagem.
Método protegidoOnEndOpen (Herdado de ClientEntity.)
Método protegidoOnEndRemoveRuleTermina a chamada assíncrona ao OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Método protegidoOnEndRemoveRulesTermina a chamada assíncrona ao OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
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)Retorna sem remover as primeiras mensagens em um lote.
Método públicoPeekBatch(Int64, Int32)Retorna sem remover as primeiras mensagens em um lote.
Método públicoPeekBatchAsync(Int32)Retorna de modo assíncrono, sem remover as primeiras mensagens em um lote.
Método públicoPeekBatchAsync(Int64, Int32)Retorna de modo assíncrono, sem remover as primeiras mensagens em um lote.
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 após a operação assíncrona.
Método públicoReceiveBatch(Int32)Recebe um lote após a operação assíncrona.
Método públicoReceiveBatch(Int32, TimeSpan)Recebe um lote após a operação assíncrona.
Método públicoReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Recebe um conjunto de mensagens de modo assíncrono (para processamento em lotes).
Método públicoReceiveBatchAsync(Int32)Recebe um conjunto de mensagens de modo assíncrono (para processamento em lotes).
Método públicoReceiveBatchAsync(Int32, TimeSpan)Recebe um conjunto de mensagens de modo assíncrono (para processamento em lotes).
Método públicoRegisterSessionHandler(Type)Registra o manipulador para a sessão do cliente.
Método públicoRegisterSessionHandler(Type, SessionHandlerOptions)Registra o manipulador para a sessão do cliente.
Método públicoRegisterSessionHandlerAsync(Type)Registra de forma assíncrona o manipulador para a sessão do cliente.
Método públicoRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Registra de forma assíncrona o manipulador para a sessão do cliente.
Método públicoRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra a fábrica de manipuladores para a sessão do cliente.
Método públicoRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra a fábrica de manipuladores para a sessão do cliente.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra de forma assíncrona a fábrica de manipuladores para a sessão do cliente.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra de forma assíncrona a fábrica de manipuladores para a sessão do cliente.
Método públicoRemoveRuleRemove a regra descrita pelo ruleName.
Método públicoRemoveRuleAsyncRemove de modo assíncrono a regra descrita pelo ruleName.
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 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.

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

Contribuições da comunidade

ADICIONAR
Mostrar:
© 2014 Microsoft