MessageReceiver Clase

Definición

Espacio de nombres:

Microsoft.ServiceBus.Messaging

Ensamblado:

Microsoft.ServiceBus.dll

Paquete:

WindowsAzure.ServiceBus v6.2.2

La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos.

public abstract class MessageReceiver : Microsoft.ServiceBus.Messaging.MessagingEntityClient

type MessageReceiver = class
    inherit MessagingEntityClient

Public MustInherit Class MessageReceiver
Inherits MessagingEntityClient

Herencia

Object

ClientEntity

MessagingEntityClient

MessageReceiver

Derivado

Microsoft.ServiceBus.Messaging.MessageSession

Comentarios

Tenga en cuenta que el mecanismo de entrega de mensajes no proporciona de forma predeterminada mensajes confiables de forma predeterminada. Service Bus elimina el mensaje una vez que sale del sistema. Para una entrega garantizada, puedes usar el 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();
}

Propiedades

BatchFlushInterval	Obtiene el intervalo de vaciado por lotes.
BatchingEnabled	Obtiene un valor que indica si el procesamiento por lotes está habilitado.
IsClosed	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
LastPeekedSequenceNumber	Obtiene o establece el número de secuencia del mensaje que se ha inspeccionado por última vez.
Mode	Obtiene el modo de recepción del mensaje.
Path	Obtiene la ruta de acceso de la cola, el tema o la suscripción en relación con la MessagingFactory dirección base. (Heredado de MessagingEntityClient)
PrefetchCount	Obtiene o establece el número de mensajes que el destinatario del mensaje puede solicitar simultáneamente.
RefreshEntityRuntimeDescription	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos.
RetryPolicy	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
SupportsGetRuntimeEntityDescription	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos.
ThisLock	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)

Métodos

Abandon(Guid)	Descarta el mensaje y renuncia a la propiedad del bloqueo del mensaje.
Abandon(Guid, IDictionary<String,Object>)	Descarta el mensaje y renuncia a la propiedad del bloqueo del mensaje.
AbandonAsync(Guid)	Descarta de forma asincrónica el mensaje y renuncia a la propiedad del bloqueo del mensaje.
AbandonAsync(Guid, IDictionary<String,Object>)	Descarta de forma asincrónica el mensaje y renuncia a la propiedad del bloqueo del mensaje.
Abort()	Realiza la funcionalidad de anulación en la entidad de mensajería. (Heredado de ClientEntity)
Close()	Envía un mensaje de limpieza a Service Bus para indicar la finalización del uso de una entidad. (Heredado de ClientEntity)
CloseAsync()	Envía un mensaje de limpieza de forma asincrónica a Service Bus para indicar la finalización del uso de una entidad. (Heredado de ClientEntity)
Complete(Guid)	Completa la operación de recepción en un mensaje. Si usa AMQP, esta operación solo se puede realizar en los mensajes recibidos por este receptor.
CompleteAsync(Guid)	Completa de forma asincrónica la operación de recepción en un mensaje. Si usa AMQP, esta operación solo se puede realizar en los mensajes recibidos por este receptor.
CompleteBatch(IEnumerable<Guid>)	Completa la operación de recepción en un lote de mensajes. Si usa AMQP, esta operación solo se puede realizar en los mensajes recibidos por este receptor.
CompleteBatchAsync(IEnumerable<Guid>)	Completa de forma asincrónica la operación de recepción en un lote de mensajes. Si usa AMQP, esta operación solo se puede realizar en los mensajes recibidos por este receptor.
DeadLetter(Guid)	Mueve el mensaje no entregado a la cola de mensajes fallidos.
DeadLetter(Guid, IDictionary<String,Object>)	Mueve el mensaje no entregado a la cola de mensajes fallidos.
DeadLetter(Guid, String, String)	Mueve el mensaje no entregado a la cola de mensajes fallidos.
DeadLetterAsync(Guid)	Mueve de forma asincrónica el mensaje no entregado a la cola de mensajes fallidos.
DeadLetterAsync(Guid, IDictionary<String,Object>)	Mueve de forma asincrónica el mensaje no entregado a la cola de mensajes fallidos.
DeadLetterAsync(Guid, String, String)	Mueve de forma asincrónica el mensaje no entregado a la cola de mensajes fallidos.
Defer(Guid)	Indica que el receptor quiere aplazar el procesamiento del mensaje.
Defer(Guid, IDictionary<String,Object>)	Indica que el receptor quiere aplazar el procesamiento del mensaje.
DeferAsync(Guid)	Aplazar de forma asincrónica el procesamiento del mensaje.
DeferAsync(Guid, IDictionary<String,Object>)	Aplazar de forma asincrónica el procesamiento del mensaje.
Fault()	Solo para uso interno. No herede de esta clase. (Heredado de ClientEntity)
GetLockToken(BrokeredMessage)	Obtiene el token de bloqueo enlazado al mensaje.
GetLockTokens(IEnumerable<BrokeredMessage>)	Obtiene la colección de tokens de bloqueo de la colección de mensajes especificada.
GetProperty<T>()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos.
OnAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan)	Ejecuta la acción de abandono.
OnAbort()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnBeginAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnAbandon o BeginAbandon.
OnBeginClose(TimeSpan, AsyncCallback, Object)	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnComplete o BeginComplete.
OnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnComplete o BeginComplete.
OnBeginDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, Boolean, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnDeadLetter o BeginDeadLetter.
OnBeginDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnDefer o BeginDefer.
OnBeginOpen(TimeSpan, AsyncCallback, Object)	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnBeginPeek(TrackingContext, Int64, Int32, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación BeginPeek.
OnBeginRenewMessageLocks(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnBegin para bloquear mensajes.
OnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)	Ejecuta la acción begin try receive.
OnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)	Ejecuta la acción begin try receive.
OnBeginTryReceive2(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)	Ejecuta la acción begin try receive.
OnBeginTryReceiveEventData(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)	Se ejecuta al llamar a la operación OnTryReceive o BeginTryReceive para los datos del evento.
OnClose(TimeSpan)	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnClosed()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnComplete(TrackingContext, IEnumerable<Guid>, TimeSpan)	Ejecuta la acción completa.
OnDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, TimeSpan)	Ejecuta la acción mover a cola de mensajes fallidos.
OnDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan)	Ejecuta la acción de aplazamiento.
OnEndAbandon(IAsyncResult)	Ejecuta la acción de abandono final.
OnEndClose(IAsyncResult)	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnEndComplete(IAsyncResult)	Ejecuta la acción de finalización completa.
OnEndDeadLetter(IAsyncResult)	Ejecuta el movimiento final a la acción de cola de mensajes fallidos.
OnEndDefer(IAsyncResult)	Ejecuta la acción de aplazamiento final.
OnEndOpen(IAsyncResult)	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnEndPeek(IAsyncResult)	Ejecuta la operación EndPeek.
OnEndRenewMessageLocks(IAsyncResult)	Ejecuta la acción EndRenew para los bloqueos de mensaje.
OnEndTryReceive(IAsyncResult, IEnumerable<BrokeredMessage>)	Ejecuta la acción end try receive.
OnEndTryReceive2(IAsyncResult, IEnumerable<BrokeredMessage>)	Ejecuta la acción end try receive.
OnEndTryReceiveEventData(IAsyncResult, IEnumerable<EventData>)	Ejecuta la acción EndTryReceive para los datos del evento.
OnFaulted()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnMessage(Action<BrokeredMessage>, OnMessageOptions)	Procesa un mensaje en una bomba de mensajes controlada por eventos.
OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)	Procesa de forma asincrónica un mensaje en una bomba de mensajes controlada por eventos.
OnOpen(TimeSpan)	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnOpened()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
OnPeek(TrackingContext, Int64, Int32, TimeSpan)	Se ejecuta al llamar a la operación Peek.
OnRenewMessageLocks(TrackingContext, IEnumerable<Guid>, TimeSpan)	Ejecuta la acción Renovar para los mensajes de bloqueo.
OnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>)	Ejecuta la acción try receive.
OnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>)	Ejecuta la acción try receive.
Peek()	Lee el siguiente mensaje sin cambiar el estado del receptor o el origen del mensaje.
Peek(Int64)	Lee el siguiente mensaje sin cambiar el estado del receptor o el origen del mensaje.
PeekAsync()	Lee de forma asincrónica el siguiente mensaje sin cambiar el estado del receptor o el origen del mensaje.
PeekAsync(Int64)	Lee de forma asincrónica el siguiente mensaje sin cambiar el estado del receptor o el origen del mensaje.
PeekBatch(Int32)	Lee el siguiente lote de mensajes sin cambiar el estado del receptor o el origen del mensaje.
PeekBatch(Int64, Int32)	Lee el siguiente lote de mensajes sin cambiar el estado del receptor o el origen del mensaje.
PeekBatchAsync(Int32)	Lee de forma asincrónica el siguiente lote de mensajes sin cambiar el estado del receptor o el origen del mensaje.
PeekBatchAsync(Int64, Int32)	Lee de forma asincrónica el siguiente lote de mensajes sin cambiar el estado del receptor o el origen del mensaje.
Receive()	Recibe un BrokeredMessage elemento de la cola o tema actual.
Receive(Int64)	Recibe un mensaje diferido de la cola o el tema actual. Este método solo funciona para el mensaje diferido, no para uno normal.
Receive(TimeSpan)	Recibe un BrokeredMessage elemento de la cola o tema actual.
ReceiveAsync()	Recibe de forma asincrónica un mensaje de la cola o tema actual.
ReceiveAsync(Int64)	Recibe de forma asincrónica un mensaje diferido de la cola o el tema actual. Este método solo funciona para el mensaje diferido, no para uno normal.
ReceiveAsync(TimeSpan)	Recibe de forma asincrónica un mensaje de la cola o tema actual.
ReceiveBatch(IEnumerable<Int64>)	Recibe un lote de mensajes.
ReceiveBatch(Int32)	Recibe un lote de mensajes.
ReceiveBatch(Int32, TimeSpan)	Recibe un lote de mensajes.
ReceiveBatchAsync(IEnumerable<Int64>)	Recibe de forma asincrónica un lote de mensajes.
ReceiveBatchAsync(Int32)	Recibe de forma asincrónica un lote de mensajes.
ReceiveBatchAsync(Int32, TimeSpan)	Recibe de forma asincrónica un lote de mensajes.
ThrowIfClosed()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
ThrowIfDisposed()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
ThrowIfDisposedOrImmutable()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
ThrowIfDisposedOrNotOpen()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)
ThrowIfFaulted()	La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos. (Heredado de ClientEntity)