MessageQueueTask 类

Contains the methods and properties used by the Message Queue task. This class cannot be inherited.

继承层次结构

System.Object
  Microsoft.SqlServer.Dts.Runtime.DtsObject
    Microsoft.SqlServer.Dts.Runtime.Task
      Microsoft.SqlServer.Dts.Tasks.MessageQueueTask.MessageQueueTask

命名空间:  Microsoft.SqlServer.Dts.Tasks.MessageQueueTask
程序集:  Microsoft.SqlServer.MSMQTask(在 Microsoft.SqlServer.MSMQTask.dll 中)

语法

声明
Public NotInheritable Class MessageQueueTask _
    Inherits Task _
    Implements IDTSComponentPersist, IMessageQueueTask, IDTSBreakpointSite, IDTSSuspend
用法
Dim instance As MessageQueueTask
public sealed class MessageQueueTask : Task, 
    IDTSComponentPersist, IMessageQueueTask, IDTSBreakpointSite, IDTSSuspend
public ref class MessageQueueTask sealed : public Task, 
    IDTSComponentPersist, IMessageQueueTask, IDTSBreakpointSite, IDTSSuspend
[<SealedAttribute>]
type MessageQueueTask =  
    class 
        inherit Task 
        interface IDTSComponentPersist 
        interface IMessageQueueTask 
        interface IDTSBreakpointSite 
        interface IDTSSuspend 
    end
public final class MessageQueueTask extends Task implements IDTSComponentPersist, IMessageQueueTask, IDTSBreakpointSite, IDTSSuspend

MessageQueueTask 类型公开以下成员。

构造函数

  名称 说明
公共方法 MessageQueueTask Initializes a new instance of the MessageQueueTask class.

页首

属性

  名称 说明
公共属性 CurrentExecutingPackageID Gets or sets the ID of the current executing package.
公共属性 DataFileOverWritable Gets or sets a Boolean that indicates whether the data file message can overwrite an existing data file.
公共属性 DebugMode Gets or sets a Boolean that indicates whether the object is in debug mode, and whether it should raise the OnBreakpointHit event while running.
公共属性 DTSMessageLineageID Gets or sets the message lineage identifier.
公共属性 DTSMessagePackageID Gets or sets the identifier of the package that is the source of the message.
公共属性 DTSMessageVersionID Gets or sets the version of the message.
公共属性 EncryptionAlgo Gets or sets the name of the encryption algorithm used to encrypt the message body of a private message.
公共属性 ErrorIfMessageTimeOut Gets or sets a Boolean specifying whether the task fails when the message times out.
公共属性 ExecutionValue Returns a user-defined object. This field is read-only. (从 Task 继承。)
公共属性 MessageDataFile Gets or sets the data file name used when the MessageType is set to DTSMQMessageType_DataFile.
公共属性 MessageString Gets or sets the message to use when the MessageType is set to DTSMQMessageType_String.
公共属性 MessageType Gets or sets a value that indicates the type of message being sent when the TaskType is DTSMQType_Sender.
公共属性 MessageVariables Gets or sets the variables list when the MQMessageType enumeration is set to DTSMQMessageType_Variables.
公共属性 MsmqConnection Gets or sets the name of the connection for the MSMQ task.
公共属性 OperationDescription Gets or sets the description of the operation.
公共属性 ReceiveMessageTimeOut Gets or sets a value that specifies the number of seconds before a received message times out.
公共属性 ReceiveMessageType Gets or sets an MQMessageType value that indicates the message type to receive.
公共属性 ReceiveVariableMessage Gets or sets the name of the variable in which to store the message.
公共属性 RemoveFromQueue Gets or sets a Boolean that specifies whether the message should be removed from the queue.
公共属性 SaveDataFileName Gets or sets the name of the file to which an incoming Data File message is saved.
公共属性 StringCompareType A value that specifies the string comparison method for a String message type when the TaskType is DTSMQType_Receiver.
公共属性 StringCompareValue Gets or sets the String to which a string message is compared to when the TaskType is DTSMQType_Receiver.
公共属性 StringMessageToVariableName Gets or sets the name of the variable to which the message contents are saved.
公共属性 SuspendRequired Gets or sets a Boolean that indicates if the task should suspend when it encounters a breakpoint. This value is set by the runtime engine for tasks and containers when a breakpoint is encountered.
公共属性 TaskType Gets or sets a value that indicates whether the message task is sending or receiving.
公共属性 Use2000Format Gets or sets a Boolean indicating that the message uses SQL Server 2000 format.
公共属性 UseEncryption Gets or sets a Boolean indicating whether the message uses encryption.
公共属性 Version *** Member deprecated; see Remarks. ***    Returns the version of the task. This property is read-only. (从 Task 继承。)

页首

方法

  名称 说明
公共方法 AcceptBreakpointManager Passes a BreakpointManager to a task. This method is called by the runtime and is not used in code.
公共方法 CanUpdate *** Member deprecated; see Remarks. ***    A Boolean that indicates whether the new package XML can update the old package XML. (从 Task 继承。)
公共方法 Equals Determines whether two object instances are equal. (从 DtsObject 继承。)
公共方法 Execute Runs the task. (覆盖 Task.Execute(Connections, VariableDispenser, IDTSComponentEvents, IDTSLogging, Object)。)
公共方法 GetConnectionID Gets a String containing the ID of the connection. (从 Task 继承。)
公共方法 GetConnectionName Gets a String containing the name of the connection. (从 Task 继承。)
公共方法 GetHashCode Returns the hash code for this instance. (从 DtsObject 继承。)
公共方法 GetType (从 Object 继承。)
公共方法 InitializeTask Initializes the properties associated with the task. This method is called by the runtime and is not used in code. (覆盖 Task.InitializeTask(Connections, VariableDispenser, IDTSInfoEvents, IDTSLogging, EventInfos, LogEntryInfos, ObjectReferenceTracker)。)
公共方法 LoadFromXML This method is not callable by your application code. To load a package saved in XML format (with the.xml file name extension), use the Application.LoadPackage method.
公共方法 ResumeExecution Resumes execution of the task after pausing. Execution of the task or container is resumed by the runtime engine.
公共方法 SaveToXML This method is not callable by your application code. To save a package as .xml, use the Application.SaveToXml method.
公共方法 SuspendExecution Indicates that the executable needs to suspend. This method is called by the runtime engine.
公共方法 ToString (从 Object 继承。)
公共方法 Update *** Member deprecated; see Remarks. ***    This method updates the old package XML with the new package XML if CanUpdate is set to true. (从 Task 继承。)
公共方法 Validate Verifies that the task is properly configured. (覆盖 Task.Validate(Connections, VariableDispenser, IDTSComponentEvents, IDTSLogging)。)

页首

注释

The Message Queue task class allows an object to send and receive messages to or from a queue of Message Queuing (also known as MSMQ). Participation in distributed transactions is allowed when running the Microsoft Distributed Transaction Coordinator (MSDTC). A single instance of a Message Queue task either sends one message to a specified queue or receives a single message from a specified queue, and also waits, if necessary, for the message to arrive. The following types of messages can be sent:

  • A string message, which is supplied as the value of a property.

  • A data file message, which is generated from the contents of a specified data file.

  • A variables message, which is generated from the names and values of one or more SQL Server Integration Services variables.

The enumeration MQMessageType determines which message format is used by a specific Message Queue task.

For more information, see 消息队列任务.

For the MessageQueueTask to work in either the API or in SSIS Designer, you must install SQL Server Integration Services. This feature will not work if only SQL Server Data Tools (SSDT) is installed.

重要说明重要提示

When configuring the Message Queue task to send messages, you can use one of the encryption algorithms that are currently supported by the Message Queuing, RC2 and RC4, to encrypt the message. Both of these encryption algorithms are now considered cryptographically weak compared to newer algorithms, which Message Queuing does not yet support. Therefore, you should consider your cryptography needs carefully when sending messages using the Message Queue task.

线程安全

此类型的任何公共 static(在 Visual Basic 中为 Shared) 成员都是线程安全的。不保证所有实例成员都是线程安全的。

请参阅

参考

Microsoft.SqlServer.Dts.Tasks.MessageQueueTask 命名空间