Abandon(Guid)
|
放弃消息并放弃消息锁的所有权。
(继承自 MessageReceiver)
|
Abandon(Guid, IDictionary<String,Object>)
|
放弃消息并放弃消息锁的所有权。
(继承自 MessageReceiver)
|
AbandonAsync(Guid)
|
异步放弃消息并放弃消息锁所有权。
(继承自 MessageReceiver)
|
AbandonAsync(Guid, IDictionary<String,Object>)
|
异步放弃消息并放弃消息锁所有权。
(继承自 MessageReceiver)
|
Abort()
|
对消息传送实体执行中止功能。
(继承自 ClientEntity)
|
Close()
|
向服务总线发送清理消息,以指示实体的使用完成。
(继承自 ClientEntity)
|
CloseAsync()
|
以异步方式将清理消息发送到服务总线,以指示实体的使用完成。
(继承自 ClientEntity)
|
Complete(Guid)
|
完成对消息的接收操作。
如果使用 AMQP,则只能对此接收方收到的消息执行此操作。
(继承自 MessageReceiver)
|
CompleteAsync(Guid)
|
异步完成对消息的接收操作。
如果使用 AMQP,则只能对此接收方收到的消息执行此操作。
(继承自 MessageReceiver)
|
CompleteBatch(IEnumerable<Guid>)
|
完成对一批消息的接收操作。
如果使用 AMQP,则只能对此接收方收到的消息执行此操作。
(继承自 MessageReceiver)
|
CompleteBatchAsync(IEnumerable<Guid>)
|
异步完成对一批消息的接收操作。
如果使用 AMQP,则只能对此接收方收到的消息执行此操作。
(继承自 MessageReceiver)
|
DeadLetter(Guid)
|
将未传递的消息移动到死信队列。
(继承自 MessageReceiver)
|
DeadLetter(Guid, IDictionary<String,Object>)
|
将未传递的消息移动到死信队列。
(继承自 MessageReceiver)
|
DeadLetter(Guid, String, String)
|
将未传递的消息移动到死信队列。
(继承自 MessageReceiver)
|
DeadLetterAsync(Guid)
|
异步将未传递的消息移动到死信队列。
(继承自 MessageReceiver)
|
DeadLetterAsync(Guid, IDictionary<String,Object>)
|
异步将未传递的消息移动到死信队列。
(继承自 MessageReceiver)
|
DeadLetterAsync(Guid, String, String)
|
异步将未传递的消息移动到死信队列。
(继承自 MessageReceiver)
|
Defer(Guid)
|
指示接收方希望延迟消息的处理。
(继承自 MessageReceiver)
|
Defer(Guid, IDictionary<String,Object>)
|
指示接收方希望延迟消息的处理。
(继承自 MessageReceiver)
|
DeferAsync(Guid)
|
异步延迟消息的处理。
(继承自 MessageReceiver)
|
DeferAsync(Guid, IDictionary<String,Object>)
|
异步延迟消息的处理。
(继承自 MessageReceiver)
|
Fault()
|
仅限内部使用。 请勿从此类继承。
(继承自 ClientEntity)
|
GetProperty<T>()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 MessageReceiver)
|
GetState()
|
获取消息会话的状态。
|
GetStateAsync()
|
异步获取消息会话的状态。
|
OnAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan)
|
放弃速览锁定邮件。
|
OnAbort()
|
中止消息会话。
|
OnBeginAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object)
|
执行开始放弃操作。
|
OnBeginClose(TimeSpan, AsyncCallback, Object)
|
开始异步操作以关闭消息会话的通信对象。
|
OnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object)
|
调用 OnComplete 或 BeginComplete 操作时执行。
|
OnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)
|
调用 OnComplete 或 BeginComplete 操作时执行。
|
OnBeginDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, Boolean, TimeSpan, AsyncCallback, Object)
|
执行开始移动到死信队列操作。
|
OnBeginDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object)
|
执行开始延迟操作。
|
OnBeginGetState(TrackingContext, TimeSpan, AsyncCallback, Object)
|
执行开始获取状态操作。
|
OnBeginOpen(TimeSpan, AsyncCallback, Object)
|
在调用消息接收器的 OnOpen 操作时执行。
|
OnBeginPeek(TrackingContext, Int64, Int32, TimeSpan, AsyncCallback, Object)
|
调用 OnPeek 或 BeginPeek 操作时执行。
|
OnBeginRenewLock(TrackingContext, TimeSpan, AsyncCallback, Object)
|
调用 RenewLock 或 BeginRenewLock 操作时执行。
|
OnBeginRenewMessageLocks(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)
|
调用锁定消息的 OnBegin 操作时执行。
|
OnBeginSetState(TrackingContext, Stream, TimeSpan, AsyncCallback, Object)
|
执行开始设置状态操作。
|
OnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)
|
执行开始尝试接收操作。
|
OnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)
|
执行开始尝试接收操作。
|
OnBeginTryReceive2(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)
|
执行开始尝试接收操作。
|
OnBeginTryReceiveEventData(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)
|
对事件数据调用 OnTryReceive 或 BeginTryReceive 操作时执行。
(继承自 MessageReceiver)
|
OnClose(TimeSpan)
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
OnClosed()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
OnComplete(TrackingContext, IEnumerable<Guid>, TimeSpan)
|
完成速览锁定消息。
|
OnDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, TimeSpan)
|
将消息移动到死信队列。
|
OnDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan)
|
延迟消息。
|
OnEndAbandon(IAsyncResult)
|
结束异步操作以放弃消息并放弃其锁定。
|
OnEndClose(IAsyncResult)
|
结束异步操作以关闭消息会话的通信对象。
|
OnEndComplete(IAsyncResult)
|
执行消息接收器的结束完成操作。
|
OnEndDeadLetter(IAsyncResult)
|
执行消息接收器的结束死信操作。
|
OnEndDefer(IAsyncResult)
|
执行消息接收器的结束延迟操作。
|
OnEndGetState(IAsyncResult)
|
在调用 OnGetState 或 EndGetState 操作时执行。
|
OnEndOpen(IAsyncResult)
|
结束异步操作以打开消息会话的通信对象。
|
OnEndPeek(IAsyncResult)
|
调用 EndPeek 操作时执行。
|
OnEndRenewLock(IAsyncResult)
|
执行消息接收器的 EndRenewLock 操作。
|
OnEndRenewMessageLocks(IAsyncResult)
|
对消息锁执行 EndRenew 操作。
|
OnEndSetState(IAsyncResult)
|
结束异步操作以设置消息会话的状态。
|
OnEndTryReceive(IAsyncResult, IEnumerable<BrokeredMessage>)
|
执行消息接收器的 end try 接收操作。
|
OnEndTryReceive2(IAsyncResult, IEnumerable<BrokeredMessage>)
|
执行消息接收器的 end try 接收操作。
|
OnEndTryReceiveEventData(IAsyncResult, IEnumerable<EventData>)
|
对事件数据执行 EndTryReceive 操作。
(继承自 MessageReceiver)
|
OnFaulted()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
OnGetState(TrackingContext, TimeSpan)
|
执行获取状态操作。
|
OnMessage(Action<BrokeredMessage>, OnMessageOptions)
|
在事件驱动的消息泵中处理消息。
(继承自 MessageReceiver)
|
OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)
|
异步处理事件驱动的消息泵中的消息。
(继承自 MessageReceiver)
|
OnOpen(TimeSpan)
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
OnOpened()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
OnPeek(TrackingContext, Int64, Int32, TimeSpan)
|
调用“速览”操作时执行。
(继承自 MessageReceiver)
|
OnRenewLock(TrackingContext, TimeSpan)
|
对消息锁执行 RenewLock 操作。
|
OnRenewMessageLocks(TrackingContext, IEnumerable<Guid>, TimeSpan)
|
对锁定消息执行“续订”操作。
(继承自 MessageReceiver)
|
OnSetState(TrackingContext, Stream, TimeSpan)
|
执行设置状态操作。
|
OnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>)
|
执行 try receive 操作。
|
OnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>)
|
执行 try receive 操作。
|
Peek()
|
在不更改接收方或消息源的状态的情况下读取下一条消息。
(继承自 MessageReceiver)
|
Peek(Int64)
|
在不更改接收方或消息源的状态的情况下读取下一条消息。
(继承自 MessageReceiver)
|
PeekAsync()
|
在不更改接收方或消息源的状态的情况下异步读取下一条消息。
(继承自 MessageReceiver)
|
PeekAsync(Int64)
|
在不更改接收方或消息源的状态的情况下异步读取下一条消息。
(继承自 MessageReceiver)
|
PeekBatch(Int32)
|
在不更改接收方或消息源的状态的情况下读取下一批消息。
(继承自 MessageReceiver)
|
PeekBatch(Int64, Int32)
|
在不更改接收方或消息源的状态的情况下读取下一批消息。
(继承自 MessageReceiver)
|
PeekBatchAsync(Int32)
|
在不更改接收方或消息源的状态的情况下异步读取下一批消息。
(继承自 MessageReceiver)
|
PeekBatchAsync(Int64, Int32)
|
在不更改接收方或消息源的状态的情况下异步读取下一批消息。
(继承自 MessageReceiver)
|
ProcessException(Exception)
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
|
Receive()
|
BrokeredMessage从当前队列或主题接收 。
(继承自 MessageReceiver)
|
Receive(Int64)
|
接收来自当前队列或主题的延迟消息。 此方法仅适用于延迟消息,不适用于常规消息。
(继承自 MessageReceiver)
|
Receive(TimeSpan)
|
BrokeredMessage从当前队列或主题接收 。
(继承自 MessageReceiver)
|
ReceiveAsync()
|
异步接收来自当前队列或主题的消息。
(继承自 MessageReceiver)
|
ReceiveAsync(Int64)
|
异步接收来自当前队列或主题的延迟消息。 此方法仅适用于延迟消息,不适用于常规消息。
(继承自 MessageReceiver)
|
ReceiveAsync(TimeSpan)
|
异步接收来自当前队列或主题的消息。
(继承自 MessageReceiver)
|
ReceiveBatch(IEnumerable<Int64>)
|
接收一批消息。
(继承自 MessageReceiver)
|
ReceiveBatch(Int32)
|
接收一批消息。
(继承自 MessageReceiver)
|
ReceiveBatch(Int32, TimeSpan)
|
接收一批消息。
(继承自 MessageReceiver)
|
ReceiveBatchAsync(IEnumerable<Int64>)
|
异步接收一批消息。
(继承自 MessageReceiver)
|
ReceiveBatchAsync(Int32)
|
异步接收一批消息。
(继承自 MessageReceiver)
|
ReceiveBatchAsync(Int32, TimeSpan)
|
异步接收一批消息。
(继承自 MessageReceiver)
|
RenewLock()
|
指定主机在消息上续订锁定的时间段。
|
RenewLockAsync()
|
指定主机在消息上续订锁定的时间段。
|
SetState(Stream)
|
设置消息会话的状态。
|
SetStateAsync(Stream)
|
异步设置消息会话的状态。
|
ThrowIfClosed()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
ThrowIfDisposed()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
ThrowIfDisposedOrImmutable()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
ThrowIfDisposedOrNotOpen()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|
ThrowIfFaulted()
|
表示一个消息会话,该会话允许对相关消息进行分组,以便在单个事务中进行处理。
(继承自 ClientEntity)
|