MsmqIntegrationBinding クラス

リファレンス

定義

名前空間:: System.ServiceModel.MsmqIntegration

アセンブリ:: System.ServiceModel.dll

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 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

継承: Object

Binding

MsmqBindingBase
MsmqIntegrationBinding

例

次の構成ファイルのスニペットは、クライアントで 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)

適用対象

Share via