MessageReceiver Clase
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
La clase MessageReceiver se usa para recibir mensajes del contenedor de mensajes y confirmarlos.
public abstract class MessageReceiver : Microsoft.ServiceBus.Messaging.MessagingEntityClienttype MessageReceiver = class
inherit MessagingEntityClientPublic MustInherit Class MessageReceiver
Inherits MessagingEntityClient- Herencia
- Derivado
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) |
Se aplica a
Azure SDK for .NET
Comentarios
Próximamente: A lo largo de 2024 iremos eliminando gradualmente GitHub Issues como mecanismo de comentarios sobre el contenido y lo sustituiremos por un nuevo sistema de comentarios. Para más información, vea: https://aka.ms/ContentUserFeedback.
Enviar y ver comentarios de