Exportar (0) Imprimir
Expandir todo

Clase QueueClient

Representa el objeto del cliente de cola.

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

public abstract class QueueClient : MessageClientEntity

El tipo QueueClient expone los siguientes miembros.

  NombreDescripción
Propiedad públicaIsClosed (Se hereda de ClientEntity.)
Propiedad públicaMessagingFactoryObtiene o establece la fábrica de mensajes.
Propiedad públicaModeObtiene el modo de recepción de mensajes al procesar el mensaje recibido.
Propiedad públicaPathObtiene o establece el nombre de ruta completo de la cola.
Propiedad públicaPrefetchCountObtiene o establece el número de mensajes que el receptor de la cola puede solicitar simultáneamente.
Propiedad públicaRetryPolicy (Se hereda de ClientEntity.)
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ú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.
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 identificador de sesión determinado.
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 identificador de sesión determinado y el tiempo de espera.
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ú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 lote de mensajes.
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 sesiones de mensajes.
Método públicoBeginGetMessageSessions(DateTime, AsyncCallback, Object)Comienza una operación asincrónica para obtener sesiones de mensajes.
Método públicoBeginPeek(AsyncCallback, Object)Comienza una operación asincrónica para inspeccionar un mensaje.
Método públicoBeginPeek(Int64, AsyncCallback, Object)Comienza una operación asincrónica para inspeccionar un mensaje.
Método públicoBeginPeekBatch(Int32, AsyncCallback, Object)Empieza una operación asincrónica para inspeccionar un lote de mensajes.
Método públicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Empieza una operación asincrónica para inspeccionar un lote de 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úblicoBeginSendComienza una operación asincrónica para enviar un mensaje.
Método públicoBeginSendBatchComienza una operación asincrónica para enviar 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 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 de mensajes.
Método públicoCompleteBatchAsyncCompleta el procesamiento de un lote de mensajes de manera asincrónica.
Método públicoMiembro estáticoCreate(String)Crea una nueva copia de QueueClient con ruta de acceso especificada.
Método públicoMiembro estáticoCreate(String, ReceiveMode)Crea una nueva copia de QueueClient con ruta de acceso y modo especificados.
Método públicoMiembro estáticoCreateFromConnectionString(String, String)Crea una nueva copia de QueueClient desde una cadena de conexión con ruta de acceso especificada.
Método públicoMiembro estáticoCreateFromConnectionString(String, String, ReceiveMode)Crea una nueva copia de QueueClient desde una cadena de conexión con ruta de acceso y 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ú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 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 suspender el procesamiento de un mensaje.
Método públicoEndGetMessageSessionsFinaliza una operación asincrónica para obtener sesiones de mensajes.
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úblicoEndSendFinaliza una operación asincrónica para enviar un mensaje.
Método públicoEndSendBatchFinaliza una operación asincrónica para enviar 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úblicoMiembro estáticoFormatDeadLetterPathCrea un nombre de formato desde la ruta de cola de mensajes fallidos especificada.
Método públicoGetHashCode (Se hereda de Object.)
Método públicoGetMessageSessions()()()()Obtiene las sesiones de mensajes, lo que permite explorar sesiones en las colas.
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 las sesiones de mensajes, lo que permite explorar sesiones en las colas.
Método públicoGetMessageSessionsAsync(DateTime)Recupera de manera asincrónica todas las sesiones de mensajes cuyo estado de sesión se ha actualizado desde lastUpdatedTime.
Método públicoGetType (Se hereda de Object.)
Método protegidoMemberwiseClone (Se hereda de Object.)
Método protegidoOnAbortSe ejecuta al llamar al evento Abort. (Invalida ClientEntity..::..OnAbort()()()().)
Método protegidoOnBeginAcceptMessageSessionSe ejecuta al llamar a la operación BeginAcceptMessageSession.
Método protegidoOnBeginCloseSe ejecuta al llamar a la operación Close. (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, ReceiveMode, TimeSpan, AsyncCallback, Object)Ejecuta la acción para iniciar la creación de receptor.
Método protegidoOnBeginCreateSenderEjecuta la acción de inicio de creación del emisor.
Método protegidoOnBeginGetMessageSessionsEjecuta la acción BeginGetMessageSessions.
Método protegidoOnBeginOpen (Se hereda de ClientEntity.)
Método protegidoOnCloseSe ejecuta al llamar a la acción Close. (Invalida ClientEntity..::..OnClose(TimeSpan).)
Método protegidoOnClosed (Se hereda de ClientEntity.)
Método protegidoOnEndAcceptMessageSessionSe ejecuta al llamar a la operación EndAcceptMessageSession.
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 protegidoOnEndCreateSenderEjecuta la acción de finalización de creación de emisor.
Método protegidoOnEndGetMessageSessionsEjecuta la acción para finalizar la obtención de mensaje.
Método protegidoOnEndOpen (Se hereda de ClientEntity.)
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)Inspecciona un lote de mensajes.
Método públicoPeekBatch(Int64, Int32)Inspecciona un lote de mensajes.
Método públicoPeekBatchAsync(Int32)Inspecciona un lote de mensajes de manera asincrónica.
Método públicoPeekBatchAsync(Int64, Int32)Inspecciona un lote de mensajes de manera asincrónica.
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 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 un lote de mensajes de manera asincrónica.
Método públicoReceiveBatchAsync(Int32)Recibe un lote de mensajes de manera asincrónica.
Método públicoReceiveBatchAsync(Int32, TimeSpan)Recibe un lote de mensajes de manera asincrónica.
Método públicoRegisterSessionHandler(Type)Registra el controlador de sesiones con el tipo específico.
Método públicoRegisterSessionHandler(Type, SessionHandlerOptions)Registra el controlador de sesiones con el tipo específico y las opciones de controlador.
Método públicoRegisterSessionHandlerAsync(Type)Registra el controlador de sesiones con el tipo específico de forma asíncrona.
Método públicoRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Registra de forma asincrónica el controlador de sesiones con el tipo específico y las opciones de controlador.
Método públicoRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra un generador de controladores de la sesión de mensajes con opciones especificadas.
Método públicoRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra un generador de controladores de la sesión de mensajes con opciones especificadas.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra de forma asincrónica un generador de controladores de la sesión de mensajes.
Método públicoRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra de forma asincrónica un generador de controladores de la sesión de mensajes.
Método públicoSendRecibe un mensaje usando InternalSender()()()().
Método públicoSendAsyncEnvía de manera asincrónica un mensaje usando InternalSender()()()().
Método públicoSendBatchEnvía un conjunto de mensajes indirectos (para el procesamiento por lotes).
Método públicoSendBatchAsyncEnvía de manera asincrónica un conjunto de mensajes indirectos (para el procesamiento por lotes).
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 class is mainly used for Service Bus run-time operations, such as sending and receiving messages.

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

// Create the MessagingFactory
     MessagingFactory factory = 
     MessagingFactory.Create(myServiceBusNamespaceUri, SharedSecretTokenProvider.CreateSharedSecretTokenProvider(issuerName, issuerKey));
    
     //********************************************************************************
     //                          Sending messages to a Queue
     //********************************************************************************
    
     // Create queue client
     QueueClient myQueueClient = factory.CreateQueueClient("myQueue");
    
     // Send messages
     List <object>; Issues = new List <object>();
     foreach (var issue in Issues)
     {
        myQueueClient.Send(new BrokeredMessage(issue));
     }
    
     // ... Recieve messages
     for (int count = 0; count < MsgCount; count++)
     {
         var message = myQueueClient.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