#pragma warning disable 162
namespace HT1_MQ
{
[Microsoft.XLANGs.BaseTypes.PortTypeOperationAttribute(
"Operation_1",
new System.Type[]{
typeof(HT1_MQ.__messagetype_HT1_MQ_SchIN)
},
new string[]{
}
)]
[Microsoft.XLANGs.BaseTypes.PortTypeAttribute(Microsoft.XLANGs.BaseTypes.EXLangSAccess.eInternal, "")]
[System.SerializableAttribute]
sealed internal class HT1_MQ_PT : Microsoft.BizTalk.XLANGs.BTXEngine.BTXPortBase
{
public HT1_MQ_PT(int portInfo, Microsoft.XLANGs.Core.IServiceProxy s)
: base(portInfo, s)
{ }
public HT1_MQ_PT(HT1_MQ_PT p)
: base(p)
{ }
public override Microsoft.XLANGs.Core.PortBase Clone()
{
HT1_MQ_PT p = new HT1_MQ_PT(this);
return p;
}
public static readonly Microsoft.XLANGs.BaseTypes.EXLangSAccess __access = Microsoft.XLANGs.BaseTypes.EXLangSAccess.eInternal;
#region port reflection support
static public Microsoft.XLANGs.Core.OperationInfo Operation_1 = new Microsoft.XLANGs.Core.OperationInfo
(
"Operation_1",
System.Web.Services.Description.OperationFlow.OneWay,
typeof(HT1_MQ_PT),
typeof(__messagetype_HT1_MQ_SchIN),
null,
new System.Type[]{},
new string[]{}
);
static public System.Collections.Hashtable OperationsInformation
{
get
{
System.Collections.Hashtable h = new System.Collections.Hashtable();
h[ "Operation_1" ] = Operation_1;
return h;
}
}
#endregion // port reflection support
}
[Microsoft.XLANGs.BaseTypes.PortTypeOperationAttribute(
"Operation_1",
new System.Type[]{
typeof(HT1_MQ.__messagetype_HT1_MQ_SchOUT)
},
new string[]{
}
)]
[Microsoft.XLANGs.BaseTypes.PortTypeAttribute(Microsoft.XLANGs.BaseTypes.EXLangSAccess.eInternal, "")]
[System.SerializableAttribute]
sealed internal class HT1_MQ_SEN_PT : Microsoft.BizTalk.XLANGs.BTXEngine.BTXPortBase
{
public HT1_MQ_SEN_PT(int portInfo, Microsoft.XLANGs.Core.IServiceProxy s)
: base(portInfo, s)
{ }
public HT1_MQ_SEN_PT(HT1_MQ_SEN_PT p)
: base(p)
{ }
public override Microsoft.XLANGs.Core.PortBase Clone()
{
HT1_MQ_SEN_PT p = new HT1_MQ_SEN_PT(this);
return p;
}
public static readonly Microsoft.XLANGs.BaseTypes.EXLangSAccess __access = Microsoft.XLANGs.BaseTypes.EXLangSAccess.eInternal;
#region port reflection support
static public Microsoft.XLANGs.Core.OperationInfo Operation_1 = new Microsoft.XLANGs.Core.OperationInfo
(
"Operation_1",
System.Web.Services.Description.OperationFlow.OneWay,
typeof(HT1_MQ_SEN_PT),
typeof(__messagetype_HT1_MQ_SchOUT),
null,
new System.Type[]{},
new string[]{}
);
static public System.Collections.Hashtable OperationsInformation
{
get
{
System.Collections.Hashtable h = new System.Collections.Hashtable();
h[ "Operation_1" ] = Operation_1;
return h;
}
}
#endregion // port reflection support
}
//#line 198 "E:\BizTalk_PRO\HT1\HT1_MQ\HT1_MQ\OrcDemo.odx"
[Microsoft.XLANGs.BaseTypes.StaticSubscriptionAttribute(
0, "HT1_MQ_REC", "Operation_1", -1, -1, true
)]
[Microsoft.XLANGs.BaseTypes.ServicePortsAttribute(
new Microsoft.XLANGs.BaseTypes.EXLangSParameter[] {
Microsoft.XLANGs.BaseTypes.EXLangSParameter.ePort|Microsoft.XLANGs.BaseTypes.EXLangSParameter.eImplements,
Microsoft.XLANGs.BaseTypes.EXLangSParameter.ePort|Microsoft.XLANGs.BaseTypes.EXLangSParameter.eUses
},
new System.Type[] {
typeof(HT1_MQ.HT1_MQ_PT),
typeof(HT1_MQ.HT1_MQ_SEN_PT)
},
new System.String[] {
"HT1_MQ_REC",
"HT1_MQ_SEN"
},
new System.Type[] {
null,
null
}
)]
[Microsoft.XLANGs.BaseTypes.ServiceCallTreeAttribute(
new System.Type[] {
},
new System.Type[] {
},
new System.Type[] {
}
)]
[Microsoft.XLANGs.BaseTypes.ServiceAttribute(
Microsoft.XLANGs.BaseTypes.EXLangSAccess.eInternal,
Microsoft.XLANGs.BaseTypes.EXLangSServiceInfo.eNone
)]
[System.SerializableAttribute]
[Microsoft.XLANGs.BaseTypes.BPELExportableAttribute(false)]
sealed internal class OrcDemo : Microsoft.BizTalk.XLANGs.BTXEngine.BTXService
{
public static readonly Microsoft.XLANGs.BaseTypes.EXLangSAccess __access = Microsoft.XLANGs.BaseTypes.EXLangSAccess.eInternal;
public static readonly bool __execable = false;
[Microsoft.XLANGs.BaseTypes.CallCompensationAttribute(
Microsoft.XLANGs.BaseTypes.EXLangSCallCompensationInfo.eNone,
new System.String[] {
},
new System.String[] {
}
)]
public static void __bodyProxy()
{
}
private static System.Guid _serviceId = Microsoft.XLANGs.Core.HashHelper.HashServiceType(typeof(OrcDemo));
private static volatile System.Guid[] _activationSubIds;
private static new object _lockIdentity = new object();
public static System.Guid UUID { get { return _serviceId; } }
public override System.Guid ServiceId { get { return UUID; } }
protected override System.Guid[] ActivationSubGuids
{
get { return _activationSubIds; }
set { _activationSubIds = value; }
}
protected override object StaleStateLock
{
get { return _lockIdentity; }
}
protected override bool HasActivation { get { return true; } }
internal bool IsExeced = false;
static OrcDemo()
{
Microsoft.BizTalk.XLANGs.BTXEngine.BTXService.CacheStaticState( _serviceId );
}
private void ConstructorHelper()
{
_segments = new Microsoft.XLANGs.Core.Segment[] {
new Microsoft.XLANGs.Core.Segment( new Microsoft.XLANGs.Core.Segment.SegmentCode(this.segment0), 0, 0, 0),
new Microsoft.XLANGs.Core.Segment( new Microsoft.XLANGs.Core.Segment.SegmentCode(this.segment1), 1, 1, 1)
};
_Locks = 0;
_rootContext = new __OrcDemo_root_0(this);
_stateMgrs = new Microsoft.XLANGs.Core.IStateManager[2];
_stateMgrs[0] = _rootContext;
FinalConstruct();
}
public OrcDemo(System.Guid instanceId, Microsoft.BizTalk.XLANGs.BTXEngine.BTXSession session, Microsoft.BizTalk.XLANGs.BTXEngine.BTXEvents tracker)
: base(instanceId, session, "OrcDemo", tracker)
{
ConstructorHelper();
}
public OrcDemo(int callIndex, System.Guid instanceId, Microsoft.BizTalk.XLANGs.BTXEngine.BTXService parent)
: base(callIndex, instanceId, parent, "OrcDemo")
{
ConstructorHelper();
}
private const string _symInfo = @"
<XsymFile>
<ProcessFlow xmlns:om='http://schemas.microsoft.com/BizTalk/2003/DesignerData'> <shapeType>RootShape</shapeType> <ShapeID>0b552b59-b7d2-4c95-893a-cc4cec4b9bc7</ShapeID>
<children>
<ShapeInfo> <shapeType>ReceiveShape</shapeType> <ShapeID>f6aff882-e910-4f88-ad84-b61ad3a9d303</ShapeID> <ParentLink>ServiceBody_Statement</ParentLink> <shapeText>Rec File</shapeText>
<children> </children>
</ShapeInfo>
<ShapeInfo> <shapeType>VariableAssignmentShape</shapeType> <ShapeID>2d3a2531-2e47-4702-8f8a-4e53cae60555</ShapeID> <ParentLink>ServiceBody_Statement</ParentLink> <shapeText>Trace Log</shapeText>
<children> </children>
</ShapeInfo>
<ShapeInfo> <shapeType>ConstructShape</shapeType> <ShapeID>626f3c43-5cdd-45cf-8e35-d02f88024d31</ShapeID> <ParentLink>ServiceBody_Statement</ParentLink> <shapeText>Construct Out Message</shapeText>
<children>
<ShapeInfo> <shapeType>TransformShape</shapeType> <ShapeID>4364ae46-43c2-40fb-ab3d-c39d0e6ef2bc</ShapeID> <ParentLink>ComplexStatement_Statement</ParentLink> <shapeText>Mapp In to OUT</shapeText>
<children>
<ShapeInfo> <shapeType>MessagePartRefShape</shapeType> <ShapeID>0b2e4ad0-1422-4dfd-99fa-afb30001f782</ShapeID> <ParentLink>Transform_InputMessagePartRef</ParentLink> <shapeText>MessagePartReference_1</shapeText>
<children> </children>
</ShapeInfo>
<ShapeInfo> <shapeType>MessagePartRefShape</shapeType> <ShapeID>1cf46884-d525-4975-b062-28b0cdbc36ab</ShapeID> <ParentLink>Transform_OutputMessagePartRef</ParentLink> <shapeText>MessagePartReference_2</shapeText>
<children> </children>
</ShapeInfo>
</children>
</ShapeInfo>
<ShapeInfo> <shapeType>MessageRefShape</shapeType> <ShapeID>c41a9654-16d2-4fa3-a4ca-e9db5f525ad4</ShapeID> <ParentLink>Construct_MessageRef</ParentLink>
<children> </children>
</ShapeInfo>
</children>
</ShapeInfo>
<ShapeInfo> <shapeType>VariableAssignmentShape</shapeType> <ShapeID>1d797645-3a2b-4531-8124-672d70ca45c6</ShapeID> <ParentLink>ServiceBody_Statement</ParentLink> <shapeText>Trace Log</shapeText>
<children> </children>
</ShapeInfo>
<ShapeInfo> <shapeType>SendShape</shapeType> <ShapeID>1e7149c9-a82b-4e86-84ca-dc73342e756a</ShapeID> <ParentLink>ServiceBody_Statement</ParentLink> <shapeText>Send Msg</shapeText>
<children> </children>
</ShapeInfo>
</children>
</ProcessFlow><Metadata>
<TrkMetadata>
<ActionName>'OrcDemo'</ActionName><IsAtomic>0</IsAtomic><Line>198</Line><Position>14</Position><ShapeID>'e211a116-cb8b-44e7-a052-0de295aa0001'</ShapeID>
</TrkMetadata>
<TrkMetadata>
<Line>210</Line><Position>22</Position><ShapeID>'f6aff882-e910-4f88-ad84-b61ad3a9d303'</ShapeID>
<Messages>
<MsgInfo><name>msgIN</name><part>part</part><schema>HT1_MQ.SchIN</schema><direction>Out</direction></MsgInfo>
</Messages>
</TrkMetadata>
<TrkMetadata>
<Line>213</Line><Position>51</Position><ShapeID>'2d3a2531-2e47-4702-8f8a-4e53cae60555'</ShapeID>
<Messages>
</Messages>
</TrkMetadata>
<TrkMetadata>
<Line>216</Line><Position>13</Position><ShapeID>'626f3c43-5cdd-45cf-8e35-d02f88024d31'</ShapeID>
<Messages>
<MsgInfo><name>msgOUT</name><part>part</part><schema>HT1_MQ.SchOUT</schema><direction>Out</direction></MsgInfo>
<MsgInfo><name>msgIN</name><part>part</part><schema>HT1_MQ.SchIN</schema><direction>In</direction></MsgInfo>
</Messages>
</TrkMetadata>
<TrkMetadata>
<Line>222</Line><Position>51</Position><ShapeID>'1d797645-3a2b-4531-8124-672d70ca45c6'</ShapeID>
<Messages>
</Messages>
</TrkMetadata>
<TrkMetadata>
<Line>225</Line><Position>13</Position><ShapeID>'1e7149c9-a82b-4e86-84ca-dc73342e756a'</ShapeID>
<Messages>
<MsgInfo><name>msgOUT</name><part>part</part><schema>HT1_MQ.SchOUT</schema><direction>Out</direction></MsgInfo>
</Messages>
</TrkMetadata>
</Metadata>
</XsymFile>";
public override string odXml { get { return _symODXML; } }
private const string _symODXML = @"
<?xml version='1.0' encoding='utf-8' standalone='yes'?>
<om:MetaModel MajorVersion='1' MinorVersion='3' Core='2b131234-7959-458d-834f-2dc0769ce683' ScheduleModel='66366196-361d-448d-976f-cab5e87496d2' xmlns:om='http://schemas.microsoft.com/BizTalk/2003/DesignerData'>
<om:Element Type='Module' OID='6058e33c-3851-48ee-9901-2141fa6cdda3' LowerBound='1.1' HigherBound='50.1'>
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='HT1_MQ' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='PortType' OID='a11d1cb9-281a-4135-8211-f55bdd20e62f' ParentLink='Module_PortType' LowerBound='4.1' HigherBound='11.1'>
<om:Property Name='Synchronous' Value='False' />
<om:Property Name='TypeModifier' Value='Internal' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='HT1_MQ_PT' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='OperationDeclaration' OID='0b80d7a8-8cc3-4caa-986e-18c5b709da59' ParentLink='PortType_OperationDeclaration' LowerBound='6.1' HigherBound='10.1'>
<om:Property Name='OperationType' Value='OneWay' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Operation_1' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='MessageRef' OID='2e530562-cb13-48be-8974-c209b31a2f14' ParentLink='OperationDeclaration_RequestMessageRef' LowerBound='8.13' HigherBound='8.18'>
<om:Property Name='Ref' Value='HT1_MQ.SchIN' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Request' />
<om:Property Name='Signal' Value='False' />
</om:Element>
</om:Element>
</om:Element>
<om:Element Type='PortType' OID='6766254c-1913-48b6-baf9-872576b17d19' ParentLink='Module_PortType' LowerBound='11.1' HigherBound='18.1'>
<om:Property Name='Synchronous' Value='False' />
<om:Property Name='TypeModifier' Value='Internal' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='HT1_MQ_SEN_PT' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='OperationDeclaration' OID='de6803d7-718b-4ac7-9b01-e67002212f9c' ParentLink='PortType_OperationDeclaration' LowerBound='13.1' HigherBound='17.1'>
<om:Property Name='OperationType' Value='OneWay' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Operation_1' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='MessageRef' OID='f9cc19fa-8ded-4e36-99b9-d3c1c3fd23c5' ParentLink='OperationDeclaration_RequestMessageRef' LowerBound='15.13' HigherBound='15.19'>
<om:Property Name='Ref' Value='HT1_MQ.SchOUT' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Request' />
<om:Property Name='Signal' Value='False' />
</om:Element>
</om:Element>
</om:Element>
<om:Element Type='ServiceDeclaration' OID='f5232e8a-40f7-4477-ad26-3b0fa43e9b8c' ParentLink='Module_ServiceDeclaration' LowerBound='18.1' HigherBound='49.1'>
<om:Property Name='InitializedTransactionType' Value='False' />
<om:Property Name='IsInvokable' Value='False' />
<om:Property Name='TypeModifier' Value='Internal' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='OrcDemo' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='VariableDeclaration' OID='c35ee1d9-8052-4e41-b03d-aec8cf6d36f2' ParentLink='ServiceDeclaration_VariableDeclaration' LowerBound='27.1' HigherBound='28.1'>
<om:Property Name='InitialValue' Value='"HT1_MQ"' />
<om:Property Name='UseDefaultConstructor' Value='False' />
<om:Property Name='Type' Value='System.String' />
<om:Property Name='ParamDirection' Value='In' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='varOrchName' />
<om:Property Name='Signal' Value='True' />
</om:Element>
<om:Element Type='MessageDeclaration' OID='79685013-f751-4300-8acd-c8796de9efdf' ParentLink='ServiceDeclaration_MessageDeclaration' LowerBound='25.1' HigherBound='26.1'>
<om:Property Name='Type' Value='HT1_MQ.SchIN' />
<om:Property Name='ParamDirection' Value='In' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='msgIN' />
<om:Property Name='Signal' Value='True' />
</om:Element>
<om:Element Type='MessageDeclaration' OID='8a95cc36-82ad-43ec-8739-a1fc640c3a1a' ParentLink='ServiceDeclaration_MessageDeclaration' LowerBound='26.1' HigherBound='27.1'>
<om:Property Name='Type' Value='HT1_MQ.SchOUT' />
<om:Property Name='ParamDirection' Value='In' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='msgOUT' />
<om:Property Name='Signal' Value='True' />
</om:Element>
<om:Element Type='ServiceBody' OID='0b552b59-b7d2-4c95-893a-cc4cec4b9bc7' ParentLink='ServiceDeclaration_ServiceBody'>
<om:Property Name='Signal' Value='False' />
<om:Element Type='Receive' OID='f6aff882-e910-4f88-ad84-b61ad3a9d303' ParentLink='ServiceBody_Statement' LowerBound='30.1' HigherBound='33.1'>
<om:Property Name='Activate' Value='True' />
<om:Property Name='PortName' Value='HT1_MQ_REC' />
<om:Property Name='MessageName' Value='msgIN' />
<om:Property Name='OperationName' Value='Operation_1' />
<om:Property Name='OperationMessageName' Value='Request' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Rec File' />
<om:Property Name='Signal' Value='True' />
</om:Element>
<om:Element Type='VariableAssignment' OID='2d3a2531-2e47-4702-8f8a-4e53cae60555' ParentLink='ServiceBody_Statement' LowerBound='33.1' HigherBound='36.1'>
<om:Property Name='Expression' Value='System.Diagnostics.EventLog.WriteEntry(
varOrchName,"STARTED..",System.Diagnostics.EventLogEntryType.SuccessAudit);
' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Trace Log' />
<om:Property Name='Signal' Value='True' />
</om:Element>
<om:Element Type='Construct' OID='626f3c43-5cdd-45cf-8e35-d02f88024d31' ParentLink='ServiceBody_Statement' LowerBound='36.1' HigherBound='42.1'>
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Construct Out Message' />
<om:Property Name='Signal' Value='True' />
<om:Element Type='Transform' OID='4364ae46-43c2-40fb-ab3d-c39d0e6ef2bc' ParentLink='ComplexStatement_Statement' LowerBound='39.1' HigherBound='41.1'>
<om:Property Name='ClassName' Value='HT1_MQ.MapIndToGrp' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Mapp In to OUT' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='MessagePartRef' OID='0b2e4ad0-1422-4dfd-99fa-afb30001f782' ParentLink='Transform_InputMessagePartRef' LowerBound='40.58' HigherBound='40.63'>
<om:Property Name='MessageRef' Value='msgIN' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='MessagePartReference_1' />
<om:Property Name='Signal' Value='False' />
</om:Element>
<om:Element Type='MessagePartRef' OID='1cf46884-d525-4975-b062-28b0cdbc36ab' ParentLink='Transform_OutputMessagePartRef' LowerBound='40.28' HigherBound='40.34'>
<om:Property Name='MessageRef' Value='msgOUT' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='MessagePartReference_2' />
<om:Property Name='Signal' Value='False' />
</om:Element>
</om:Element>
<om:Element Type='MessageRef' OID='c41a9654-16d2-4fa3-a4ca-e9db5f525ad4' ParentLink='Construct_MessageRef' LowerBound='37.23' HigherBound='37.29'>
<om:Property Name='Ref' Value='msgOUT' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Signal' Value='False' />
</om:Element>
</om:Element>
<om:Element Type='VariableAssignment' OID='1d797645-3a2b-4531-8124-672d70ca45c6' ParentLink='ServiceBody_Statement' LowerBound='42.1' HigherBound='45.1'>
<om:Property Name='Expression' Value='System.Diagnostics.EventLog.WriteEntry(
varOrchName,"FINISHED.",System.Diagnostics.EventLogEntryType.SuccessAudit);
' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Trace Log' />
<om:Property Name='Signal' Value='False' />
</om:Element>
<om:Element Type='Send' OID='1e7149c9-a82b-4e86-84ca-dc73342e756a' ParentLink='ServiceBody_Statement' LowerBound='45.1' HigherBound='47.1'>
<om:Property Name='PortName' Value='HT1_MQ_SEN' />
<om:Property Name='MessageName' Value='msgOUT' />
<om:Property Name='OperationName' Value='Operation_1' />
<om:Property Name='OperationMessageName' Value='Request' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='Send Msg' />
<om:Property Name='Signal' Value='True' />
</om:Element>
</om:Element>
<om:Element Type='PortDeclaration' OID='a7a3c5b0-7dfb-492d-8e46-d5a1d0067ebc' ParentLink='ServiceDeclaration_PortDeclaration' LowerBound='21.1' HigherBound='23.1'>
<om:Property Name='PortModifier' Value='Implements' />
<om:Property Name='Orientation' Value='Left' />
<om:Property Name='PortIndex' Value='1' />
<om:Property Name='IsWebPort' Value='False' />
<om:Property Name='OrderedDelivery' Value='False' />
<om:Property Name='DeliveryNotification' Value='None' />
<om:Property Name='Type' Value='HT1_MQ.HT1_MQ_PT' />
<om:Property Name='ParamDirection' Value='In' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='HT1_MQ_REC' />
<om:Property Name='Signal' Value='True' />
<om:Element Type='PhysicalBindingAttribute' OID='fa12d6e2-d4e5-4fd5-bb42-295ad036f010' ParentLink='PortDeclaration_CLRAttribute' LowerBound='21.1' HigherBound='22.1'>
<om:Property Name='InPipeline' Value='Microsoft.BizTalk.DefaultPipelines.XMLReceive' />
<om:Property Name='OutPipeline' Value='Microsoft.BizTalk.DefaultPipelines.XMLTransmit' />
<om:Property Name='TransportType' Value='FILE' />
<om:Property Name='URI' Value='\\10.10.234.58\Share\HT1\IN_MQ\*.*' />
<om:Property Name='IsDynamic' Value='False' />
<om:Property Name='Signal' Value='False' />
</om:Element>
</om:Element>
<om:Element Type='PortDeclaration' OID='f0cd99f3-7a88-460f-88f2-8f0c1ba787f4' ParentLink='ServiceDeclaration_PortDeclaration' LowerBound='23.1' HigherBound='25.1'>
<om:Property Name='PortModifier' Value='Uses' />
<om:Property Name='Orientation' Value='Right' />
<om:Property Name='PortIndex' Value='15' />
<om:Property Name='IsWebPort' Value='False' />
<om:Property Name='OrderedDelivery' Value='False' />
<om:Property Name='DeliveryNotification' Value='None' />
<om:Property Name='Type' Value='HT1_MQ.HT1_MQ_SEN_PT' />
<om:Property Name='ParamDirection' Value='In' />
<om:Property Name='ReportToAnalyst' Value='True' />
<om:Property Name='Name' Value='HT1_MQ_SEN' />
<om:Property Name='Signal' Value='False' />
<om:Element Type='LogicalBindingAttribute' OID='32020973-632e-4afa-af63-c4d9948c384b' ParentLink='PortDeclaration_CLRAttribute' LowerBound='23.1' HigherBound='24.1'>
<om:Property Name='Signal' Value='False' />
</om:Element>
</om:Element>
</om:Element>
</om:Element>
</om:MetaModel>
";
[System.SerializableAttribute]
public class __OrcDemo_root_0 : Microsoft.XLANGs.Core.ServiceContext
{
public __OrcDemo_root_0(Microsoft.XLANGs.Core.Service svc)
: base(svc, "OrcDemo")
{
}
public override int Index { get { return 0; } }
public override Microsoft.XLANGs.Core.Segment InitialSegment
{
get { return _service._segments[0]; }
}
public override Microsoft.XLANGs.Core.Segment FinalSegment
{
get { return _service._segments[0]; }
}
public override int CompensationSegment { get { return -1; } }
public override bool OnError()
{
Finally();
return false;
}
public override void Finally()
{
OrcDemo __svc__ = (OrcDemo)_service;
__OrcDemo_root_0 __ctx0__ = (__OrcDemo_root_0)(__svc__._stateMgrs[0]);
if (__svc__.HT1_MQ_SEN != null)
{
__svc__.HT1_MQ_SEN.Close(this, null);
__svc__.HT1_MQ_SEN = null;
}
if (__svc__.HT1_MQ_REC != null)
{
__svc__.HT1_MQ_REC.Close(this, null);
__svc__.HT1_MQ_REC = null;
}
base.Finally();
}
internal Microsoft.XLANGs.Core.SubscriptionWrapper __subWrapper0;
}
[System.SerializableAttribute]
public class __OrcDemo_1 : Microsoft.XLANGs.Core.ExceptionHandlingContext
{
public __OrcDemo_1(Microsoft.XLANGs.Core.Service svc)
: base(svc, "OrcDemo")
{
}
public override int Index { get { return 1; } }
public override bool CombineParentCommit { get { return true; } }
public override Microsoft.XLANGs.Core.Segment InitialSegment
{
get { return _service._segments[1]; }
}
public override Microsoft.XLANGs.Core.Segment FinalSegment
{
get { return _service._segments[1]; }
}
public override int CompensationSegment { get { return -1; } }
public override bool OnError()
{
Finally();
return false;
}
public override void Finally()
{
OrcDemo __svc__ = (OrcDemo)_service;
__OrcDemo_1 __ctx1__ = (__OrcDemo_1)(__svc__._stateMgrs[1]);
if (__ctx1__ != null && __ctx1__.__msgOUT != null)
{
__ctx1__.UnrefMessage(__ctx1__.__msgOUT);
__ctx1__.__msgOUT = null;
}
if (__ctx1__ != null && __ctx1__.__msgIN != null)
{
__ctx1__.UnrefMessage(__ctx1__.__msgIN);
__ctx1__.__msgIN = null;
}
if (__ctx1__ != null)
__ctx1__.__varOrchName = null;
base.Finally();
}
[Microsoft.XLANGs.Core.UserVariableAttribute("msgIN")]
public __messagetype_HT1_MQ_SchIN __msgIN;
[Microsoft.XLANGs.Core.UserVariableAttribute("msgOUT")]
public __messagetype_HT1_MQ_SchOUT __msgOUT;
[Microsoft.XLANGs.Core.UserVariableAttribute("varOrchName")]
internal System.String __varOrchName;
}
private static Microsoft.XLANGs.Core.CorrelationType[] _correlationTypes = null;
public override Microsoft.XLANGs.Core.CorrelationType[] CorrelationTypes { get { return _correlationTypes; } }
private static System.Guid[] _convoySetIds;
public override System.Guid[] ConvoySetGuids
{
get { return _convoySetIds; }
set { _convoySetIds = value; }
}
public static object[] StaticConvoySetInformation
{
get {
return null;
}
}
[Microsoft.XLANGs.BaseTypes.PhysicalBindingAttribute("FILE", "\\\\10.10.234.58\\Share\\HT1\\IN_MQ\\*.*", typeof(Microsoft.BizTalk.DefaultPipelines.XMLReceive))]
[Microsoft.XLANGs.BaseTypes.PortAttribute(
Microsoft.XLANGs.BaseTypes.EXLangSParameter.eImplements
)]
[Microsoft.XLANGs.Core.UserVariableAttribute("HT1_MQ_REC")]
internal HT1_MQ_PT HT1_MQ_REC;
[Microsoft.XLANGs.BaseTypes.LogicalBindingAttribute()]
[Microsoft.XLANGs.BaseTypes.PortAttribute(
Microsoft.XLANGs.BaseTypes.EXLangSParameter.eUses
)]
[Microsoft.XLANGs.Core.UserVariableAttribute("HT1_MQ_SEN")]
internal HT1_MQ_SEN_PT HT1_MQ_SEN;
public static Microsoft.XLANGs.Core.PortInfo[] _portInfo = new Microsoft.XLANGs.Core.PortInfo[] {
new Microsoft.XLANGs.Core.PortInfo(new Microsoft.XLANGs.Core.OperationInfo[] {HT1_MQ_PT.Operation_1},
typeof(OrcDemo).GetField("HT1_MQ_REC", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance),
Microsoft.XLANGs.BaseTypes.Polarity.implements,
false,
Microsoft.XLANGs.Core.HashHelper.HashPort(typeof(OrcDemo), "HT1_MQ_REC"),
null),
new Microsoft.XLANGs.Core.PortInfo(new Microsoft.XLANGs.Core.OperationInfo[] {HT1_MQ_SEN_PT.Operation_1},
typeof(OrcDemo).GetField("HT1_MQ_SEN", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance),
Microsoft.XLANGs.BaseTypes.Polarity.uses,
false,
Microsoft.XLANGs.Core.HashHelper.HashPort(typeof(OrcDemo), "HT1_MQ_SEN"),
null)
};
public override Microsoft.XLANGs.Core.PortInfo[] PortInformation
{
get { return _portInfo; }
}
static public System.Collections.Hashtable PortsInformation
{
get
{
System.Collections.Hashtable h = new System.Collections.Hashtable();
h[_portInfo[0].Name] = _portInfo[0];
h[_portInfo[1].Name] = _portInfo[1];
return h;
}
}
public static System.Type[] InvokedServicesTypes
{
get
{
return new System.Type[] {
// type of each service invoked by this service
};
}
}
public static System.Type[] CalledServicesTypes
{
get
{
return new System.Type[] {
};
}
}
public static System.Type[] ExecedServicesTypes
{
get
{
return new System.Type[] {
};
}
}
public static object[] StaticSubscriptionsInformation {
get {
return new object[1]{
new object[5] { _portInfo[0], 0, null , -1, true }
};
}
}
public static Microsoft.XLANGs.RuntimeTypes.Location[] __eventLocations = new Microsoft.XLANGs.RuntimeTypes.Location[] {
new Microsoft.XLANGs.RuntimeTypes.Location(0, "00000000-0000-0000-0000-000000000000", 1, true),
new Microsoft.XLANGs.RuntimeTypes.Location(1, "f6aff882-e910-4f88-ad84-b61ad3a9d303", 1, true),
new Microsoft.XLANGs.RuntimeTypes.Location(2, "f6aff882-e910-4f88-ad84-b61ad3a9d303", 1, false),
new Microsoft.XLANGs.RuntimeTypes.Location(3, "00000000-0000-0000-0000-000000000000", 1, false),
new Microsoft.XLANGs.RuntimeTypes.Location(4, "2d3a2531-2e47-4702-8f8a-4e53cae60555", 1, true),
new Microsoft.XLANGs.RuntimeTypes.Location(5, "2d3a2531-2e47-4702-8f8a-4e53cae60555", 1, false),
new Microsoft.XLANGs.RuntimeTypes.Location(6, "626f3c43-5cdd-45cf-8e35-d02f88024d31", 1, true),
new Microsoft.XLANGs.RuntimeTypes.Location(7, "626f3c43-5cdd-45cf-8e35-d02f88024d31", 1, false),
new Microsoft.XLANGs.RuntimeTypes.Location(8, "1d797645-3a2b-4531-8124-672d70ca45c6", 1, true),
new Microsoft.XLANGs.RuntimeTypes.Location(9, "1d797645-3a2b-4531-8124-672d70ca45c6", 1, false),
new Microsoft.XLANGs.RuntimeTypes.Location(10, "1e7149c9-a82b-4e86-84ca-dc73342e756a", 1, true),
new Microsoft.XLANGs.RuntimeTypes.Location(11, "1e7149c9-a82b-4e86-84ca-dc73342e756a", 1, false)
};
public override Microsoft.XLANGs.RuntimeTypes.Location[] EventLocations
{
get { return __eventLocations; }
}
public static Microsoft.XLANGs.RuntimeTypes.EventData[] __eventData = new Microsoft.XLANGs.RuntimeTypes.EventData[] {
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.Start | Microsoft.XLANGs.RuntimeTypes.Operation.Body),
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.Start | Microsoft.XLANGs.RuntimeTypes.Operation.Receive),
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.Start | Microsoft.XLANGs.RuntimeTypes.Operation.Expression),
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.End | Microsoft.XLANGs.RuntimeTypes.Operation.Expression),
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.Start | Microsoft.XLANGs.RuntimeTypes.Operation.Construct),
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.Start | Microsoft.XLANGs.RuntimeTypes.Operation.Send),
new Microsoft.XLANGs.RuntimeTypes.EventData( Microsoft.XLANGs.RuntimeTypes.Operation.End | Microsoft.XLANGs.RuntimeTypes.Operation.Body)
};
public static int[] __progressLocation0 = new int[] { 0,0,0,3,3,};
public static int[] __progressLocation1 = new int[] { 0,0,1,1,2,2,4,4,5,6,6,7,8,8,9,10,10,10,11,3,3,3,3,};
public static int[][] __progressLocations = new int[2] [] {__progressLocation0,__progressLocation1};
public override int[][] ProgressLocations {get {return __progressLocations;} }
public Microsoft.XLANGs.Core.StopConditions segment0(Microsoft.XLANGs.Core.StopConditions stopOn)
{
Microsoft.XLANGs.Core.Segment __seg__ = _segments[0];
Microsoft.XLANGs.Core.Context __ctx__ = (Microsoft.XLANGs.Core.Context)_stateMgrs[0];
__OrcDemo_root_0 __ctx0__ = (__OrcDemo_root_0)_stateMgrs[0];
__OrcDemo_1 __ctx1__ = (__OrcDemo_1)_stateMgrs[1];
switch (__seg__.Progress)
{
case 0:
HT1_MQ_REC = new HT1_MQ_PT(0, this);
HT1_MQ_SEN = new HT1_MQ_SEN_PT(1, this);
__ctx__.PrologueCompleted = true;
__ctx0__.__subWrapper0 = new Microsoft.XLANGs.Core.SubscriptionWrapper(ActivationSubGuids[0], HT1_MQ_REC, this);
if ( !PostProgressInc( __seg__, __ctx__, 1 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
if ((stopOn & Microsoft.XLANGs.Core.StopConditions.Initialized) != 0)
return Microsoft.XLANGs.Core.StopConditions.Initialized;
goto case 1;
case 1:
__ctx1__ = new __OrcDemo_1(this);
_stateMgrs[1] = __ctx1__;
if ( !PostProgressInc( __seg__, __ctx__, 2 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 2;
case 2:
__ctx0__.StartContext(__seg__, __ctx1__);
if ( !PostProgressInc( __seg__, __ctx__, 3 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
return Microsoft.XLANGs.Core.StopConditions.Blocked;
case 3:
if (!__ctx0__.CleanupAndPrepareToCommit(__seg__))
return Microsoft.XLANGs.Core.StopConditions.Blocked;
if ( !PostProgressInc( __seg__, __ctx__, 4 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 4;
case 4:
__ctx1__.Finally();
ServiceDone(__seg__, (Microsoft.XLANGs.Core.Context)_stateMgrs[0]);
__ctx0__.OnCommit();
break;
}
return Microsoft.XLANGs.Core.StopConditions.Completed;
}
public Microsoft.XLANGs.Core.StopConditions segment1(Microsoft.XLANGs.Core.StopConditions stopOn)
{
Microsoft.XLANGs.Core.Envelope __msgEnv__ = null;
Microsoft.XLANGs.Core.Segment __seg__ = _segments[1];
Microsoft.XLANGs.Core.Context __ctx__ = (Microsoft.XLANGs.Core.Context)_stateMgrs[1];
__OrcDemo_root_0 __ctx0__ = (__OrcDemo_root_0)_stateMgrs[0];
__OrcDemo_1 __ctx1__ = (__OrcDemo_1)_stateMgrs[1];
switch (__seg__.Progress)
{
case 0:
__ctx1__.__varOrchName = default(System.String);
__ctx__.PrologueCompleted = true;
if ( !PostProgressInc( __seg__, __ctx__, 1 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 1;
case 1:
if ( !PreProgressInc( __seg__, __ctx__, 2 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[0],__eventData[0],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 2;
case 2:
if ( !PreProgressInc( __seg__, __ctx__, 3 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[1],__eventData[1],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 3;
case 3:
if (!HT1_MQ_REC.GetMessageId(__ctx0__.__subWrapper0.getSubscription(this), __seg__, __ctx1__, out __msgEnv__))
return Microsoft.XLANGs.Core.StopConditions.Blocked;
if (__ctx1__.__msgIN != null)
__ctx1__.UnrefMessage(__ctx1__.__msgIN);
__ctx1__.__msgIN = new __messagetype_HT1_MQ_SchIN("msgIN", __ctx1__);
__ctx1__.RefMessage(__ctx1__.__msgIN);
HT1_MQ_REC.ReceiveMessage(0, __msgEnv__, __ctx1__.__msgIN, null, (Microsoft.XLANGs.Core.Context)_stateMgrs[1], __seg__);
if (HT1_MQ_REC != null)
{
HT1_MQ_REC.Close(__ctx1__, __seg__);
HT1_MQ_REC = null;
}
if ( !PostProgressInc( __seg__, __ctx__, 4 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 4;
case 4:
if ( !PreProgressInc( __seg__, __ctx__, 5 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
{
Microsoft.XLANGs.RuntimeTypes.EventData __edata = new Microsoft.XLANGs.RuntimeTypes.EventData(Microsoft.XLANGs.RuntimeTypes.Operation.End | Microsoft.XLANGs.RuntimeTypes.Operation.Receive);
__edata.Messages.Add(__ctx1__.__msgIN);
__edata.PortName = @"HT1_MQ_REC";
Tracker.FireEvent(__eventLocations[2],__edata,_stateMgrs[1].TrackDataStream );
}
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 5;
case 5:
__ctx1__.__varOrchName = "HT1_MQ";
if ( !PostProgressInc( __seg__, __ctx__, 6 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 6;
case 6:
if ( !PreProgressInc( __seg__, __ctx__, 7 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[4],__eventData[2],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 7;
case 7:
System.Diagnostics.EventLog.WriteEntry(__ctx1__.__varOrchName, "STARTED..", System.Diagnostics.EventLogEntryType.SuccessAudit);
if ( !PostProgressInc( __seg__, __ctx__, 8 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 8;
case 8:
if ( !PreProgressInc( __seg__, __ctx__, 9 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[5],__eventData[3],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 9;
case 9:
if ( !PreProgressInc( __seg__, __ctx__, 10 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[6],__eventData[4],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 10;
case 10:
{
__messagetype_HT1_MQ_SchOUT __msgOUT = new __messagetype_HT1_MQ_SchOUT("msgOUT", __ctx1__);
ApplyTransform(typeof(HT1_MQ.MapIndToGrp), new object[] {__msgOUT.part}, new object[] {__ctx1__.__msgIN.part});
if (__ctx1__.__msgOUT != null)
__ctx1__.UnrefMessage(__ctx1__.__msgOUT);
__ctx1__.__msgOUT = __msgOUT;
__ctx1__.RefMessage(__ctx1__.__msgOUT);
}
__ctx1__.__msgOUT.ConstructionCompleteEvent(true);
if ( !PostProgressInc( __seg__, __ctx__, 11 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 11;
case 11:
if ( !PreProgressInc( __seg__, __ctx__, 12 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
{
Microsoft.XLANGs.RuntimeTypes.EventData __edata = new Microsoft.XLANGs.RuntimeTypes.EventData(Microsoft.XLANGs.RuntimeTypes.Operation.End | Microsoft.XLANGs.RuntimeTypes.Operation.Construct);
__edata.Messages.Add(__ctx1__.__msgOUT);
__edata.Messages.Add(__ctx1__.__msgIN);
Tracker.FireEvent(__eventLocations[7],__edata,_stateMgrs[1].TrackDataStream );
}
if (__ctx1__ != null && __ctx1__.__msgIN != null)
{
__ctx1__.UnrefMessage(__ctx1__.__msgIN);
__ctx1__.__msgIN = null;
}
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 12;
case 12:
if ( !PreProgressInc( __seg__, __ctx__, 13 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[8],__eventData[2],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 13;
case 13:
System.Diagnostics.EventLog.WriteEntry(__ctx1__.__varOrchName, "FINISHED.", System.Diagnostics.EventLogEntryType.SuccessAudit);
if (__ctx1__ != null)
__ctx1__.__varOrchName = null;
if ( !PostProgressInc( __seg__, __ctx__, 14 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 14;
case 14:
if ( !PreProgressInc( __seg__, __ctx__, 15 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[9],__eventData[3],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 15;
case 15:
if ( !PreProgressInc( __seg__, __ctx__, 16 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[10],__eventData[5],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 16;
case 16:
if (!__ctx1__.PrepareToPendingCommit(__seg__))
return Microsoft.XLANGs.Core.StopConditions.Blocked;
if ( !PostProgressInc( __seg__, __ctx__, 17 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 17;
case 17:
if ( !PreProgressInc( __seg__, __ctx__, 18 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
HT1_MQ_SEN.SendMessage(0, __ctx1__.__msgOUT, null, null, __ctx1__, __seg__ , Microsoft.XLANGs.Core.ActivityFlags.NextActivityPersists );
if (HT1_MQ_SEN != null)
{
HT1_MQ_SEN.Close(__ctx1__, __seg__);
HT1_MQ_SEN = null;
}
if ((stopOn & Microsoft.XLANGs.Core.StopConditions.OutgoingRqst) != 0)
return Microsoft.XLANGs.Core.StopConditions.OutgoingRqst;
goto case 18;
case 18:
if ( !PreProgressInc( __seg__, __ctx__, 19 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
{
Microsoft.XLANGs.RuntimeTypes.EventData __edata = new Microsoft.XLANGs.RuntimeTypes.EventData(Microsoft.XLANGs.RuntimeTypes.Operation.End | Microsoft.XLANGs.RuntimeTypes.Operation.Send);
__edata.Messages.Add(__ctx1__.__msgOUT);
__edata.PortName = @"HT1_MQ_SEN";
Tracker.FireEvent(__eventLocations[11],__edata,_stateMgrs[1].TrackDataStream );
}
if (__ctx1__ != null && __ctx1__.__msgOUT != null)
{
__ctx1__.UnrefMessage(__ctx1__.__msgOUT);
__ctx1__.__msgOUT = null;
}
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 19;
case 19:
if ( !PreProgressInc( __seg__, __ctx__, 20 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
Tracker.FireEvent(__eventLocations[3],__eventData[6],_stateMgrs[1].TrackDataStream );
if (IsDebugged)
return Microsoft.XLANGs.Core.StopConditions.InBreakpoint;
goto case 20;
case 20:
if (!__ctx1__.CleanupAndPrepareToCommit(__seg__))
return Microsoft.XLANGs.Core.StopConditions.Blocked;
if ( !PostProgressInc( __seg__, __ctx__, 21 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
goto case 21;
case 21:
if ( !PreProgressInc( __seg__, __ctx__, 22 ) )
return Microsoft.XLANGs.Core.StopConditions.Paused;
__ctx1__.OnCommit();
goto case 22;
case 22:
__seg__.SegmentDone();
_segments[0].PredecessorDone(this);
break;
}
return Microsoft.XLANGs.Core.StopConditions.Completed;
}
}
[System.SerializableAttribute]
sealed public class __HT1_MQ_SchIN__ : Microsoft.XLANGs.Core.XSDPart
{
private static HT1_MQ.SchIN _schema = new HT1_MQ.SchIN();
public __HT1_MQ_SchIN__(Microsoft.XLANGs.Core.XMessage msg, string name, int index) : base(msg, name, index) { }
#region part reflection support
public static Microsoft.XLANGs.BaseTypes.SchemaBase PartSchema { get { return (Microsoft.XLANGs.BaseTypes.SchemaBase)_schema; } }
#endregion // part reflection support
}
[Microsoft.XLANGs.BaseTypes.MessageTypeAttribute(
Microsoft.XLANGs.BaseTypes.EXLangSAccess.ePublic,
Microsoft.XLANGs.BaseTypes.EXLangSMessageInfo.eThirdKind,
"HT1_MQ.SchIN",
new System.Type[]{
typeof(HT1_MQ.SchIN)
},
new string[]{
"part"
},
new System.Type[]{
typeof(__HT1_MQ_SchIN__)
},
0,
@"http://HT1_MQ.SchIN#Ind"
)]
[System.SerializableAttribute]
sealed public class __messagetype_HT1_MQ_SchIN : Microsoft.BizTalk.XLANGs.BTXEngine.BTXMessage
{
public __HT1_MQ_SchIN__ part;
private void __CreatePartWrappers()
{
part = new __HT1_MQ_SchIN__(this, "part", 0);
this.AddPart("part", 0, part);
}
public __messagetype_HT1_MQ_SchIN(string msgName, Microsoft.XLANGs.Core.Context ctx) : base(msgName, ctx)
{
__CreatePartWrappers();
}
}
[System.SerializableAttribute]
sealed public class __HT1_MQ_SchOUT__ : Microsoft.XLANGs.Core.XSDPart
{
private static HT1_MQ.SchOUT _schema = new HT1_MQ.SchOUT();
public __HT1_MQ_SchOUT__(Microsoft.XLANGs.Core.XMessage msg, string name, int index) : base(msg, name, index) { }
#region part reflection support
public static Microsoft.XLANGs.BaseTypes.SchemaBase PartSchema { get { return (Microsoft.XLANGs.BaseTypes.SchemaBase)_schema; } }
#endregion // part reflection support
}
[Microsoft.XLANGs.BaseTypes.MessageTypeAttribute(
Microsoft.XLANGs.BaseTypes.EXLangSAccess.ePublic,
Microsoft.XLANGs.BaseTypes.EXLangSMessageInfo.eThirdKind,
"HT1_MQ.SchOUT",
new System.Type[]{
typeof(HT1_MQ.SchOUT)
},
new string[]{
"part"
},
new System.Type[]{
typeof(__HT1_MQ_SchOUT__)
},
0,
@"http://HT1_MQ.SchOUT#Member"
)]
[System.SerializableAttribute]
sealed public class __messagetype_HT1_MQ_SchOUT : Microsoft.BizTalk.XLANGs.BTXEngine.BTXMessage
{
public __HT1_MQ_SchOUT__ part;
private void __CreatePartWrappers()
{
part = new __HT1_MQ_SchOUT__(this, "part", 0);
this.AddPart("part", 0, part);
}
public __messagetype_HT1_MQ_SchOUT(string msgName, Microsoft.XLANGs.Core.Context ctx) : base(msgName, ctx)
{
__CreatePartWrappers();
}
}
[Microsoft.XLANGs.BaseTypes.BPELExportableAttribute(false)]
sealed public class _MODULE_PROXY_ { }
}