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à 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à protettaReceiverStartTime
Proprietà pubblicaRetryPolicy Ereditato da ClientEntity.
Proprietà protettaStartOffset
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 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 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<(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 la ricezione di un messaggio.
Metodo pubblicoBeginDefer(Guid, IDictionary<(Of <<'(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<(Of <<'(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 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'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<(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)Indica che il ricevitore desidera differire l'elaborazione del messaggio.
Metodo pubblicoDefer(Guid, IDictionary<(Of <<'(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<(Of <<'(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 protettoFaultFor internal use only. Do not inherit from this class. 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 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<(Of <<'(ArraySegment<(Of <<'(Byte>)>>)>)>>), Boolean, TimeSpan, AsyncCallback, Object)
Metodo protettoOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(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<(Of <<'(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 protettoOnBeginTryReceiveEventData
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 protettoOnEndTryReceiveEventData
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<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Viene eseguito subito dopo la chiamata dell'operazione TryReceive.
Metodo protettoOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(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<(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 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

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.

Aggiunte alla community

Mostra:
© 2015 Microsoft