Exportar (0) Imprimir
Expandir Tudo

Classe MessageReceiver

Recebe mensagens do contêiner de mensagens e as reconhece.

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

public abstract class MessageReceiver : MessageClientEntity

O tipo MessageReceiver expõe os membros a seguir.

  NomeDescrição
Propriedade públicaBatchFlushIntervalObtém o intervalo de liberação do lote.
Propriedade protegidaBatchingEnabledObtém um valor que indica se o envio em lote está ativado.
Propriedade públicaIsClosed (Herdado de ClientEntity.)
Propriedade públicaLastPeekedSequenceNumberObtém ou define o número sequencial da última mensagem espiada.
Propriedade públicaModeObtém o modo de recepção da mensagem.
Propriedade protegidaOffsetInclusive
Propriedade públicaPathObtém o caminho da fila ou tópico, relativo ao endereço básico da MessagingFactory.
Propriedade públicaPrefetchCountObtém ou define a quantidade de mensagens que o receptor da mensagem pode solicitar simultaneamente.
Propriedade protegidaReceiverStartTimeObtém ou define a hora de início do receptor.
Propriedade públicaRetryPolicy (Herdado de ClientEntity.)
Propriedade protegidaStartOffsetObtém ou define o ponto inicial do deslocamento.
Propriedade protegidaSupportsGetRuntimeEntityDescription
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<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<String, Object>)Descarta a mensagem de modo assíncrono e renuncia à propriedade de bloqueio da mensagem.
Método públicoAbortRealiza a funcionalidade de anulação na entidade de sistema de mensagens. (Herdado de ClientEntity.)
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<String, Object>, AsyncCallback, Object)Inicia uma operação assíncrona para abandonar a mensagem e renunciar ao seu bloqueio.
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 a recepção de uma mensagem.
Método públicoBeginCompleteBatchInicia uma operação assíncrona para concluir um envio de mensagem em lotes.
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<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 a recepção de uma mensagem.
Método públicoBeginDefer(Guid, IDictionary<String, Object>, AsyncCallback, Object)Inicia uma operação assíncrona para suspender a recepção de uma mensagem.
Método públicoBeginPeek(AsyncCallback, Object)Inicia uma operação para espiar uma mensagem.
Método públicoBeginPeek(Int64, AsyncCallback, Object)Inicia uma operação para espiar uma mensagem.
Método públicoBeginPeekBatch(Int32, AsyncCallback, Object)Inicia uma operação para espiar um lote de mensagens.
Método públicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Inicia uma operação 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<Int64>, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote de mensagem.
Método públicoBeginReceiveBatch(Int32, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote de mensagem.
Método públicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Inicia uma operação assíncrona para receber um lote de mensagem.
Método públicoCloseEnvia uma mensagem de limpeza ao Barramento de Serviço para sinalizar o término do uso de uma entidade. (Herdado de ClientEntity.)
Método públicoCloseAsyncEnvia uma mensagem de limpeza de forma assíncrona ao Barramento de Serviço para sinalizar o término do uso de uma entidade. (Herdado de ClientEntity.)
Método públicoCompleteConclui a operação de recepção de uma mensagem.
Método públicoCompleteAsyncConclui a operação de recepção de uma mensagem de modo assíncrono.
Método públicoCompleteBatchConclui a operação de recepção em um lote de mensagem.
Método públicoCompleteBatchAsyncConclui a operação de recepção em um lote de mensagem de modo assíncrono.
Método públicoDeadLetter(Guid)Move a mensagem não entregue para a fila de mensagens mortas.
Método públicoDeadLetter(Guid, IDictionary<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<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)Indica que o receptor deseja adiar o processamento da mensagem.
Método públicoDefer(Guid, IDictionary<String, Object>)Indica que o receptor deseja adiar o processamento da mensagem.
Método públicoDeferAsync(Guid)Adia de modo assíncrono o processamento da mensagem.
Método públicoDeferAsync(Guid, IDictionary<String, Object>)Adia de modo assíncrono o processamento da mensagem.
Método públicoEndAbandonTermina a operação assíncrona para abandonar a mensagem e renunciar ao seu bloqueio.
Método públicoEndCloseTermina uma operação assíncrona para fechar a entidade de cliente de mensagem. (Herdado de MessageClientEntity.)
Método públicoEndCompleteTermina a operação assíncrona para concluir a recepção de uma mensagem.
Método públicoEndCompleteBatchTermina a operação assíncrona para concluir a recepção de um lote de mensagem.
Método públicoEndDeadLetterTermina uma operação assíncrona para mover a mensagem para a fila de mensagens mortas.
Método públicoEndDeferTermina a operação assíncrona para adiar a recepção de uma 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 mensagem.
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 de mensagem.
Método públicoEquals (Herdado de Object.)
Método protegidoFaultSomente para uso interno. Não herdar desta classe. (Herdado de ClientEntity.)
Método protegidoFinalize (Herdado de Object.)
Método públicoGetHashCode (Herdado de Object.)
Método protegidoMembro estáticoGetLockTokenObtém o token de bloqueio associado à mensagem.
Método protegidoMembro estáticoGetLockTokensObtém a coleção de tokens de bloqueio da coleção de mensagens especificada.
Método protegidoGetProperty<T>
Método públicoGetType (Herdado de Object.)
Método protegidoMemberwiseClone (Herdado de Object.)
Método protegidoOnAbandonExecuta ao chamar a operação Abandonar.
Método protegidoOnAbort (Herdado de ClientEntity.)
Método protegidoOnBeginAbandonExecuta ao chamar a operação OnAbandon ou BeginAbandon.
Método protegidoOnBeginClose (Herdado de ClientEntity.)
Método protegidoOnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object)Executa ao chamar a operação OnComplete ou BeginComplete.
Método protegidoOnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)Executa ao chamar a operação OnComplete ou BeginComplete.
Método protegidoOnBeginDeadLetterExecuta ao chamar a operação OnDeadLetter ou BeginDeadLetter.
Método protegidoOnBeginDeferExecuta ao chamar a operação OnDefer ou BeginDefer.
Método protegidoOnBeginOpen (Herdado de ClientEntity.)
Método protegidoOnBeginPeekExecuta ao chamar a operação BeginPeek.
Método protegidoOnBeginRenewMessageLocksExecuta ao chamar a operação OnBegin para mensagens de bloqueio.
Método protegidoOnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)Executa ao chamar a operação OnTryReceive ou BeginTryReceive.
Método protegidoOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)Executa ao chamar a operação OnTryReceive ou BeginTryReceive.
Método protegidoOnBeginTryReceive2Executa ao chamar a operação OnTryReceive ou BeginTryReceive.
Método protegidoOnBeginTryReceiveEventDataExecuta após chamar a operação OnTryReceive ou BeginTryReceive dos dados do evento.
Método protegidoOnClose (Herdado de ClientEntity.)
Método protegidoOnClosed (Herdado de ClientEntity.)
Método protegidoOnCompleteExecuta ao chamar a operação Concluir.
Método protegidoOnDeadLetterExecuta ao chamar a operação DeadLetter.
Método protegidoOnDeferExecuta ao chamar a operação Adiar.
Método protegidoOnEndAbandonExecuta a ação de término de abandono.
Método protegidoOnEndClose (Herdado de ClientEntity.)
Método protegidoOnEndCompleteExecuta a ação de término de conclusão.
Método protegidoOnEndDeadLetterExecuta a ação de término de movimentação para a fila de mensagens mortas.
Método protegidoOnEndDeferExecuta a ação de término de adiamento.
Método protegidoOnEndOpen (Herdado de ClientEntity.)
Método protegidoOnEndPeekExecuta a operação EndPeek.
Método protegidoOnEndRenewMessageLocksExecuta a ação EndRenew para bloqueios de mensagem.
Método protegidoOnEndTryReceiveExecuta a ação de término de tentativa de recepção.
Método protegidoOnEndTryReceive2Executa a ação de término de tentativa de recepção.
Método protegidoOnEndTryReceiveEventDataExecuta a ação EndTryReceive para os dados de evento.
Método protegidoOnFaulted (Herdado de ClientEntity.)
Método públicoOnMessageProcessa uma mensagem em uma bomba de mensagens direcionada a eventos.
Método públicoOnMessageAsyncProcessa de maneira assíncrona uma mensagem em uma bomba de mensagens direcionada a eventos.
Método protegidoOnOpen (Herdado de ClientEntity.)
Método protegidoOnOpened (Herdado de ClientEntity.)
Método protegidoOnPeekExecuta ao chamar a operação Peek.
Método protegidoOnRenewMessageLocksExecuta a ação Renew para mensagens de bloqueio.
Método protegidoOnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>)Executa ao chamar a operação TryReceive.
Método protegidoOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>)Executa ao chamar a operação TryReceive.
Método públicoPeek()Lê a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeek(Int64)Lê a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeekAsync()Lê a próxima mensagem de modo assíncrono sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeekAsync(Int64)Lê a próxima mensagem de modo assíncrono sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeekBatch(Int32)Lê o próximo lote de mensagens sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeekBatch(Int64, Int32)Lê o próximo lote de mensagens sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeekBatchAsync(Int32)Lê o próximo lote de mensagens de modo assíncrono sem alterar o estado do receptor ou a origem da mensagem.
Método públicoPeekBatchAsync(Int64, Int32)Lê o próximo lote de mensagens de modo assíncrono sem alterar o estado do receptor ou a origem da mensagem.
Método públicoReceive()Recebe uma BrokeredMessage da fila ou tópico atual.
Método públicoReceive(Int64)Recebe uma mensagem da fila ou tópico atual.
Método públicoReceive(TimeSpan)Recebe uma BrokeredMessage da fila ou tópico atual.
Método públicoReceiveAsync()Recebe uma mensagem da fila ou tópico atual de modo assíncrono.
Método públicoReceiveAsync(Int64)Recebe uma mensagem da fila ou tópico atual de modo assíncrono.
Método públicoReceiveAsync(TimeSpan)Recebe uma mensagem da fila ou tópico atual de modo assíncrono.
Método públicoReceiveBatch(IEnumerable<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<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 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

Embora seja possível usar a classe QueueClient para enviar e receber mensagens sem criar um objeto MessageReceiver, também é possível usar MessageSender e MessageReceiver para criar um remetente e um receptor em uma entidade. No entanto, observe que você só é possível usar um MessageReceiver para receber mensagens de uma fila ou assinatura;não é possível receber mensagens nem escutar mensagens de um tópico. Da mesma forma, só é possível usar um MessageSender para enviar mensagens para uma fila ou tópico; não é possível enviar mensagens para uma assinatura. Observe que o modo de recepção de mensagens padrão é PeekLock, o que garante a recepção de mensagens confiáveis.

Quando se cria um MessageReceiver para assinaturas, o parâmetro entityPath é do formato topicPath/subscriptions/subscriptionName.

O exemplo a seguir recebe uma mensagem da fila criada no exemplo MessageSender:

Uri serviceUri = ServiceBusEnvironment.CreateServiceUri("sb", ServiceNamespace, string.Empty); 

MessagingFactory factory = MessagingFactory.Create(serviceUri, credentials); 

MessageReceiver myMessageReceiver = factory.CreateMessageReceiver(queueName);

BrokeredMessage message;
while ((message = myMessageReceiver.Receive(new TimeSpan(hours: 0, minutes: 1, seconds: 5))) != null)
{
    Console.WriteLine(
    string.Format(
    "Message received: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
    message.Complete();
}

Quaisquer membros estáticos públicos (Compartilhados em Visual Basic) desse tipo são à prova de threads. Os membros da instância também têm a garantia de serem à prova de thread.

Contribuições da comunidade

ADICIONAR
A Microsoft está realizando uma pesquisa online para saber sua opinião sobre o site do MSDN. Se você optar por participar, a pesquisa online lhe será apresentada quando você sair do site do MSDN.

Deseja participar?
Mostrar:
© 2015 Microsoft