Esporta (0) Stampa
Espandi tutto

Classe QueueClient

Rappresenta l'oggetto client di coda.

Spazio dei nomi  Microsoft.ServiceBus.Messaging
Assembly:  Microsoft.ServiceBus (in Microsoft.ServiceBus.dll)

public abstract class QueueClient : MessageClientEntity

Nel tipo QueueClient sono esposti i membri seguenti.

  NomeDescrizione
Proprietà pubblicaIsClosed Ereditato da ClientEntity.
Proprietà pubblicaMessagingFactoryOttiene o imposta la factory di messaggistica.
Proprietà pubblicaModeOttiene la modalità di ricezione del messaggio durante l'elaborazione del messaggio ricevuto.
Proprietà pubblicaPathOttiene o imposta il percorso completo della coda.
Proprietà pubblicaPrefetchCountOttiene o imposta il numero di messaggi che possono essere richiesti simultaneamente dal ricevitore della coda.
Proprietà pubblicaRetryPolicy Ereditato da ClientEntity.
Proprietà protettaThisLock Ereditato da ClientEntity.
In alto

  NomeDescrizione
Metodo pubblicoAbandon(Guid)Rimuove il messaggio e rilascia la proprietà del blocco del messaggio.
Metodo pubblicoAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Rimuove il messaggio e rilascia la proprietà del blocco del messaggio.
Metodo pubblicoAbandonAsync(Guid)Rimuove in modo asincrono il messaggio e rilascia la proprietà del blocco del messaggio.
Metodo pubblicoAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Rimuove in modo asincrono il messaggio e rilascia la proprietà del blocco del messaggio.
Metodo pubblicoAbortPerforms abort functionality on the messaging entity. Ereditato da ClientEntity.
Metodo pubblicoAcceptMessageSession()()()()Accetta una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione.
Metodo pubblicoAcceptMessageSession(String)Accetta una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione utilizzando l'identificatore di sessione specificato.
Metodo pubblicoAcceptMessageSession(TimeSpan)Accetta una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione utilizzando il tempo di attesa del server specificato.
Metodo pubblicoAcceptMessageSession(String, TimeSpan)Accetta una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione utilizzando l'identificatore di sessione e il tempo di attesa specificati.
Metodo pubblicoAcceptMessageSessionAsync()()()()Accetta in modo asincrono una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione.
Metodo pubblicoAcceptMessageSessionAsync(String)Accetta in modo asincrono una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione utilizzando l'identificatore di sessione specificato.
Metodo pubblicoAcceptMessageSessionAsync(TimeSpan)Accetta in modo asincrono una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione utilizzando il tempo di attesa del server specificato.
Metodo pubblicoAcceptMessageSessionAsync(String, TimeSpan)Accetta in modo asincrono una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione utilizzando l'identificatore di sessione e il tempo di attesa specificati.
Metodo pubblicoBeginAbandon(Guid, AsyncCallback, Object)Inizia un'operazione asincrona per abbandonare il messaggio e rilasciare il relativo blocco.
Metodo pubblicoBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Inizia un'operazione asincrona per abbandonare il messaggio e rilasciare il relativo blocco.
Metodo pubblicoBeginAcceptMessageSession(AsyncCallback, Object)Inizia un'operazione asincrona per accettare una sessione di messaggistica.
Metodo pubblicoBeginAcceptMessageSession(String, AsyncCallback, Object)Inizia un'operazione asincrona per accettare una sessione di messaggistica.
Metodo pubblicoBeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)Inizia un'operazione asincrona per accettare una sessione di messaggistica.
Metodo pubblicoBeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)Inizia un'operazione asincrona per accettare una sessione di messaggistica.
Metodo pubblicoBeginCloseInizia un'operazione asincrona per chiudere l'entità client del messaggio. Ereditato da MessageClientEntity.
Metodo pubblicoBeginCompleteInizia un'operazione asincrona per completare l'elaborazione di un messaggio.
Metodo pubblicoBeginCompleteBatchInizia un'operazione asincrona per completare l'elaborazione di un batch di messaggi.
Metodo pubblicoBeginDeadLetter(Guid, AsyncCallback, Object)Inizia un'operazione asincrona per spostare un messaggio nella coda dei messaggi non recapitabili.
Metodo pubblicoBeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Inizia un'operazione asincrona per spostare un messaggio nella coda dei messaggi non recapitabili.
Metodo pubblicoBeginDeadLetter(Guid, String, String, AsyncCallback, Object)Inizia un'operazione asincrona per spostare un messaggio nella coda dei messaggi non recapitabili.
Metodo pubblicoBeginDefer(Guid, AsyncCallback, Object)Inizia un'operazione asincrona per sospendere l'elaborazione di un messaggio.
Metodo pubblicoBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Inizia un'operazione asincrona per sospendere l'elaborazione di un messaggio.
Metodo pubblicoBeginGetMessageSessions(AsyncCallback, Object)Inizia un'operazione asincrona per ottenere le sessioni di messaggistica.
Metodo pubblicoBeginGetMessageSessions(DateTime, AsyncCallback, Object)Inizia un'operazione asincrona per ottenere le sessioni di messaggistica.
Metodo pubblicoBeginPeek(AsyncCallback, Object)Inizia un'operazione asincrona per visualizzare un messaggio.
Metodo pubblicoBeginPeek(Int64, AsyncCallback, Object)Inizia un'operazione asincrona per visualizzare un messaggio.
Metodo pubblicoBeginPeekBatch(Int32, AsyncCallback, Object)Inizia un'operazione asincrona per visualizzare un batch di messaggi.
Metodo pubblicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Inizia un'operazione asincrona per visualizzare un batch di messaggi.
Metodo pubblicoBeginReceive(AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un messaggio.
Metodo pubblicoBeginReceive(Int64, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un messaggio.
Metodo pubblicoBeginReceive(TimeSpan, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un messaggio.
Metodo pubblicoBeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un batch di messaggi.
Metodo pubblicoBeginReceiveBatch(Int32, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un batch di messaggi.
Metodo pubblicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un batch di messaggi.
Metodo pubblicoBeginSendInizia un'operazione asincrona per inviare un messaggio.
Metodo pubblicoBeginSendBatchInizia un'operazione asincrona per inviare un batch di messaggi.
Metodo pubblicoCloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. Ereditato da ClientEntity.
Metodo pubblicoCloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. Ereditato da ClientEntity.
Metodo pubblicoCompleteCompleta l'elaborazione di un messaggio.
Metodo pubblicoCompleteAsyncCompleta in modo asincrono l'elaborazione di un messaggio.
Metodo pubblicoCompleteBatchCompleta l'elaborazione di un batch di messaggi.
Metodo pubblicoCompleteBatchAsyncCompleta in modo asincrono l'elaborazione di un batch di messaggi.
Metodo pubblicoMembro staticoCreate(String)Crea una nuova copia di QueueClient con il percorso specificato.
Metodo pubblicoMembro staticoCreate(String, ReceiveMode)Crea una nuova copia di QueueClient con il percorso e la modalità specificati.
Metodo pubblicoMembro staticoCreateFromConnectionString(String, String)Crea una nuova copia di QueueClient a partire da una stringa di connessione con il percorso specificato.
Metodo pubblicoMembro staticoCreateFromConnectionString(String, String, ReceiveMode)Crea una nuova copia di QueueClient a partire da una stringa di connessione con il percorso e la modalità specificati.
Metodo pubblicoDeadLetter(Guid)Sposta il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))Sposta il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDeadLetter(Guid, String, String)Sposta il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDeadLetterAsync(Guid)Sposta in modo asincrono il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Sposta in modo asincrono il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDeadLetterAsync(Guid, String, String)Sposta in modo asincrono il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDefer(Guid)Sospende l'elaborazione di un messaggio.
Metodo pubblicoDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Sospende l'elaborazione di un messaggio.
Metodo pubblicoDeferAsync(Guid)Sospende in modo asincrono l'elaborazione di un messaggio.
Metodo pubblicoDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Sospende in modo asincrono l'elaborazione di un messaggio.
Metodo pubblicoEndAbandonTermina un'operazione asincrona per abbandonare il messaggio e rilasciare il relativo blocco.
Metodo pubblicoEndAcceptMessageSessionTermina un'operazione asincrona per accettare una sessione di messaggistica che consente il raggruppamento di messaggi correlati da elaborare in un'unica transazione.
Metodo pubblicoEndCloseTermina un'operazione asincrona per chiudere l'entità client del messaggio. Ereditato da MessageClientEntity.
Metodo pubblicoEndCompleteTermina un'operazione asincrona per completare l'elaborazione di un messaggio.
Metodo pubblicoEndCompleteBatchTermina un'operazione asincrona per completare l'elaborazione di un batch di messaggi.
Metodo pubblicoEndDeadLetterTermina un'operazione asincrona per spostare il messaggio nella coda dei messaggi non recapitabili.
Metodo pubblicoEndDeferTermina un'operazione asincrona per sospendere l'elaborazione di un messaggio.
Metodo pubblicoEndGetMessageSessionsTermina un'operazione asincrona per ottenere le sessioni di messaggistica.
Metodo pubblicoEndPeekTermina un'operazione asincrona per visualizzare un messaggio.
Metodo pubblicoEndPeekBatchTermina un'operazione asincrona per visualizzare un batch di messaggi.
Metodo pubblicoEndReceiveTermina un'operazione asincrona per ricevere un messaggio.
Metodo pubblicoEndReceiveBatchTermina un'operazione asincrona per ricevere un batch di messaggi.
Metodo pubblicoEndSendTermina un'operazione asincrona per inviare un messaggio.
Metodo pubblicoEndSendBatchTermina un'operazione asincrona per inviare un batch di messaggi.
Metodo pubblicoEquals Ereditato da Object.
Metodo protettoFaultFor internal use only. Do not inherit from this class. Ereditato da ClientEntity.
Metodo protettoFinalize Ereditato da Object.
Metodo pubblicoMembro staticoFormatDeadLetterPathCrea un nome di formato dal percorso della coda dei messaggi non recapitabili specificato.
Metodo pubblicoGetHashCode Ereditato da Object.
Metodo pubblicoGetMessageSessions()()()()Ottiene le sessioni di messaggistica, consentendo di esplorare le sessioni nelle code.
Metodo pubblicoGetMessageSessions(DateTime)Recupera tutte le sessioni di messaggistica il cui stato è stato aggiornato a partire dal valore di lastUpdatedTime.
Metodo pubblicoGetMessageSessionsAsync()()()()Ottiene in modo asincrono le sessioni di messaggistica, consentendo di esplorare le sessioni nelle code.
Metodo pubblicoGetMessageSessionsAsync(DateTime)Recupera in modo asincrono tutte le sessioni di messaggistica il cui stato è stato aggiornato a partire dal valore di lastUpdatedTime.
Metodo pubblicoGetType Ereditato da Object.
Metodo protettoMemberwiseClone Ereditato da Object.
Metodo protettoOnAbortViene eseguito subito dopo la chiamata dell'evento Abort. Esegue l'override di ClientEntity..::..OnAbort()()()().
Metodo protettoOnBeginAcceptMessageSessionViene eseguito subito dopo la chiamata dell'operazione BeginAcceptMessageSession.
Metodo protettoOnBeginCloseViene eseguito nel momento in cui viene chiamata l'operazione Close. Esegue l'override di ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object).
Metodo protettoOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)Esegue l'azione iniziale di creazione del ricevitore.
Metodo protettoOnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)Esegue l'azione iniziale di creazione del ricevitore.
Metodo protettoOnBeginCreateSenderEsegue l'azione iniziale di creazione del mittente.
Metodo protettoOnBeginGetMessageSessionsEsegue l'azione BeginGetMessageSessions.
Metodo protettoOnBeginOpen Ereditato da ClientEntity.
Metodo protettoOnCloseViene eseguito subito dopo la chiamata dell'azione Close. Esegue l'override di ClientEntity..::..OnClose(TimeSpan).
Metodo protettoOnClosed Ereditato da ClientEntity.
Metodo protettoOnEndAcceptMessageSessionViene eseguito subito dopo la chiamata dell'operazione EndAcceptMessageSession.
Metodo protettoOnEndCloseEsegue l'azione finale di chiusura. Esegue l'override di ClientEntity..::..OnEndClose(IAsyncResult).
Metodo protettoOnEndCreateReceiverEsegue l'azione finale di creazione del ricevitore.
Metodo protettoOnEndCreateSenderEsegue l'azione finale di creazione del mittente.
Metodo protettoOnEndGetMessageSessionsEsegue l'azione finale di acquisizione del messaggio.
Metodo protettoOnEndOpen Ereditato da ClientEntity.
Metodo protettoOnFaulted Ereditato da ClientEntity.
Metodo pubblicoOnMessage(Action<(Of <<'(BrokeredMessage>)>>))Elabora un messaggio in un message pump guidato dagli eventi.
Metodo pubblicoOnMessage(Action<(Of <<'(BrokeredMessage>)>>), OnMessageOptions)Elabora un messaggio in un message pump guidato dagli eventi con il set di opzioni OnMessageOptions specificato.
Metodo pubblicoOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>))Elabora in modo asincrono un messaggio.
Metodo pubblicoOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>), OnMessageOptions)Elabora in modo asincrono un messaggio.
Metodo protettoOnOpen Ereditato da ClientEntity.
Metodo protettoOnOpened Ereditato da ClientEntity.
Metodo pubblicoPeek()()()()Restituisce il primo messaggio presente nella coda senza rimuoverlo.
Metodo pubblicoPeek(Int64)Restituisce il primo messaggio presente nella coda senza rimuoverlo.
Metodo pubblicoPeekAsync()()()()Restituisce in modo asincrono il primo messaggio presente nella coda senza rimuoverlo.
Metodo pubblicoPeekAsync(Int64)Restituisce in modo asincrono il primo messaggio presente nella coda senza rimuoverlo.
Metodo pubblicoPeekBatch(Int32)Visualizza un batch del messaggio.
Metodo pubblicoPeekBatch(Int64, Int32)Visualizza un batch di messaggi.
Metodo pubblicoPeekBatchAsync(Int32)Visualizza in modo asincrono un batch del messaggio.
Metodo pubblicoPeekBatchAsync(Int64, Int32)Visualizza in modo asincrono un batch del messaggio.
Metodo pubblicoReceive()()()()Riceve un messaggio utilizzando la proprietà InternalReceiver()()()().
Metodo pubblicoReceive(Int64)Riceve un messaggio utilizzando la proprietà InternalReceiver()()()().
Metodo pubblicoReceive(TimeSpan)Riceve un messaggio utilizzando la proprietà InternalReceiver()()()().
Metodo pubblicoReceiveAsync()()()()Riceve in modo asincrono un messaggio utilizzando la proprietà InternalReceiver()()()().
Metodo pubblicoReceiveAsync(Int64)Riceve in modo asincrono un messaggio utilizzando la proprietà InternalReceiver()()()().
Metodo pubblicoReceiveAsync(TimeSpan)Riceve in modo asincrono un messaggio utilizzando la proprietà InternalReceiver()()()().
Metodo pubblicoReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Riceve un batch di messaggi.
Metodo pubblicoReceiveBatch(Int32)Riceve un batch di messaggi.
Metodo pubblicoReceiveBatch(Int32, TimeSpan)Riceve un batch di messaggi.
Metodo pubblicoReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Riceve in modo asincrono un batch di messaggi.
Metodo pubblicoReceiveBatchAsync(Int32)Riceve in modo asincrono un batch di messaggi.
Metodo pubblicoReceiveBatchAsync(Int32, TimeSpan)Riceve in modo asincrono un batch di messaggi.
Metodo pubblicoRegisterSessionHandler(Type)Registra il gestore della sessione del tipo specificato.
Metodo pubblicoRegisterSessionHandler(Type, SessionHandlerOptions)Registra il gestore della sessione del tipo specificato e le opzioni relative al gestore.
Metodo pubblicoRegisterSessionHandlerAsync(Type)Registra in modo asincrono il gestore della sessione del tipo specificato.
Metodo pubblicoRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Registra in modo asincrono il gestore della sessione del tipo specificato e le opzioni relative al gestore.
Metodo pubblicoRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra una factory del gestore della sessione di messaggistica con le opzioni specificate.
Metodo pubblicoRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra una factory del gestore della sessione di messaggistica con le opzioni specificate.
Metodo pubblicoRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Registra in modo asincrono una factory del gestore della sessione di messaggistica.
Metodo pubblicoRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Registra in modo asincrono una factory del gestore della sessione di messaggistica.
Metodo pubblicoSendInvia un messaggio utilizzando la proprietà InternalSender()()()().
Metodo pubblicoSendAsyncInvia in modo asincrono un messaggio utilizzando la proprietà InternalSender()()()().
Metodo pubblicoSendBatchInvia un set di messaggi negoziati (per l'elaborazione batch).
Metodo pubblicoSendBatchAsyncInvia in modo asincrono un set di messaggi negoziati (per l'elaborazione batch).
Metodo protettoThrowIfClosed Ereditato da ClientEntity.
Metodo protettoThrowIfDisposed Ereditato da ClientEntity.
Metodo protettoThrowIfDisposedOrImmutable Ereditato da ClientEntity.
Metodo protettoThrowIfDisposedOrNotOpen Ereditato da ClientEntity.
Metodo protettoThrowIfFaulted Ereditato da ClientEntity.
Metodo pubblicoToString Ereditato da Object.
In alto

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.

Aggiunte alla community

AGGIUNGI
Mostra:
© 2014 Microsoft