MsmqIntegrationBinding クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
MsmqIntegrationBinding クラスは、Microsoft Message Queuing (MSMQ) メッセージを Windows Communication Foundation (WCF) メッセージにマッピングします。
public ref class MsmqIntegrationBinding : System::ServiceModel::MsmqBindingBase
public class MsmqIntegrationBinding : System.ServiceModel.MsmqBindingBase
type MsmqIntegrationBinding = class
inherit MsmqBindingBase
Public Class MsmqIntegrationBinding
Inherits MsmqBindingBase
- 継承
例
次の構成ファイルのスニペットは、クライアントで MsmqIntegrationBinding バインディングを構成する方法を示しています。
次の構成ファイルのスニペットは、サービスで MsmqIntegrationBinding バインディングを構成する方法を示しています。
[ServiceContract(Namespace = "http://Microsoft.ServiceModel.Samples")]
[ServiceKnownType(typeof(PurchaseOrder))]
public interface IOrderProcessor
{
[OperationContract(IsOneWay = true, Action = "*")]
void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg);
}
<ServiceContract(Namespace:="http:'Microsoft.ServiceModel.Samples")> _
<ServiceKnownType(GetType(PurchaseOrder))> _
Public Interface IOrderProcessor
<OperationContract(IsOneWay:=True, Action:="*")> _
Sub SubmitPurchaseOrder(ByVal msg As MsmqMessage(Of PurchaseOrder))
End Interface
次のコードは、サービスのプログラムで MsmqIntegrationBinding バインディングを使用する方法を示しています。
public class OrderProcessorService : IOrderProcessor
{
[OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
public void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> ordermsg)
{
PurchaseOrder po = (PurchaseOrder)ordermsg.Body;
Random statusIndexer = new Random();
po.Status = (OrderStates)statusIndexer.Next(3);
Console.WriteLine("Processing {0} ", po);
}
// Host the service within this EXE console application.
public static void Main()
{
// Get base address from appsettings in configuration.
Uri baseAddress = new Uri(ConfigurationManager.AppSettings["baseAddress"]);
// Create a ServiceHost for the CalculatorService type and provide the base address.
using (ServiceHost serviceHost = new ServiceHost(typeof(IOrderProcessor), baseAddress))
{
// Open the ServiceHostBase to create listeners and start listening for messages.
serviceHost.Open();
// The service can now be accessed.
Console.WriteLine("The service is ready.");
Console.WriteLine("The service is running in the following account: {0}", WindowsIdentity.GetCurrent().Name);
Console.WriteLine("Press <ENTER> to terminate service.");
Console.WriteLine();
Console.ReadLine();
// Close the ServiceHostBase to shutdown the service.
serviceHost.Close();
}
}
}
Public Class OrderProcessorService
Implements IOrderProcessor
<OperationBehavior(TransactionScopeRequired:=True, TransactionAutoComplete:=True)> _
Public Sub SubmitPurchaseOrder(ByVal ordermsg As MsmqMessage(Of PurchaseOrder)) Implements IOrderProcessor.SubmitPurchaseOrder
Dim po As PurchaseOrder = ordermsg.Body
Dim statusIndexer As New Random()
po.Status = statusIndexer.Next(3)
Console.WriteLine("Processing {0} ", po)
End Sub
End Class
次のコードは、クライアントのプログラムで MsmqIntegrationBinding バインディングを使用する方法を示しています。
MsmqIntegrationBinding binding = new MsmqIntegrationBinding();
EndpointAddress address = new EndpointAddress("msmq.formatname:DIRECT=OS:.\\private$\\Orders");
ChannelFactory<IOrderProcessor> channelFactory = new ChannelFactory<IOrderProcessor>(binding, address);
IOrderProcessor channel = channelFactory.CreateChannel();
PurchaseOrder po = new PurchaseOrder();
po.customerId = "somecustomer.com";
po.poNumber = Guid.NewGuid().ToString();
PurchaseOrderLineItem lineItem1 = new PurchaseOrderLineItem();
lineItem1.productId = "Blue Widget";
lineItem1.quantity = 54;
lineItem1.unitCost = 29.99F;
PurchaseOrderLineItem lineItem2 = new PurchaseOrderLineItem();
lineItem2.productId = "Red Widget";
lineItem2.quantity = 890;
lineItem2.unitCost = 45.89F;
po.orderLineItems = new PurchaseOrderLineItem[2];
po.orderLineItems[0] = lineItem1;
po.orderLineItems[1] = lineItem2;
MsmqMessage<PurchaseOrder> ordermsg = new MsmqMessage<PurchaseOrder>(po);
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
{
channel.SubmitPurchaseOrder(ordermsg);
scope.Complete();
}
Console.WriteLine("Order has been submitted:{0}", po);
Dim binding As New MsmqIntegrationBinding()
Dim address As New EndpointAddress("msmq.formatname:DIRECT=OS:.\\private$\\Orders")
Dim channelFactory As New ChannelFactory(Of IOrderProcessor)(binding, address)
Dim channel As IOrderProcessor = channelFactory.CreateChannel()
Dim po As New PurchaseOrder()
po.customerId = "somecustomer.com"
po.poNumber = Guid.NewGuid().ToString()
Dim lineItem1 As New PurchaseOrderLineItem()
lineItem1.productId = "Blue Widget"
lineItem1.quantity = 54
lineItem1.unitCost = 29.99F
Dim lineItem2 = New PurchaseOrderLineItem()
lineItem2.productId = "Red Widget"
lineItem2.quantity = 890
lineItem2.unitCost = 45.89F
Dim lineItems(1) As PurchaseOrderLineItem
lineItems(0) = lineItem1
lineItems(1) = lineItem2
po.orderLineItems = lineItems
Dim ordermsg As MsmqMessage(Of PurchaseOrder) = New MsmqMessage(Of PurchaseOrder)(po)
Using scope As New TransactionScope(TransactionScopeOption.Required)
channel.SubmitPurchaseOrder(ordermsg)
scope.Complete()
End Using
Console.WriteLine("Order has been submitted:{0}", po)
注釈
重要
このクラスのメソッドを信頼されていないデータを指定して呼び出すことには、セキュリティ上のリスクが伴います。 このクラスのメソッドの呼び出しは、信頼されたデータだけを指定して実行してください。 詳細については、「 すべての入力の検証」を参照してください。
このバインディングを使用すると、WCF アプリケーションは、COM、ネイティブ C++ API、または名前空間で定義されている型を使用する既存の MSMQ アプリケーションとの間で System.Messaging メッセージを送受信できます。
コンストラクター
MsmqIntegrationBinding() |
MsmqIntegrationBinding クラスの新しいインスタンスを初期化します。 |
MsmqIntegrationBinding(MsmqIntegrationSecurityMode) |
指定された MsmqIntegrationBinding を使用して、MsmqIntegrationSecurityMode クラスの新しいインスタンスを初期化します。 |
MsmqIntegrationBinding(String) |
指定した構成バインド要素の設定から MsmqIntegrationBinding クラスの新しいインスタンスを初期化します。 |
プロパティ
CloseTimeout |
接続の終了を待機する時間間隔を取得および設定します。これを超えるとトランスポートで例外が発生します。 (継承元 Binding) |
CustomDeadLetterQueue |
各アプリケーションの配信不能キューの場所が含まれている URI を取得または設定します。この URI には、期限切れのメッセージや、転送または配信に失敗したメッセージが配置されます。 (継承元 MsmqBindingBase) |
DeadLetterQueue |
使用する配信不能キューの型を指定する列挙値を取得または設定します。 (継承元 MsmqBindingBase) |
Durable |
このバインディングによって処理されるメッセージが永続的なものか不安定なものかを示す値を取得または設定します。 (継承元 MsmqBindingBase) |
ExactlyOnce |
このバインディングによって処理されるメッセージが 1 回だけ受信されるものかどうかを示す値を取得または設定します。 (継承元 MsmqBindingBase) |
MaxReceivedMessageSize |
このバインディングで処理されるメッセージの最大サイズ (バイト単位) を取得または設定します。 (継承元 MsmqBindingBase) |
MaxRetryCycles |
受信アプリケーションにメッセージを配信する再試行サイクルの最大数を取得または設定します。 (継承元 MsmqBindingBase) |
MessageVersion |
バインディングで構成されるクライアントとサービスが使用するメッセージ バージョンを取得します。 (継承元 Binding) |
Name |
バインディングの名前を取得または設定します。 (継承元 Binding) |
Namespace |
バインドの XML 名前空間を取得または設定します。 (継承元 Binding) |
OpenTimeout |
接続の確立を待機する時間間隔を取得および設定します。これを超えるとトランスポートで例外が発生します。 (継承元 Binding) |
ReceiveContextEnabled |
受信コンテキストの動作が要求されているかどうかを示す値を取得または設定します。 (継承元 MsmqBindingBase) |
ReceiveErrorHandling |
有害メッセージの処理方法を指定する列挙値を取得または設定します。 (継承元 MsmqBindingBase) |
ReceiveRetryCount |
アプリケーション キューから読み取られるメッセージの即時配信試行の最大回数を取得または設定します。 (継承元 MsmqBindingBase) |
ReceiveTimeout |
アプリケーション メッセージが受信されない間に、接続が非アクティブになってから切断されるまでの時間を取得または設定します。 (継承元 Binding) |
RetryCycleDelay |
すぐに配信できないメッセージの配信を試みるときの、再試行サイクルの時間遅延を示す値を取得または設定します。 (継承元 MsmqBindingBase) |
Scheme |
このバインドのスキーマを返します。 (継承元 MsmqBindingBase) |
Security |
このバインドに関連付けられている MsmqIntegrationSecurity を取得します。 |
SendTimeout |
書き込み操作の完了を待機する時間間隔を取得および設定します。これを超えるとトランスポートで例外が発生します。 (継承元 Binding) |
SerializationFormat |
メッセージのシリアル化または逆シリアル化に使用するシリアル化形式を取得または設定します。 |
TimeToLive |
このバインドで処理されるメッセージの期限が切れるまで、キュー内で保持する期間を取得または設定します。 (継承元 MsmqBindingBase) |
UseMsmqTracing |
このバインディングにより処理されるメッセージをトレースするかどうかを示す値を取得または設定します。 (継承元 MsmqBindingBase) |
UseSourceJournal |
このバインディングにより処理されるメッセージのコピーをソース ジャーナル キューに保存するかどうかを示す値を取得または設定します。 (継承元 MsmqBindingBase) |
ValidityDuration |
メッセージが受信コンテキスト機能によってロックされる期間を指定する値を取得または設定します。 (継承元 MsmqBindingBase) |
メソッド
BuildChannelFactory<TChannel>(BindingParameterCollection) |
指定した種類のチャネルを作成し、バインド パラメーターのコレクションで指定されている機能を満たすチャネル ファクトリ スタックを、クライアント上に構築します。 (継承元 Binding) |
BuildChannelFactory<TChannel>(Object[]) |
指定した種類のチャネルを作成し、オブジェクト配列で指定されている機能を満たすチャネル ファクトリ スタックを、クライアント上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(BindingParameterCollection) |
指定した種類のチャネルを受け入れ、バインド パラメーターのコレクションで指定されている機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Object[]) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Uri, BindingParameterCollection) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Uri, Object[]) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Uri, String, BindingParameterCollection) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Uri, String, ListenUriMode, BindingParameterCollection) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Uri, String, ListenUriMode, Object[]) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
BuildChannelListener<TChannel>(Uri, String, Object[]) |
指定した種類のチャネルを受け入れ、指定した機能を満たすチャネル リスナーを、サービス上に構築します。 (継承元 Binding) |
CanBuildChannelFactory<TChannel>(BindingParameterCollection) |
指定したバインド パラメーターのコレクションを満たすチャネル ファクトリ スタックを、現在のバインドがクライアント上に構築できるかどうかを示す値を返します。 (継承元 Binding) |
CanBuildChannelFactory<TChannel>(Object[]) |
オブジェクト配列で指定した要件を満たすチャネル ファクトリ スタックを、現在のバインドがクライアント上に構築できるかどうかを示す値を返します。 (継承元 Binding) |
CanBuildChannelListener<TChannel>(BindingParameterCollection) |
指定したバインド パラメーターのコレクションを満たすチャネル リスナー スタックを、現在のバインドがサービス上に構築できるかどうかを示す値を返します。 (継承元 Binding) |
CanBuildChannelListener<TChannel>(Object[]) |
オブジェクトの配列で指定した条件を満たすチャネル リスナー スタックを、現在のバインドがサービス上に構築できるかどうかを示す値を返します。 (継承元 Binding) |
CreateBindingElements() |
基本プロファイル スタックのバインド要素を返します。 |
Equals(Object) |
指定されたオブジェクトが現在のオブジェクトと等しいかどうかを判断します。 (継承元 Object) |
GetHashCode() |
既定のハッシュ関数として機能します。 (継承元 Object) |
GetProperty<T>(BindingParameterCollection) |
バインド スタックの適切な層から、要求のあった型指定されたオブジェクト (ある場合) を返します。 (継承元 Binding) |
GetType() |
現在のインスタンスの Type を取得します。 (継承元 Object) |
MemberwiseClone() |
現在の Object の簡易コピーを作成します。 (継承元 Object) |
ShouldSerializeName() |
バインドの名前をシリアル化する必要があるかどうかを示す値を返します。 (継承元 Binding) |
ShouldSerializeNamespace() |
バインドの名前空間をシリアル化する必要があるかどうかを示す値を返します。 (継承元 Binding) |
ShouldSerializeSecurity() |
セキュリティ情報をシリアル化する必要があるかどうかを指定する値を取得します。 |
ToString() |
現在のオブジェクトを表す文字列を返します。 (継承元 Object) |
明示的なインターフェイスの実装
IBindingRuntimePreferences.ReceiveSynchronously |
受信した要求を処理するには同期と非同期のどちらの方が効率的かを示す値を取得します。 (継承元 MsmqBindingBase) |