MessageReceiver Classe

Definição

A classe MessageReceiver é usada para receber mensagens do contêiner de mensagens e confirmá-las.

public abstract class MessageReceiver : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type MessageReceiver = class
    inherit MessagingEntityClient
Public 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