MessageReceiver Classe
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las.
public abstract class MessageReceiver : Microsoft.ServiceBus.Messaging.MessagingEntityClienttype MessageReceiver = class
inherit MessagingEntityClientPublic MustInherit Class MessageReceiver
Inherits MessagingEntityClient- Herança
- Derivado
Comentários
Observe que o mecanismo de entrega de mensagens não fornece por padrão o recebimento de mensagens confiáveis de todos os tempos. O Barramento de Serviço exclui a mensagem quando ela sai do sistema. Para uma entrega garantida, você pode usar o modo de entrega PeekLock.
//********************************************************************************
// Sending messages to a Queue
//********************************************************************************
// Create a sender
MessageSender myMessageSender = myQueueClient.CreateSender(SendMode.Default);
// Send messages
List<string> Issues = new List<string>();
foreach (var issue in Issues)
{
myMessageSender.Send(new BrokeredMessage(issue));
}
//********************************************************************************
// Recieving messages from a Queue
//********************************************************************************
// Create a receiver
MessageReceiver myMessageReceiver =
myQueueClient.CreateReceiver(ReceiveMode.PeekLock);
// Receive messages
for (int count = 0; count < Issues.Count; count++)
{
var message = myMessageReceiver.Receive();
message.Complete();
}
//********************************************************************************
// Receiving messages from a particular session
//********************************************************************************
// Create subscription client
SubscriptionClient mySubscriptionClient = factory.CreateSubscriptionClient(mySubscription);
// Create a receiver
MessageReceiver myMessageReceiver = mySubscriptionClient.AcceptMessageSession(ReceiveMode.PeekLock);
// Receive messages
for (int count = 0; count *lt; Issues.Count; count++)
{
var message = myMessageReceiver.Receive();
message.Complete();
}
Propriedades
| BatchFlushInterval |
Obtém o intervalo de liberação do lote. |
| BatchingEnabled |
Obtém um valor que indica se o envio em lote está habilitado. |
| IsClosed |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| LastPeekedSequenceNumber |
Obtém ou define o número de sequência da última espiada da mensagem. |
| Mode |
Obtém o modo de recebimento da mensagem. |
| Path |
Obtém o caminho da fila, do tópico ou da assinatura em relação ao MessagingFactory endereço base. (Herdado de MessagingEntityClient) |
| PrefetchCount |
Obtém ou define o número de mensagens que o destinatário da mensagem pode solicitar simultaneamente. |
| RefreshEntityRuntimeDescription |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. |
| RetryPolicy |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| SupportsGetRuntimeEntityDescription |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. |
| ThisLock |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
Métodos
| Abandon(Guid) |
Descarta a mensagem e abre mão da propriedade do bloqueio de mensagem. |
| Abandon(Guid, IDictionary<String,Object>) |
Descarta a mensagem e abre mão da propriedade do bloqueio de mensagem. |
| AbandonAsync(Guid) |
Descarta a mensagem de forma assíncrona e renuncia à propriedade do bloqueio de mensagem. |
| AbandonAsync(Guid, IDictionary<String,Object>) |
Descarta a mensagem de forma assíncrona e renuncia à propriedade do bloqueio de mensagem. |
| Abort() |
Executa a funcionalidade de anulação na entidade de mensagens. (Herdado de ClientEntity) |
| Close() |
Envia uma mensagem de limpeza para o Barramento de Serviço para sinalizar a conclusão do uso de uma entidade. (Herdado de ClientEntity) |
| CloseAsync() |
Envia uma mensagem de limpeza de forma assíncrona para o Barramento de Serviço para sinalizar a conclusão do uso de uma entidade. (Herdado de ClientEntity) |
| Complete(Guid) |
Conclui a operação de recebimento em uma mensagem. Se estiver usando o AMQP, essa operação só poderá ser executada em mensagens recebidas por esse receptor. |
| CompleteAsync(Guid) |
Conclui de forma assíncrona a operação de recebimento em uma mensagem. Se estiver usando o AMQP, essa operação só poderá ser executada em mensagens recebidas por esse receptor. |
| CompleteBatch(IEnumerable<Guid>) |
Conclui a operação de recebimento em um lote de mensagens. Se estiver usando o AMQP, essa operação só poderá ser executada em mensagens recebidas por esse receptor. |
| CompleteBatchAsync(IEnumerable<Guid>) |
Conclui de forma assíncrona a operação de recebimento em um lote de mensagem. Se estiver usando o AMQP, essa operação só poderá ser executada em mensagens recebidas por esse receptor. |
| DeadLetter(Guid) |
Move a mensagem não entregue para a fila de mensagens mortas. |
| DeadLetter(Guid, IDictionary<String,Object>) |
Move a mensagem não entregue para a fila de mensagens mortas. |
| DeadLetter(Guid, String, String) |
Move a mensagem não entregue para a fila de mensagens mortas. |
| DeadLetterAsync(Guid) |
Move de forma assíncrona a mensagem não entregue para a fila de mensagens mortas. |
| DeadLetterAsync(Guid, IDictionary<String,Object>) |
Move de forma assíncrona a mensagem não entregue para a fila de mensagens mortas. |
| DeadLetterAsync(Guid, String, String) |
Move de forma assíncrona a mensagem não entregue para a fila de mensagens mortas. |
| Defer(Guid) |
Indica que o receptor deseja adiar o processamento da mensagem. |
| Defer(Guid, IDictionary<String,Object>) |
Indica que o receptor deseja adiar o processamento da mensagem. |
| DeferAsync(Guid) |
Adie de forma assíncrona o processamento da mensagem. |
| DeferAsync(Guid, IDictionary<String,Object>) |
Adie de forma assíncrona o processamento da mensagem. |
| Fault() |
Apenas para uso interno. Não herde dessa classe. (Herdado de ClientEntity) |
| GetLockToken(BrokeredMessage) |
Obtém o token de bloqueio associado à mensagem. |
| GetLockTokens(IEnumerable<BrokeredMessage>) |
Obtém a coleção de tokens de bloqueio da coleção especificada de mensagens. |
| GetProperty<T>() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. |
| OnAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan) |
Executa a ação de abandono. |
| OnAbort() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnBeginAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnAbandon ou BeginAbandon. |
| OnBeginClose(TimeSpan, AsyncCallback, Object) |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnComplete ou BeginComplete. |
| OnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnComplete ou BeginComplete. |
| OnBeginDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, Boolean, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnDeadLetter ou BeginDeadLetter. |
| OnBeginDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnDefer ou BeginDefer. |
| OnBeginOpen(TimeSpan, AsyncCallback, Object) |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnBeginPeek(TrackingContext, Int64, Int32, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação BeginPeek. |
| OnBeginRenewMessageLocks(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnBegin para mensagens de bloqueio. |
| OnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object) |
Executa a ação iniciar tentativa de receber. |
| OnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object) |
Executa a ação iniciar tentativa de receber. |
| OnBeginTryReceive2(TrackingContext, Int32, TimeSpan, AsyncCallback, Object) |
Executa a ação iniciar tentativa de receber. |
| OnBeginTryReceiveEventData(TrackingContext, Int32, TimeSpan, AsyncCallback, Object) |
Executa ao chamar a operação OnTryReceive ou BeginTryReceive para os dados do evento. |
| OnClose(TimeSpan) |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnClosed() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnComplete(TrackingContext, IEnumerable<Guid>, TimeSpan) |
Executa a ação completa. |
| OnDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, TimeSpan) |
Executa a ação mover para a fila de mensagens mortas. |
| OnDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan) |
Executa a ação de adiamento. |
| OnEndAbandon(IAsyncResult) |
Executa a ação de abandono final. |
| OnEndClose(IAsyncResult) |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnEndComplete(IAsyncResult) |
Executa a ação de término completo. |
| OnEndDeadLetter(IAsyncResult) |
Executa a ação de migração final para a fila de mensagens mortas. |
| OnEndDefer(IAsyncResult) |
Executa a ação de adiamento final. |
| OnEndOpen(IAsyncResult) |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnEndPeek(IAsyncResult) |
Executa a operação EndPeek. |
| OnEndRenewMessageLocks(IAsyncResult) |
Executa a ação EndRenew para bloqueios de mensagens. |
| OnEndTryReceive(IAsyncResult, IEnumerable<BrokeredMessage>) |
Executa a ação end try receive. |
| OnEndTryReceive2(IAsyncResult, IEnumerable<BrokeredMessage>) |
Executa a ação end try receive. |
| OnEndTryReceiveEventData(IAsyncResult, IEnumerable<EventData>) |
Executa a ação EndTryReceive para os dados do evento. |
| OnFaulted() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnMessage(Action<BrokeredMessage>, OnMessageOptions) |
Processa uma mensagem em uma bomba de mensagem controlada por eventos. |
| OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions) |
Processa de forma assíncrona uma mensagem em uma bomba de mensagem controlada por eventos. |
| OnOpen(TimeSpan) |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnOpened() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| OnPeek(TrackingContext, Int64, Int32, TimeSpan) |
Executa ao chamar a operação Peek. |
| OnRenewMessageLocks(TrackingContext, IEnumerable<Guid>, TimeSpan) |
Executa a ação Renovar para mensagens de bloqueio. |
| OnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>) |
Executa a ação try receive. |
| OnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>) |
Executa a ação try receive. |
| Peek() |
Lê a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| Peek(Int64) |
Lê a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| PeekAsync() |
Lê de forma assíncrona a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| PeekAsync(Int64) |
Lê de forma assíncrona a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| PeekBatch(Int32) |
Lê o próximo lote de mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| PeekBatch(Int64, Int32) |
Lê o próximo lote de mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| PeekBatchAsync(Int32) |
Lê de forma assíncrona o próximo lote de mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| PeekBatchAsync(Int64, Int32) |
Lê de forma assíncrona o próximo lote de mensagem sem alterar o estado do receptor ou a origem da mensagem. |
| Receive() |
Recebe um BrokeredMessage da fila ou tópico atual. |
| Receive(Int64) |
Recebe uma mensagem adiada da fila ou tópico atual. Esse método funciona apenas para mensagens adiadas, não regulares. |
| Receive(TimeSpan) |
Recebe um BrokeredMessage da fila ou tópico atual. |
| ReceiveAsync() |
Recebe de forma assíncrona uma mensagem da fila ou tópico atual. |
| ReceiveAsync(Int64) |
Recebe de forma assíncrona uma mensagem adiada da fila ou tópico atual. Esse método funciona apenas para mensagens adiadas, não regulares. |
| ReceiveAsync(TimeSpan) |
Recebe de forma assíncrona uma mensagem da fila ou tópico atual. |
| ReceiveBatch(IEnumerable<Int64>) |
Recebe um lote de mensagens. |
| ReceiveBatch(Int32) |
Recebe um lote de mensagens. |
| ReceiveBatch(Int32, TimeSpan) |
Recebe um lote de mensagens. |
| ReceiveBatchAsync(IEnumerable<Int64>) |
Recebe de forma assíncrona um lote de mensagens. |
| ReceiveBatchAsync(Int32) |
Recebe de forma assíncrona um lote de mensagens. |
| ReceiveBatchAsync(Int32, TimeSpan) |
Recebe de forma assíncrona um lote de mensagens. |
| ThrowIfClosed() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| ThrowIfDisposed() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| ThrowIfDisposedOrImmutable() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| ThrowIfDisposedOrNotOpen() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
| ThrowIfFaulted() |
A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las. (Herdado de ClientEntity) |
Aplica-se a
Azure SDK for .NET