Exportar (0) Imprimir
Expandir todo

Clase SubscriptionClient

Representa la clase de ancla usada en operaciones de tiempo real relacionadas con una suscripción de tema.

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

public abstract class SubscriptionClient : MessageClientEntity

El tipo SubscriptionClient expone los siguientes miembros.

  NombreDescripción
Propiedad públicaIsClosed (Se hereda de ClientEntity.)
Propiedad públicaMessagingFactoryObtiene la fábrica de mensajes utilizada para crear este cliente se suscripción.
Propiedad públicaModeObtiene el modo de recepción de mensajes al procesar el mensaje recibido.
Propiedad públicaNameObtiene el nombre de la suscripción.
Propiedad públicaPrefetchCountObtiene o establece el número de mensajes que el receptor de mensajes puede solicitar simultáneamente.
Propiedad públicaRetryPolicy (Se hereda de ClientEntity.)
Propiedad protegidaThisLock (Se hereda de ClientEntity.)
Propiedad públicaTopicPathObtiene el nombre de ruta completo del tema.
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úblicoAcceptMessageSession()()()()Acepta una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción.
Método públicoAcceptMessageSession(String)Acepta una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el identificador de sesión determinado.
Método públicoAcceptMessageSession(TimeSpan)Acepta una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el tiempo de espera del servidor especificado.
Método públicoAcceptMessageSession(String, TimeSpan)Acepta una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el identificador de sesión determinado y el tiempo de espera.
Método públicoAcceptMessageSessionAsync()()()()Acepta de manera asincrónica una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el tiempo de espera del servidor especificado.
Método públicoAcceptMessageSessionAsync(String)Acepta de manera asincrónica una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el tiempo de espera del servidor especificado.
Método públicoAcceptMessageSessionAsync(TimeSpan)Acepta de manera asincrónica una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el tiempo de espera del servidor especificado.
Método públicoAcceptMessageSessionAsync(String, TimeSpan)Acepta de manera asincrónica una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción usando el tiempo de espera del servidor especificado.
Método públicoAddRule(RuleDescription)Añade una nueva regla al Subscription mediante la descripción de regla especificada.
Método públicoAddRule(String, Filter)Añade una regla a la suscripción actual con el nombre especificado y la expresión de filtro.
Método públicoAddRuleAsync(RuleDescription)Añade de manera asincrónica una nueva regla al Subscription mediante la descripción de regla especificada.
Método públicoAddRuleAsync(String, Filter)Añade de manera asincrónica una regla a la suscripción actual con el nombre especificado y la expresión de filtro.
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úblicoBeginAcceptMessageSession(AsyncCallback, Object)Comienza una operación asincrónica para aceptar una sesión de mensajes.
Método públicoBeginAcceptMessageSession(String, AsyncCallback, Object)Comienza una operación asincrónica para aceptar una sesión de mensajes.
Método públicoBeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)Comienza una operación asincrónica para aceptar una sesión de mensajes.
Método públicoBeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)Comienza una operación asincrónica para aceptar una sesión de mensajes.
Método públicoBeginAddRule(RuleDescription, AsyncCallback, Object)Comienza una operación asincrónica para agregar una nueva regla a la suscripción.
Método públicoBeginAddRule(String, Filter, AsyncCallback, Object)Comienza una operación asincrónica para agregar una nueva regla a la suscripción.
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 el procesamiento de un mensaje.
Método públicoBeginCompleteBatchComienza una operación asincrónica para completar el procesamiento de un mensaje.
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 el procesamiento de un mensaje.
Método públicoBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Comienza una operación asincrónica para suspender el procesamiento de un mensaje.
Método públicoBeginGetMessageSessions(AsyncCallback, Object)Comienza una operación asincrónica para obtener una sesión de mensajes.
Método públicoBeginGetMessageSessions(DateTime, AsyncCallback, Object)Comienza una operación asincrónica para obtener una sesión de mensajes.
Método públicoBeginPeek(AsyncCallback, Object)Inicia una operación asincrónica para devolver sin eliminar el primer mensaje de la cola.
Método públicoBeginPeek(Int64, AsyncCallback, Object)Inicia una operación asincrónica para devolver sin eliminar el primer mensaje de la cola.
Método públicoBeginPeekBatch(Int32, AsyncCallback, Object)Comienza una operación asincrónica para inspeccionar un lote.
Método públicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Comienza una operación asincrónica para inspeccionar un lote.
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.
Método públicoBeginReceiveBatch(Int32, AsyncCallback, Object)Comienza una operación asincrónica para recibir un lote.
Método públicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Comienza una operación asincrónica para recibir un lote.
Método públicoBeginRemoveRuleComienza una acción asincrónica de eliminación de reglas.
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 el procesamiento de un mensaje.
Método públicoCompleteAsyncCompleta el procesamiento de un mensaje de manera asincrónica.
Método públicoCompleteBatchCompleta el procesamiento de un lote.
Método públicoCompleteBatchAsyncCompleta el procesamiento de un lote de manera asincrónica.
Método públicoMiembro estáticoCreate(String, String)Crea una nueva copia de SubscriptionClient con el nombre y la ruta de acceso de tema especificados.
Método públicoMiembro estáticoCreate(String, String, ReceiveMode)Crea una nueva copia de SubscriptionClient con el nombre, la ruta de acceso del tema y el modo especificados.
Método públicoMiembro estáticoCreateFromConnectionString(String, String, String)Crea una nueva copia de SubscriptionClient desde una cadena de conexión con la ruta de acceso del tema y el nombre especificados.
Método públicoMiembro estáticoCreateFromConnectionString(String, String, String, ReceiveMode)Crea una nueva copia de SubscriptionClient desde una cadena de conexión con la ruta de acceso del tema, el nombre y el modo especificados.
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)Suspende el procesamiento de un mensaje.
Método públicoDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Suspende el procesamiento de un mensaje.
Método públicoDeferAsync(Guid)Suspende el procesamiento de un mensaje de manera asincrónica.
Método públicoDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Suspende el procesamiento de un mensaje de manera asincrónica.
Método públicoEndAbandonFinaliza una operación asincrónica para abandonar el mensaje y renunciar a su bloqueo.
Método públicoEndAcceptMessageSessionAcepta una operación asincrónica para aceptar una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción.
Método públicoEndAddRuleFinaliza una operación asincrónica de adición de reglas.
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 una operación asincrónica para completar el procesamiento de un mensaje.
Método públicoEndCompleteBatchFinaliza una operación asincrónica para completar el procesamiento de un lote.
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 suspender el procesamiento de un mensaje.
Método públicoEndGetMessageSessionsFinaliza una operación asincrónica para obtener el procesamiento de un mensaje.
Método públicoEndPeekFinaliza la operación de inspección asincrónica.
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.
Método públicoEndRemoveRuleFinaliza una operación asincrónica de eliminación de reglas.
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úblicoMiembro estáticoFormatDeadLetterPathCrea una ruta de mensajes fallidos de nombre de formato mediante la ruta del tema especificada y el nombre de la suscripción.
Método públicoMiembro estáticoFormatSubscriptionPathCrea una ruta de suscripción de nombre de formato mediante la ruta del tema especificada y el nombre de la suscripción.
Método públicoGetHashCode (Se hereda de Object.)
Método públicoGetMessageSessions()()()()Obtiene una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción.
Método públicoGetMessageSessions(DateTime)Recupera todas las sesiones de mensajes cuyo estado de sesión se ha actualizado desde lastUpdatedTime.
Método públicoGetMessageSessionsAsync()()()()Obtiene de manera asincrónica una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción.
Método públicoGetMessageSessionsAsync(DateTime)Obtiene de manera asincrónica una sesión de mensajes que permite agrupar mensajes relacionados para procesarlos en una sola transacción.
Método públicoGetType (Se hereda de Object.)
Método protegidoMemberwiseClone (Se hereda de Object.)
Método protegidoOnAbortEjecuta la acción de anulación. (Invalida ClientEntity..::..OnAbort()()()().)
Método protegidoOnBeginAcceptMessageSessionSe ejecuta al llamar a la operación BeginAcceptMessageSession.
Método protegidoOnBeginAddRuleSe ejecuta al llamar a la operación BeginAddRule.
Método protegidoOnBeginCloseEjecuta la acción para iniciar el cierre. (Invalida ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object).)
Método protegidoOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)Ejecuta la acción para iniciar la creación de receptor.
Método protegidoOnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object)Ejecuta la acción para iniciar la creación de receptor.
Método protegidoOnBeginGetMessageSessionsSe ejecuta al llamar a la operación BeginGetMessageSessions.
Método protegidoOnBeginOpen (Se hereda de ClientEntity.)
Método protegidoOnBeginRemoveRuleComienza a quitar un Rule de un Subscription a través del protocolo del cliente de tiempo de ejecución.
Método protegidoOnBeginRemoveRulesByTagComienza a quitar un Rule de un Subscription a través del protocolo del cliente de tiempo de ejecución mediante una etiqueta.
Método protegidoOnCloseEjecuta la acción de cierre. (Invalida ClientEntity..::..OnClose(TimeSpan).)
Método protegidoOnClosed (Se hereda de ClientEntity.)
Método protegidoOnEndAcceptMessageSessionSe ejecuta al llamar a la operación EndAcceptMessageSession.
Método protegidoOnEndAddRuleFinaliza la llamada asincrónica a OnBeginAddRule.
Método protegidoOnEndCloseEjecuta la acción de finalización de cierre. (Invalida ClientEntity..::..OnEndClose(IAsyncResult).)
Método protegidoOnEndCreateReceiverEjecuta la acción de finalización de creación de receptor.
Método protegidoOnEndGetMessageSessionsEjecuta la acción para finalizar la obtención de mensaje.
Método protegidoOnEndOpen (Se hereda de ClientEntity.)
Método protegidoOnEndRemoveRuleFinaliza la llamada asincrónica a OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Método protegidoOnEndRemoveRulesFinaliza la llamada asincrónica a OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Método protegidoOnFaulted (Se hereda de ClientEntity.)
Método públicoOnMessage(Action<(Of <<'(BrokeredMessage>)>>))Procesa un mensaje en un bombeo de mensajes basados en eventos.
Método públicoOnMessage(Action<(Of <<'(BrokeredMessage>)>>), OnMessageOptions)Procesa un mensaje de un bombeo de mensajes basados en eventos, con el determinado conjunto de opciones OnMessageOptions.
Método públicoOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>))Procesa un mensaje de manera asincrónica.
Método públicoOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>), OnMessageOptions)Procesa un mensaje de manera asincrónica.
Método protegidoOnOpen (Se hereda de ClientEntity.)
Método protegidoOnOpened (Se hereda de ClientEntity.)
Método públicoPeek()()()()Devuelve sin eliminar el primer mensaje de la cola.
Método públicoPeek(Int64)Devuelve sin eliminar el primer mensaje de la cola.
Método públicoPeekAsync()()()()Devuelve de manera asincrónica sin eliminar el primer mensaje de la cola.
Método públicoPeekAsync(Int64)Devuelve de manera asincrónica sin eliminar el primer mensaje de la cola.
Método públicoPeekBatch(Int32)Devuelve sin eliminar los primeros mensajes del lote.
Método públicoPeekBatch(Int64, Int32)Devuelve sin eliminar los primeros mensajes del lote.
Método públicoPeekBatchAsync(Int32)Devuelve de manera asincrónica sin eliminar los primeros mensajes del lote.
Método públicoPeekBatchAsync(Int64, Int32)Devuelve de manera asincrónica sin eliminar los primeros mensajes del lote.
Método públicoReceive()()()()Recibe un mensaje usando InternalReceiver()()()().
Método públicoReceive(Int64)Recibe un mensaje usando InternalReceiver()()()().
Método públicoReceive(TimeSpan)Recibe un mensaje usando InternalReceiver()()()().
Método públicoReceiveAsync()()()()Recibe de manera asincrónica un mensaje usando InternalReceiver()()()().
Método públicoReceiveAsync(Int64)Recibe de manera asincrónica un mensaje usando InternalReceiver()()()().
Método públicoReceiveAsync(TimeSpan)Recibe de manera asincrónica un mensaje usando InternalReceiver()()()().
Método públicoReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Recibe un lote después de la operación asíncrona.
Método públicoReceiveBatch(Int32)Recibe un lote después de la operación asíncrona.
Método públicoReceiveBatch(Int32, TimeSpan)Recibe un lote después de la operación asíncrona.
Método públicoReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Recibe de manera asincrónica un conjunto de mensajes (para el procesamiento por lotes).
Método públicoReceiveBatchAsync(Int32)Recibe de manera asincrónica un conjunto de mensajes (para el procesamiento por lotes).
Método públicoReceiveBatchAsync(Int32, TimeSpan)Recibe de manera asincrónica un conjunto de mensajes (para el procesamiento por lotes).
Método públicoRegisterSessionHandler(Type)Registra el controlador de la sesión del cliente.
Método públicoRegisterSessionHandler(Type, SessionHandlerOptions)Registra el controlador de la sesión del cliente.
Método públicoRegisterSessionHandlerAsync(Type)Registra de forma asincrónica el controlador de la sesión del cliente.
Método públicoRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Registra de forma asincrónica el controlador de la sesión del cliente.
Método públicoRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra el generador de controladores de la sesión del cliente.
Método públicoRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra el generador de controladores de la sesión del cliente.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra de forma asincrónica el generador de controladores de la sesión del cliente.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra de forma asincrónica el generador de controladores de la sesión del cliente.
Método públicoRemoveRuleQuita la regla descrita por ruleName.
Método públicoRemoveRuleAsyncQuita de manera asincrónica la regla descrita por ruleName.
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

This abstract class is not meant to be inherited, so protected members of this class should be ignored.

// Create subscription client
SubscriptionClient mySubscriptionClient = 
factory.CreateSubscriptionClient(topicName, subscriptionName);

// Create a receiver
MessageReceiver myMessageReceiver = mySubscriptionClient.CreateReceiver(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count &lt; MsgCount; count++)
{
    var message = subscriptionClient.Receive();
    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