Exportar (0) Imprimir
Expandir todo

Clase MessageReceiver

Recibe mensajes del contenedor de mensajes y los reconoce.

Espacio de nombres:  Microsoft.ServiceBus.Messaging
Ensamblado:  Microsoft.ServiceBus (en Microsoft.ServiceBus.dll)

'Declaración
Public MustInherit Class MessageReceiver _
	Inherits MessageClientEntity
'Uso
Dim instance As MessageReceiver

El tipo MessageReceiver expone los siguientes miembros.

  NombreDescripción
Propiedad públicaBatchFlushIntervalObtiene el intervalo de descarga por lotes.
Propiedad protegidaBatchingEnabledObtiene un valor que indica si el procesamiento por lotes está habilitado.
Propiedad públicaIsClosed (Se hereda de ClientEntity.)
Propiedad públicaLastPeekedSequenceNumberObtiene o establece el número de secuencia del último mensaje inspeccionado.
Propiedad públicaModeObtiene el modo de recepción del mensaje.
Propiedad públicaPathObtiene la ruta de la cola o del tema relativa a la dirección base de MessagingFactory.
Propiedad públicaPrefetchCountObtiene o establece el número de mensajes que el receptor de mensajes puede solicitar simultáneamente.
Propiedad protegidaReceiverStartTime
Propiedad públicaRetryPolicy (Se hereda de ClientEntity.)
Propiedad protegidaStartOffset
Propiedad protegidaThisLock (Se hereda de ClientEntity.)
Arriba

  NombreDescripción
Método públicoAbandon(Guid)Descarta el mensaje y renuncia a la propiedad de bloqueo del mensaje.
Método públicoAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Descarta el mensaje y renuncia a la propiedad de bloqueo del mensaje.
Método públicoAbandonAsync(Guid)Descarta el mensaje y renuncia a la propiedad de bloqueo del mensaje de manera asincrónica.
Método públicoAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Descarta el mensaje y renuncia a la propiedad de bloqueo del mensaje de manera asincrónica.
Método públicoAbortPerforms abort functionality on the messaging entity. (Se hereda de ClientEntity.)
Método públicoBeginAbandon(Guid, AsyncCallback, Object)Comienza una operación asincrónica para abandonar el mensaje y renunciar a su bloqueo.
Método públicoBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Comienza una operación asincrónica para abandonar el mensaje y renunciar a su bloqueo.
Método públicoBeginCloseComienza una operación asincrónica para cerrar la entidad del cliente de mensajes. (Se hereda de MessageClientEntity.)
Método públicoBeginCompleteComienza una operación asincrónica para completar la recepción de un mensaje.
Método públicoBeginCompleteBatchComienza una operación asincrónica para completar un mensaje por lotes.
Método públicoBeginDeadLetter(Guid, AsyncCallback, Object)Comienza una operación asincrónica para mover un mensaje a la cola de mensajes fallidos.
Método públicoBeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Comienza una operación asincrónica para mover un mensaje a la cola de mensajes fallidos.
Método públicoBeginDeadLetter(Guid, String, String, AsyncCallback, Object)Comienza una operación asincrónica para mover un mensaje a la cola de mensajes fallidos.
Método públicoBeginDefer(Guid, AsyncCallback, Object)Comienza una operación asincrónica para suspender la recepción de un mensaje.
Método públicoBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Comienza una operación asincrónica para suspender la recepción de un mensaje.
Método públicoBeginPeek(AsyncCallback, Object)Comienza una operación para inspeccionar un mensaje.
Método públicoBeginPeek(Int64, AsyncCallback, Object)Comienza una operación para inspeccionar un mensaje.
Método públicoBeginPeekBatch(Int32, AsyncCallback, Object)Comienza una operación para inspeccionar lote un mensajes.
Método públicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Comienza una operación para inspeccionar lote un mensajes.
Método públicoBeginReceive(AsyncCallback, Object)Comienza una operación asincrónica para recibir un mensaje.
Método públicoBeginReceive(Int64, AsyncCallback, Object)Comienza una operación asincrónica para recibir un mensaje.
Método públicoBeginReceive(TimeSpan, AsyncCallback, Object)Comienza una operación asincrónica para recibir un mensaje.
Método públicoBeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)Comienza una operación asincrónica para recibir un lote de mensajes.
Método públicoBeginReceiveBatch(Int32, AsyncCallback, Object)Comienza una operación asincrónica para recibir un lote de mensajes.
Método públicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Comienza una operación asincrónica para recibir un lote de mensajes.
Método públicoCloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (Se hereda de ClientEntity.)
Método públicoCloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (Se hereda de ClientEntity.)
Método públicoCompleteCompleta la operación de recepción de un mensaje.
Método públicoCompleteAsyncCompleta de manera asincrónica la operación de recepción de un mensaje.
Método públicoCompleteBatchCompleta la operación de recepción de un lote de mensajes.
Método públicoCompleteBatchAsyncCompleta de manera asincrónica la operación de recepción de un lote de mensajes.
Método públicoDeadLetter(Guid)Mueve el mensaje no entregado a la cola de mensajes fallidos.
Método públicoDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))Mueve el mensaje no entregado a la cola de mensajes fallidos.
Método públicoDeadLetter(Guid, String, String)Mueve el mensaje no entregado a la cola de mensajes fallidos.
Método públicoDeadLetterAsync(Guid)Mueve el mensaje no entregado de manera asincrónica a la cola de mensajes fallidos.
Método públicoDeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Mueve el mensaje no entregado de manera asincrónica a la cola de mensajes fallidos.
Método públicoDeadLetterAsync(Guid, String, String)Mueve el mensaje no entregado de manera asincrónica a la cola de mensajes fallidos.
Método públicoDefer(Guid)Indica que el receptor desea aplazar el procesamiento del mensaje.
Método públicoDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Indica que el receptor desea aplazar el procesamiento del mensaje.
Método públicoDeferAsync(Guid)Aplazar de manera asincrónica el procesamiento del mensaje.
Método públicoDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Aplazar de manera asincrónica el procesamiento del mensaje.
Método públicoEndAbandonFinaliza la operación asincrónica para abandonar el mensaje y renunciar a su bloqueo.
Método públicoEndCloseFinaliza una operación asincrónica para cerrar la entidad del cliente de mensajes. (Se hereda de MessageClientEntity.)
Método públicoEndCompleteFinaliza la operación asincrónica para completar la recepción de un mensaje.
Método públicoEndCompleteBatchFinaliza la operación asincrónica para completar la recepción de un lote de mensajes.
Método públicoEndDeadLetterFinaliza una operación asincrónica para mover el mensaje a la cola de mensajes fallidos.
Método públicoEndDeferFinaliza una operación asincrónica para aplazar la recepción de un mensaje.
Método públicoEndPeekFinaliza una operación asincrónica para inspeccionar un mensaje.
Método públicoEndPeekBatchFinaliza una operación asincrónica para inspeccionar un lote de mensajes.
Método públicoEndReceiveFinaliza una operación asincrónica para recibir un mensaje.
Método públicoEndReceiveBatchFinaliza una operación asincrónica para recibir un lote de mensajes.
Método públicoEquals (Se hereda de Object.)
Método protegidoFaultFor internal use only. Do not inherit from this class. (Se hereda de ClientEntity.)
Método protegidoFinalize (Se hereda de Object.)
Método públicoGetHashCode (Se hereda de Object.)
Método protegidoMiembro estáticoGetLockTokenObtiene el enlace del token de bloqueo al mensaje.
Método protegidoMiembro estáticoGetLockTokensObtiene la colección de tokens de bloqueo de la colección especificada de mensajes.
Método públicoGetType (Se hereda de Object.)
Método protegidoMemberwiseClone (Se hereda de Object.)
Método protegidoOnAbandonSe ejecuta al llamar a la operación Abandon.
Método protegidoOnAbort (Se hereda de ClientEntity.)
Método protegidoOnBeginAbandonSe ejecuta al llamar a la operación OnAbandon o BeginAbandon.
Método protegidoOnBeginClose (Se hereda 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)Se ejecuta al llamar a la operación OnComplete o BeginComplete.
Método protegidoOnBeginDeadLetterSe ejecuta al llamar a la operación OnDeadLetter o BeginDeadLetter.
Método protegidoOnBeginDeferSe ejecuta al llamar a la operación OnDefer o BeginDefer.
Método protegidoOnBeginOpen (Se hereda de ClientEntity.)
Método protegidoOnBeginPeekSe ejecuta al llamar a la operación BeginPeek.
Método protegidoOnBeginRenewMessageLocksSe ejecuta al llamar a la operación OnBegin para bloquear mensajes.
Método protegidoOnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)Se ejecuta al llamar a la operación OnTryReceive o BeginTryReceive.
Método protegidoOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)Se ejecuta al llamar a la operación OnTryReceive o BeginTryReceive.
Método protegidoOnBeginTryReceive2Se ejecuta al llamar a la operación OnTryReceive o BeginTryReceive.
Método protegidoOnBeginTryReceiveEventData
Método protegidoOnClose (Se hereda de ClientEntity.)
Método protegidoOnClosed (Se hereda de ClientEntity.)
Método protegidoOnCompleteSe ejecuta al llamar a la operación Complete.
Método protegidoOnDeadLetterSe ejecuta al llamar a la operación DeadLetter.
Método protegidoOnDeferSe ejecuta al llamar a la operación Defer.
Método protegidoOnEndAbandonEjecuta la acción de finalización de abandono.
Método protegidoOnEndClose (Se hereda de ClientEntity.)
Método protegidoOnEndCompleteEjecuta la acción de finalización de terminación.
Método protegidoOnEndDeadLetterEjecute la acción de finalización del movimiento a la cola de mensajes fallidos.
Método protegidoOnEndDeferEjecuta la acción de finalización de aplazamiento.
Método protegidoOnEndOpen (Se hereda de ClientEntity.)
Método protegidoOnEndPeekSe ejecuta la operación EndPeek.
Método protegidoOnEndRenewMessageLocksEjecuta la acción EndRenew de los bloqueos de mensajes.
Método protegidoOnEndTryReceiveEjecuta la acción de finalización de intento de recepción.
Método protegidoOnEndTryReceive2Ejecuta la acción de finalización de intento de recepción.
Método protegidoOnEndTryReceiveEventData
Método protegidoOnFaulted (Se hereda de ClientEntity.)
Método públicoOnMessageProcesa un mensaje en un bombeo de mensajes basados en eventos.
Método públicoOnMessageAsyncProcesa de manera asincrónica un mensaje en un bombeo de mensajes basados en eventos.
Método protegidoOnOpen (Se hereda de ClientEntity.)
Método protegidoOnOpened (Se hereda de ClientEntity.)
Método protegidoOnPeekSe ejecuta al llamar a la operación Peek.
Método protegidoOnRenewMessageLocksEjecuta la acción Renew de los mensajes de bloqueo.
Método protegidoOnTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Se ejecuta al llamar a la operación TryReceive.
Método protegidoOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Se ejecuta al llamar a la operación TryReceive.
Método públicoPeek()()()()Lee el siguiente mensaje sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeek(Int64)Lee el siguiente mensaje sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeekAsync()()()()Lee de manera asincrónica el siguiente mensaje sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeekAsync(Int64)Lee de manera asincrónica el siguiente mensaje sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeekBatch(Int32)Lee el siguiente lote de mensajes sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeekBatch(Int64, Int32)Lee el siguiente lote de mensajes sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeekBatchAsync(Int32)Lee de manera asincrónica el siguiente lote de mensajes sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoPeekBatchAsync(Int64, Int32)Lee de manera asincrónica el siguiente lote de mensajes sin cambiar el estado del receptor ni el origen del mensaje.
Método públicoReceive()()()()Recibe un valor de BrokeredMessage de la cola o del tema actual.
Método públicoReceive(Int64)Recibe un mensaje de la cola o del tema actual.
Método públicoReceive(TimeSpan)Recibe un valor de BrokeredMessage de la cola o del tema actual.
Método públicoReceiveAsync()()()()Recibe de manera asincrónica un mensaje de la cola o del tema actual.
Método públicoReceiveAsync(Int64)Recibe de manera asincrónica un mensaje de la cola o del tema actual.
Método públicoReceiveAsync(TimeSpan)Recibe de manera asincrónica un mensaje de la cola o del tema actual.
Método públicoReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Recibe un lote de mensajes.
Método públicoReceiveBatch(Int32)Recibe un lote de mensajes.
Método públicoReceiveBatch(Int32, TimeSpan)Recibe un lote de mensajes.
Método públicoReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Recibe de manera asincrónica un lote de mensajes.
Método públicoReceiveBatchAsync(Int32)Recibe de manera asincrónica un lote de mensajes.
Método públicoReceiveBatchAsync(Int32, TimeSpan)Recibe de manera asincrónica un lote de mensajes.
Método protegidoThrowIfClosed (Se hereda de ClientEntity.)
Método protegidoThrowIfDisposed (Se hereda de ClientEntity.)
Método protegidoThrowIfDisposedOrImmutable (Se hereda de ClientEntity.)
Método protegidoThrowIfDisposedOrNotOpen (Se hereda de ClientEntity.)
Método protegidoThrowIfFaulted (Se hereda de ClientEntity.)
Método públicoToString (Se hereda de Object.)
Arriba

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.

Adiciones de comunidad

AGREGAR
Mostrar:
© 2014 Microsoft