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 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 protegidaReceiverStartTime
Propriedade públicaRetryPolicy (Herdado de ClientEntity.)
Propriedade protegidaStartOffset
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ú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ú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<(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 a recepção de uma mensagem.
Método públicoBeginDefer(Guid, IDictionary<(Of <<'(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<(Of <<'(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ú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 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<(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)Indica que o receptor deseja adiar o processamento da mensagem.
Método públicoDefer(Guid, IDictionary<(Of <<'(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<(Of <<'(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 protegidoFaultFor internal use only. Do not inherit from this class. (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 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<(Of <<'(ArraySegment<(Of <<'(Byte>)>>)>)>>), Boolean, TimeSpan, AsyncCallback, Object)
Método protegidoOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(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<(Of <<'(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 protegidoOnBeginTryReceiveEventData
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 protegidoOnEndTryReceiveEventData
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<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Executa ao chamar a operação TryReceive.
Método protegidoOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(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<(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 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

Although you can use the QueueClient class to send and receive messages without creating a MessageReceiver object, you can also use MessageSender and MessageReceiver to create a sender and receiver on an entity. However, note that you can only use a MessageReceiver to receive messages from a queue or subscription; you cannot receive messages or listen for messages from a topic. Similarly, you can only use a MessageSender to send messages to a queue or topic; you cannot send messages to a subscription. Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

When you create a MessageReceiver for subscriptions, the entityPath parameter is of the form topicPath/subscriptions/subscriptionName.

The following example receives a message from the queue created in the MessageSender example:

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();
}

Any public static (Shared in Visual Basic) members of this type are thread safe. Instance members are also guaranteed to be thread safe.

Contribuições da comunidade

ADICIONAR
Mostrar:
© 2014 Microsoft