Exportar (0) Imprimir
Expandir Tudo
Este tópico ainda não foi avaliado como - Avalie este tópico

Classe SubscriptionClient

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

System..::..Object
  Microsoft.ServiceBus.Messaging..::..MessageClientEntity
    Microsoft.ServiceBus.Messaging..::..SubscriptionClient

Namespace:  Microsoft.ServiceBus.Messaging
Assembly:  Microsoft.ServiceBus (em Microsoft.ServiceBus.dll)
public abstract class SubscriptionClient extends MessageClientEntity

O tipo SubscriptionClient expõe os membros a seguir.

  NomeDescrição
Propriedade públicaIsClosedObtém ou define um valor que indica se a entidade de cliente de mensagem fechar. (Herdado de MessageClientEntity.)
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úblicaRetryPolicyObtém ou define uma política de novas tentativas associada a esta instância que determina se a solicitação deve ser repetida. (Herdado de MessageClientEntity.)
Propriedade protegidaThisLockEnvia um objeto usado para bloquear a instância de MessageClientEntity. (Herdado de MessageClientEntity.)
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úblicoAbortAnula a entidade de cliente de mensagem e coloca seu status em fechamento. (Herdado de MessageClientEntity.)
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úblicoCloseFecha a entidade de cliente de mensagem e coloca seu status como fechado. (Herdado de MessageClientEntity.)
Método públicoCloseAsyncFecha de modo assíncrono a entidade de cliente de mensagem e coloca seu status como fechado. (Herdado de MessageClientEntity.)
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 protegidoFaultColoca a entidade de cliente de mensagem em estado de falha. (Herdado de MessageClientEntity.)
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 MessageClientEntity..::..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 MessageClientEntity..::..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 protegidoOnBeginOpenExecuta ao chamar a operação para iniciar a abertura da entidade de cliente de mensagem. (Herdado de MessageClientEntity.)
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 MessageClientEntity..::..OnClose(TimeSpan).)
Método protegidoOnClosedOcorre quando a entidade de cliente de mensagem muda para um estado de fechamento. (Herdado de MessageClientEntity.)
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 MessageClientEntity..::..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 protegidoOnEndOpenExecuta ao chamar a operação para terminar a abertura da entidade de cliente de mensagem. (Herdado de MessageClientEntity.)
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 protegidoOnFaultedExecuta ao chamar a operação Falha. (Herdado de MessageClientEntity.)
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 protegidoOnOpenExecuta ao chamar a operação para abrir a entidade de cliente de mensagem. (Herdado de MessageClientEntity.)
Método protegidoOnOpenedExecuta quando a entidade de cliente de mensagem é aberta. (Herdado de MessageClientEntity.)
Método protegidoOnRuntimeDescriptionChangedGera um evento quando a descrição de tempo de execução for alterada. (Herdado de MessageClientEntity.)
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úblicoRemoveRuleRemove a regra descrita pelo ruleName.
Método públicoRemoveRuleAsyncRemove de modo assíncrono a regra descrita pelo ruleName.
Método protegidoThrowIfClosedGera uma exceção se a entidade de cliente de mensagem for fechada. (Herdado de MessageClientEntity.)
Método protegidoThrowIfDisposedGera uma exceção se a entidade de cliente de mensagem for descartada. (Herdado de MessageClientEntity.)
Método protegidoThrowIfDisposedOrImmutableGera uma exceção se o cliente for descartado ou estiver imutável. (Herdado de MessageClientEntity.)
Método protegidoThrowIfDisposedOrNotOpenGera uma exceção se o cliente for descartado ou não abrir. (Herdado de MessageClientEntity.)
Método protegidoThrowIfFaultedGera uma exceção se o cliente falhar. (Herdado de MessageClientEntity.)
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. Todos os direitos reservados.