works with ouside queue

This commit is contained in:
wojciech
2024-09-05 10:48:53 +02:00
parent fcb24954ec
commit 56b0ab8e14
10 changed files with 257 additions and 258 deletions

View File

@@ -18,7 +18,7 @@
<transacted>false</transacted>
<acknowledgeMode>1</acknowledgeMode>
<maxSessions>1</maxSessions>
<destination>deleteRequest</destination>
<destination>deleteRequestWS</destination>
</SessionAttributes>
<ConfigurableHeaders>
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
@@ -40,7 +40,6 @@
<pd:inputBindings/>
</pd:starter>
<pd:endName>End</pd:endName>
<pd:endType/>
<pd:endX>614</pd:endX>
<pd:endY>67</pd:endY>
<pd:errorSchemas>
@@ -59,26 +58,92 @@
</config>
<pd:inputBindings/>
</pd:activity>
<pd:activity name="SendErrorResponse">
<pd:type>com.tibco.plugin.jms.JMSTopicPublishActivity</pd:type>
<pd:resourceType>ae.activities.JMSTopicPublishActivity</pd:resourceType>
<pd:x>476</pd:x>
<pd:y>221</pd:y>
<pd:activity name="SqlDELETE">
<pd:type>com.tibco.pe.core.CallProcessActivity</pd:type>
<pd:resourceType>ae.process.subprocess</pd:resourceType>
<pd:x>307</pd:x>
<pd:y>67</pd:y>
<config>
<processName>/Processes/xml/author/XmlDELETE.process</processName>
<processNameXPath>if ($_globalVariables/pfx3:GlobalVariables/processType='sql') then '/Processes/sql/author/SqlDELETE.process' else '/Processes/xml/author/XmlDELETE.process'</processNameXPath>
</config>
<pd:inputBindings>
<root>
<id>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/Body/root/id"/>
</id>
</root>
</pd:inputBindings>
</pd:activity>
<pd:activity name="Reply to JMS Message">
<pd:type>com.tibco.plugin.jms.JMSReplyActivity</pd:type>
<pd:resourceType>ae.activities.JMSReplyActivity</pd:resourceType>
<pd:x>456</pd:x>
<pd:y>71</pd:y>
<config>
<PermittedMessageType>XML Text</PermittedMessageType>
<SessionAttributes>
<transacted>false</transacted>
<acknowledgeMode>1</acknowledgeMode>
<maxSessions>1</maxSessions>
<destination>deleteResponse</destination>
</SessionAttributes>
<ConfigurableHeaders>
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
<JMSExpiration>0</JMSExpiration>
<JMSPriority>4</JMSPriority>
<EventSource>JMS Topic Subscriber</EventSource>
</ConfigurableHeaders>
<DeliveryDelay>0</DeliveryDelay>
<InDataxsdString>
<xsd:element name="root">
<xsd:complexType>
<xsd:sequence>
<xsd:element ref="pfx:author" minOccurs="0"/>
<xsd:element ref="pfx2:response"/>
</xsd:sequence>
</xsd:complexType>
</xsd:element>
</InDataxsdString>
</config>
<pd:inputBindings>
<ns:ActivityInput>
<Body>
<root>
<pfx2:response>
<pfx2:status>
<xsl:value-of select="$SqlDELETE/root/status"/>
</pfx2:status>
<pfx2:isError>
<xsl:value-of select="'false'"/>
</pfx2:isError>
<pfx2:correlationID>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
</pfx2:correlationID>
</pfx2:response>
</root>
</Body>
</ns:ActivityInput>
</pd:inputBindings>
</pd:activity>
<pd:activity name="Reply-to-JMS-Message-1">
<pd:type>com.tibco.plugin.jms.JMSReplyActivity</pd:type>
<pd:resourceType>ae.activities.JMSReplyActivity</pd:resourceType>
<pd:x>480</pd:x>
<pd:y>220</pd:y>
<config>
<PermittedMessageType>XML Text</PermittedMessageType>
<SessionAttributes>
<transacted>false</transacted>
<acknowledgeMode>1</acknowledgeMode>
<maxSessions>1</maxSessions>
</SessionAttributes>
<ConfigurableHeaders>
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
<JMSExpiration>0</JMSExpiration>
<JMSPriority>4</JMSPriority>
<EventSource>JMS Topic Subscriber</EventSource>
</ConfigurableHeaders>
<DeliveryDelay>0</DeliveryDelay>
<ConnectionReference>/LocalResources/jmsConnections/server.post.sharedjmscon</ConnectionReference>
<InDataxsdString>
<xsd:element name="root">
<xsd:complexType>
@@ -99,10 +164,10 @@
<xsl:value-of select="$Catch/xmlDeleteError/message"/>
</pfx2:status>
<pfx2:isError>
<xsl:value-of select="true()"/>
<xsl:value-of select="'true'"/>
</pfx2:isError>
<pfx2:correlationID>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/JMSHeaders/ns:JMSCorrelationID"/>
</pfx2:correlationID>
</pfx2:response>
</root>
@@ -110,79 +175,6 @@
</ns:ActivityInput>
</pd:inputBindings>
</pd:activity>
<pd:activity name="SendResponse">
<pd:type>com.tibco.plugin.jms.JMSTopicPublishActivity</pd:type>
<pd:resourceType>ae.activities.JMSTopicPublishActivity</pd:resourceType>
<pd:x>476</pd:x>
<pd:y>67</pd:y>
<config>
<PermittedMessageType>XML Text</PermittedMessageType>
<SessionAttributes>
<transacted>false</transacted>
<acknowledgeMode>1</acknowledgeMode>
<maxSessions>1</maxSessions>
<destination/>
</SessionAttributes>
<ConfigurableHeaders>
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
<JMSExpiration>0</JMSExpiration>
<JMSPriority>4</JMSPriority>
</ConfigurableHeaders>
<DeliveryDelay>0</DeliveryDelay>
<ConnectionReference>/LocalResources/jmsConnections/server.delete.sharedjmscon</ConnectionReference>
<InDataxsdString>
<xsd:element name="root">
<xsd:complexType>
<xsd:sequence>
<xsd:element ref="pfx:author" minOccurs="0"/>
<xsd:element ref="pfx2:response"/>
</xsd:sequence>
</xsd:complexType>
</xsd:element>
</InDataxsdString>
</config>
<pd:inputBindings>
<ns:ActivityInput>
<xsl:if test="$JMS-Topic-Subscriber/ns:ActivityOutput/JMSHeaders/ns:JMSReplyTo">
<destinationTopic>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/JMSHeaders/ns:JMSReplyTo"/>
</destinationTopic>
</xsl:if>
<Body>
<root>
<pfx2:response>
<pfx2:status>
<xsl:value-of select="$SqlDELETE/root/status"/>
</pfx2:status>
<pfx2:isError>
<xsl:value-of select="false()"/>
</pfx2:isError>
<pfx2:correlationID>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
</pfx2:correlationID>
</pfx2:response>
</root>
</Body>
</ns:ActivityInput>
</pd:inputBindings>
</pd:activity>
<pd:activity name="SqlDELETE">
<pd:type>com.tibco.pe.core.CallProcessActivity</pd:type>
<pd:resourceType>ae.process.subprocess</pd:resourceType>
<pd:x>307</pd:x>
<pd:y>67</pd:y>
<config>
<processName>/Processes/xml/author/XmlDELETE.process</processName>
<processNameXPath>if ($_globalVariables/pfx3:GlobalVariables/processType='sql') then '/Processes/sql/author/SqlDELETE.process' else '/Processes/xml/author/XmlDELETE.process'</processNameXPath>
</config>
<pd:inputBindings>
<root>
<id>
<xsl:value-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/Body/root/id"/>
</id>
</root>
</pd:inputBindings>
</pd:activity>
<pd:transition>
<pd:from>JMS Topic Subscriber</pd:from>
<pd:to>SqlDELETE</pd:to>
@@ -192,13 +184,13 @@
</pd:transition>
<pd:transition>
<pd:from>SqlDELETE</pd:from>
<pd:to>SendResponse</pd:to>
<pd:to>Reply to JMS Message</pd:to>
<pd:lineType>Default</pd:lineType>
<pd:lineColor>-16777216</pd:lineColor>
<pd:conditionType>always</pd:conditionType>
</pd:transition>
<pd:transition>
<pd:from>SendResponse</pd:from>
<pd:from>Reply to JMS Message</pd:from>
<pd:to>End</pd:to>
<pd:lineType>Default</pd:lineType>
<pd:lineColor>-16777216</pd:lineColor>
@@ -206,13 +198,13 @@
</pd:transition>
<pd:transition>
<pd:from>Catch</pd:from>
<pd:to>SendErrorResponse</pd:to>
<pd:to>Reply-to-JMS-Message-1</pd:to>
<pd:lineType>Default</pd:lineType>
<pd:lineColor>-16777216</pd:lineColor>
<pd:conditionType>always</pd:conditionType>
</pd:transition>
<pd:transition>
<pd:from>SendErrorResponse</pd:from>
<pd:from>Reply-to-JMS-Message-1</pd:from>
<pd:to>End</pd:to>
<pd:lineType>Default</pd:lineType>
<pd:lineColor>-16777216</pd:lineColor>