MessageSession クラス

定義

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

public abstract class MessageSession : Microsoft.ServiceBus.Messaging.MessageReceiver
type MessageSession = class
    inherit MessageReceiver
Public MustInherit Class MessageSession
Inherits MessageReceiver
継承

プロパティ

BatchFlushInterval

バッチ フラッシュ間隔を取得します。

(継承元 MessageReceiver)
BatchingEnabled

バッチ処理が有効かどうかを示す値を取得します。

(継承元 MessageReceiver)
IsClosed

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
IsExclusiveMode

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

LastPeekedSequenceNumber

セッションで最後にピークされたシーケンス番号を取得または設定します。

LockedUntilUtc

メッセージ セッションのロックを解除する日時を取得または設定します。

LockToken

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

Mode

メッセージ受信モードを取得します。

(継承元 MessageReceiver)
Path

ベース アドレスに対するキュー、トピック、またはサブスクリプションのパスを MessagingFactory 取得します。

(継承元 MessagingEntityClient)
PrefetchCount

メッセージの受信者が同時に要求できるメッセージ数を取得または設定します。

RefreshEntityRuntimeDescription

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 MessageReceiver)
RetryPolicy

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
SessionId

メッセージ セッション識別子を取得または設定します。

SupportsGetRuntimeEntityDescription

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

ThisLock

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)

メソッド

Abandon(Guid)

メッセージを破棄し、メッセージ ロックの所有権を放棄します。

(継承元 MessageReceiver)
Abandon(Guid, IDictionary<String,Object>)

メッセージを破棄し、メッセージ ロックの所有権を放棄します。

(継承元 MessageReceiver)
AbandonAsync(Guid)

メッセージを非同期的に破棄し、メッセージ ロックの所有権を放棄します。

(継承元 MessageReceiver)
AbandonAsync(Guid, IDictionary<String,Object>)

メッセージを非同期的に破棄し、メッセージ ロックの所有権を放棄します。

(継承元 MessageReceiver)
Abort()

メッセージング エンティティに対して中止機能を実行します。

(継承元 ClientEntity)
Close()

エンティティの使用の完了を通知するクリーンアップ メッセージを Service Bus に送信します。

(継承元 ClientEntity)
CloseAsync()

クリーンアップ メッセージを Service Bus に非同期的に送信して、エンティティの使用の完了を通知します。

(継承元 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>()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 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)

begin try receive アクションを実行します。

OnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)

begin try receive アクションを実行します。

OnBeginTryReceive2(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)

begin try receive アクションを実行します。

OnBeginTryReceiveEventData(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)

イベント データに対して OnTryReceive または BeginTryReceive 操作を呼び出すと実行されます。

(継承元 MessageReceiver)
OnClose(TimeSpan)

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
OnClosed()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 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>)

メッセージ レシーバーの終了 try 受信操作を実行します。

OnEndTryReceive2(IAsyncResult, IEnumerable<BrokeredMessage>)

メッセージ レシーバーの終了 try 受信操作を実行します。

OnEndTryReceiveEventData(IAsyncResult, IEnumerable<EventData>)

イベント データの EndTryReceive アクションを実行します。

(継承元 MessageReceiver)
OnFaulted()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
OnGetState(TrackingContext, TimeSpan)

状態の取得アクションを実行します。

OnMessage(Action<BrokeredMessage>, OnMessageOptions)

イベント ドリブン メッセージ ポンプでメッセージを処理します。

(継承元 MessageReceiver)
OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)

イベント ドリブン メッセージ ポンプでメッセージを非同期的に処理します。

(継承元 MessageReceiver)
OnOpen(TimeSpan)

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
OnOpened()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
OnPeek(TrackingContext, Int64, Int32, TimeSpan)

Peek 操作の呼び出し時に実行されます。

(継承元 MessageReceiver)
OnRenewLock(TrackingContext, TimeSpan)

メッセージ ロックに対して RenewLock アクションを実行します。

OnRenewMessageLocks(TrackingContext, IEnumerable<Guid>, TimeSpan)

ロック メッセージの [更新] アクションを実行します。

(継承元 MessageReceiver)
OnSetState(TrackingContext, Stream, TimeSpan)

set state アクションを実行します。

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)

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

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

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
ThrowIfDisposed()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
ThrowIfDisposedOrImmutable()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
ThrowIfDisposedOrNotOpen()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)
ThrowIfFaulted()

1 つのトランザクションで処理するための関連メッセージのグループ化を許可するメッセージ セッションを表します。

(継承元 ClientEntity)

適用対象