MsmqIntegrationBinding クラス

定義

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 バインディングを構成する方法を示しています。

次の構成ファイルのスニペットは、サービスで 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)

適用対象