Questa pagina è stata utile?
I suggerimenti relativi al contenuto di questa pagina sono importanti. Comunicaceli.
Altri suggerimenti?
1500 caratteri rimanenti
Esporta (0) Stampa
Espandi tutto

Classe MessageReceiver

Riceve messaggi dal contenitore di messaggi e li accetta.

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

public abstract class MessageReceiver : MessageClientEntity

Nel tipo MessageReceiver sono esposti i membri seguenti.

  NomeDescrizione
Proprietà pubblicaBatchFlushIntervalOttiene l'intervallo di scaricamento dei batch.
Proprietà protettaBatchingEnabledOttiene un valore che indica se è abilitato l'invio in batch.
Proprietà pubblicaIsClosed Ereditato da ClientEntity.
Proprietà pubblicaLastPeekedSequenceNumberOttiene o imposta il numero di sequenza del messaggio visualizzato per ultimo.
Proprietà pubblicaModeOttiene la modalità di ricezione del messaggio.
Proprietà protettaOffsetInclusive
Proprietà pubblicaPathOttiene il percorso della coda o dell'argomento, relativo all'indirizzo di base della classe MessagingFactory.
Proprietà pubblicaPrefetchCountOttiene o imposta il numero di messaggi che possono essere richiesti simultaneamente dal ricevitore del messaggio.
Proprietà protettaReceiverStartTimeOttiene o imposta l'ora di inizio del ricevitore.
Proprietà pubblicaRetryPolicy Ereditato da ClientEntity.
Proprietà protettaStartOffsetOttiene o imposta il punto iniziale dell'offset.
Proprietà protettaSupportsGetRuntimeEntityDescription
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<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<String, Object>)Rimuove in modo asincrono il messaggio e rilascia la proprietà del blocco del messaggio.
Metodo pubblicoAbortEsegue funzionalità di interruzione sull'entità di messaggistica. Ereditato da ClientEntity.
Metodo pubblicoBeginAbandon(Guid, AsyncCallback, Object)Inizia un'operazione asincrona per abbandonare il messaggio e rilasciare il relativo blocco.
Metodo pubblicoBeginAbandon(Guid, IDictionary<String, Object>, AsyncCallback, Object)Inizia un'operazione asincrona per abbandonare il messaggio e rilasciare il relativo blocco.
Metodo pubblicoBeginCloseInizia un'operazione asincrona per chiudere l'entità client del messaggio. Ereditato da MessageClientEntity.
Metodo pubblicoBeginCompleteInizia un'operazione asincrona per completare la ricezione di un messaggio.
Metodo pubblicoBeginCompleteBatchInizia un'operazione asincrona per completare l'invio in batch di un messaggio.
Metodo pubblicoBeginDeadLetter(Guid, AsyncCallback, Object)Inizia un'operazione asincrona per spostare un messaggio nella coda dei messaggi non recapitabili.
Metodo pubblicoBeginDeadLetter(Guid, IDictionary<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 la ricezione di un messaggio.
Metodo pubblicoBeginDefer(Guid, IDictionary<String, Object>, AsyncCallback, Object)Inizia un'operazione asincrona per sospendere la ricezione di un messaggio.
Metodo pubblicoBeginPeek(AsyncCallback, Object)Inizia un'operazione per visualizzare un messaggio.
Metodo pubblicoBeginPeek(Int64, AsyncCallback, Object)Inizia un'operazione per visualizzare un messaggio.
Metodo pubblicoBeginPeekBatch(Int32, AsyncCallback, Object)Inizia un'operazione per visualizzare un batch del messaggio.
Metodo pubblicoBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Inizia un'operazione per visualizzare un batch del messaggio.
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<Int64>, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un batch del messaggio.
Metodo pubblicoBeginReceiveBatch(Int32, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un batch del messaggio.
Metodo pubblicoBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Inizia un'operazione asincrona per ricevere un batch del messaggio.
Metodo pubblicoCloseInvia un messaggio di pulizia al bus di servizio per segnalare il completamento dell'utilizzo di un'entità. Ereditato da ClientEntity.
Metodo pubblicoCloseAsyncInvia un messaggio di pulizia asincrono al bus di servizio per segnalare il completamento dell'utilizzo di un'entità. Ereditato da ClientEntity.
Metodo pubblicoCompleteCompleta l'operazione di ricezione in un messaggio.
Metodo pubblicoCompleteAsyncCompleta in modo asincrono l'operazione di ricezione in un messaggio.
Metodo pubblicoCompleteBatchCompleta l'operazione di ricezione in un batch del messaggio.
Metodo pubblicoCompleteBatchAsyncCompleta in modo asincrono l'operazione di ricezione in un batch del messaggio.
Metodo pubblicoDeadLetter(Guid)Sposta il messaggio non recapitato nella coda dei messaggi non recapitabili.
Metodo pubblicoDeadLetter(Guid, IDictionary<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<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)Indica che il ricevitore desidera differire l'elaborazione del messaggio.
Metodo pubblicoDefer(Guid, IDictionary<String, Object>)Indica che il ricevitore desidera differire l'elaborazione del messaggio.
Metodo pubblicoDeferAsync(Guid)Rinvia in modo asincrono l'elaborazione del messaggio.
Metodo pubblicoDeferAsync(Guid, IDictionary<String, Object>)Rinvia in modo asincrono l'elaborazione del messaggio.
Metodo pubblicoEndAbandonTermina l'operazione asincrona per abbandonare il messaggio e rilasciare il relativo blocco.
Metodo pubblicoEndCloseTermina un'operazione asincrona per chiudere l'entità client del messaggio. Ereditato da MessageClientEntity.
Metodo pubblicoEndCompleteTermina l'operazione asincrona per completare la ricezione di un messaggio.
Metodo pubblicoEndCompleteBatchTermina l'operazione asincrona per completare la ricezione di un batch del messaggio.
Metodo pubblicoEndDeadLetterTermina un'operazione asincrona per spostare il messaggio nella coda dei messaggi non recapitabili.
Metodo pubblicoEndDeferTermina un'operazione asincrona per differire la ricezione di un messaggio.
Metodo pubblicoEndPeekTermina un'operazione asincrona per visualizzare un messaggio.
Metodo pubblicoEndPeekBatchTermina un'operazione asincrona per visualizzare un batch del messaggio.
Metodo pubblicoEndReceiveTermina un'operazione asincrona per ricevere un messaggio.
Metodo pubblicoEndReceiveBatchTermina un'operazione asincrona per ricevere un batch del messaggio.
Metodo pubblicoEquals Ereditato da Object.
Metodo protettoFaultSolo per uso interno. Non eredita da questa classe. Ereditato da ClientEntity.
Metodo protettoFinalize Ereditato da Object.
Metodo pubblicoGetHashCode Ereditato da Object.
Metodo protettoMembro staticoGetLockTokenOttiene il token di blocco associato al messaggio.
Metodo protettoMembro staticoGetLockTokensOttiene la raccolta di token di blocco dalla raccolta di messaggi specificata.
Metodo protettoGetProperty<T>
Metodo pubblicoGetType Ereditato da Object.
Metodo protettoMemberwiseClone Ereditato da Object.
Metodo protettoOnAbandonViene eseguito subito dopo la chiamata dell'operazione Abandon.
Metodo protettoOnAbort Ereditato da ClientEntity.
Metodo protettoOnBeginAbandonViene eseguito subito dopo la chiamata dell'operazione OnAbandon o BeginAbandon.
Metodo protettoOnBeginClose Ereditato da ClientEntity.
Metodo protettoOnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object)Viene eseguito subito dopo la chiamata dell'operazione OnComplete o BeginComplete.
Metodo protettoOnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)Viene eseguito subito dopo la chiamata dell'operazione OnComplete o BeginComplete.
Metodo protettoOnBeginDeadLetterViene eseguito subito dopo la chiamata dell'operazione OnDeadLetter o BeginDeadLetter.
Metodo protettoOnBeginDeferViene eseguito subito dopo la chiamata dell'operazione OnDefer o BeginDefer.
Metodo protettoOnBeginOpen Ereditato da ClientEntity.
Metodo protettoOnBeginPeekViene eseguito subito dopo la chiamata dell'operazione BeginPeek.
Metodo protettoOnBeginRenewMessageLocksViene eseguito subito dopo la chiamata dell'operazione OnBegin per i messaggi di blocco.
Metodo protettoOnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)Viene eseguito subito dopo la chiamata dell'operazione OnTryReceive o BeginTryReceive.
Metodo protettoOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)Viene eseguito subito dopo la chiamata dell'operazione OnTryReceive o BeginTryReceive.
Metodo protettoOnBeginTryReceive2Viene eseguito subito dopo la chiamata dell'operazione OnTryReceive o BeginTryReceive.
Metodo protettoOnBeginTryReceiveEventDataViene eseguito dopo la chiamata dell'operazione OnTryReceive o BeginTryReceive per i dati evento.
Metodo protettoOnClose Ereditato da ClientEntity.
Metodo protettoOnClosed Ereditato da ClientEntity.
Metodo protettoOnCompleteViene eseguito subito dopo la chiamata dell'operazione Complete.
Metodo protettoOnDeadLetterViene eseguito subito dopo la chiamata dell'operazione DeadLetter.
Metodo protettoOnDeferViene eseguito subito dopo la chiamata dell'operazione Defer.
Metodo protettoOnEndAbandonEsegue l'azione finale di abbandono.
Metodo protettoOnEndClose Ereditato da ClientEntity.
Metodo protettoOnEndCompleteEsegue l'azione finale di completamento.
Metodo protettoOnEndDeadLetterEsegue l'azione finale di trasferimento nella coda dei messaggi non recapitabili.
Metodo protettoOnEndDeferEsegue l'azione finale di differimento.
Metodo protettoOnEndOpen Ereditato da ClientEntity.
Metodo protettoOnEndPeekEsegue l'operazione EndPeek.
Metodo protettoOnEndRenewMessageLocksEsegue l'azione EndRenew per i blocchi dei messaggi.
Metodo protettoOnEndTryReceiveEsegue l'azione finale di tentativo di ricezione.
Metodo protettoOnEndTryReceive2Esegue l'azione finale di tentativo di ricezione.
Metodo protettoOnEndTryReceiveEventDataViene eseguita l'azione EndTryReceive per i dati evento.
Metodo protettoOnFaulted Ereditato da ClientEntity.
Metodo pubblicoOnMessageElabora un messaggio in un message pump guidato dagli eventi.
Metodo pubblicoOnMessageAsyncElabora in modo asincrono un messaggio in un message pump guidato dagli eventi.
Metodo protettoOnOpen Ereditato da ClientEntity.
Metodo protettoOnOpened Ereditato da ClientEntity.
Metodo protettoOnPeekViene eseguito subito dopo la chiamata dell'operazione Peek.
Metodo protettoOnRenewMessageLocksEsegue l'azione Renew per i messaggi di blocco.
Metodo protettoOnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>)Viene eseguito subito dopo la chiamata dell'operazione TryReceive.
Metodo protettoOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>)Viene eseguito subito dopo la chiamata dell'operazione TryReceive.
Metodo pubblicoPeek()Legge il messaggio successivo senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeek(Int64)Legge il messaggio successivo senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeekAsync()Legge in modo asincrono il messaggio successivo senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeekAsync(Int64)Legge in modo asincrono il messaggio successivo senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeekBatch(Int32)Legge il batch successivo del messaggio senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeekBatch(Int64, Int32)Legge il batch successivo del messaggio senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeekBatchAsync(Int32)Legge in modo asincrono il batch successivo del messaggio senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoPeekBatchAsync(Int64, Int32)Legge in modo asincrono il batch successivo del messaggio senza modificare lo stato del ricevitore o l'origine del messaggio.
Metodo pubblicoReceive()Riceve un oggetto BrokeredMessage dalla coda o dall'argomento corrente.
Metodo pubblicoReceive(Int64)Riceve un messaggio dalla coda o dall'argomento corrente.
Metodo pubblicoReceive(TimeSpan)Riceve un oggetto BrokeredMessage dalla coda o dall'argomento corrente.
Metodo pubblicoReceiveAsync()Riceve in modo asincrono un messaggio dalla coda o dall'argomento corrente.
Metodo pubblicoReceiveAsync(Int64)Riceve in modo asincrono un messaggio dalla coda o dall'argomento corrente.
Metodo pubblicoReceiveAsync(TimeSpan)Riceve in modo asincrono un messaggio dalla coda o dall'argomento corrente.
Metodo pubblicoReceiveBatch(IEnumerable<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<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 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

Sebbene sia possibile usare la classe QueueClient per inviare e ricevere messaggi senza creare un oggetto MessageReceiver, è possibile usare anche MessageSender e MessageReceiver per creare un mittente e un ricevitore su un'entità. Tenere comunque presente che è possibile solo usare un oggetto MessageReceiver per ricevere messaggi da una coda o sottoscrizione, ma non è possibile ricevere o attendere messaggi da un argomento. Analogamente, è possibile solo usare un oggetto MessageSender per inviare messaggi a una coda o a un argomento, ma non è possibile inviare messaggi a una sottoscrizione. Si noti che la modalità di ricezione dei messaggi predefinita è PeekLock, che assicura una ricezione affidabile.

Quando si crea un oggetto MessageReceiver per una sottoscrizione, il parametro entityPath è nel formato topicPath/subscriptions/subscriptionName.

Nell'esempio seguente viene ricevuto un messaggio dalla coda creata nell'esempio relativo a MessageSender:

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();
}

Qualsiasi membro statico pubblico (Shared in Visual Basic) di questo tipo è thread-safe. Anche i membri di istanza sono garantiti come thread-safe.

Aggiunte alla community

AGGIUNGI
Mostra:
© 2015 Microsoft