add jms
This commit is contained in:
wojciech
7
LocalResources/.folder
Normal file
7
LocalResources/.folder
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<Repository:repository xmlns:Repository="http://www.tibco.com/xmlns/repo/types/2002">
|
||||||
|
<folder resourceType="ae.designerfolder" name="LocalResources" propLocks="" allowUserToChangeIcon="false" sortContents="false" acceptsResources="true" allowDuplicates="false">
|
||||||
|
<description/>
|
||||||
|
<fixedChildren/>
|
||||||
|
</folder>
|
||||||
|
</Repository:repository>
|
||||||
24
LocalResources/alternativeQueue.sharedjmscon
Normal file
24
LocalResources/alternativeQueue.sharedjmscon
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<BWSharedResource>
|
||||||
|
<name>alternativeQueue</name>
|
||||||
|
<resourceType>ae.shared.JMSConnectionKey</resourceType>
|
||||||
|
<config>
|
||||||
|
<NamingEnvironment>
|
||||||
|
<UseJNDI>true</UseJNDI>
|
||||||
|
<ProviderURL>tcp://localhost:7222</ProviderURL>
|
||||||
|
<NamingURL>tibjmsnaming://localhost:7222</NamingURL>
|
||||||
|
<NamingInitialContextFactory>com.tibco.tibjms.naming.TibjmsInitialContextFactory</NamingInitialContextFactory>
|
||||||
|
<TopicFactoryName>TopicConnectionFactory</TopicFactoryName>
|
||||||
|
<QueueFactoryName>QueueConnectionFactory</QueueFactoryName>
|
||||||
|
<NamingPrincipal>admin</NamingPrincipal>
|
||||||
|
<NamingCredential/>
|
||||||
|
</NamingEnvironment>
|
||||||
|
<ConnectionAttributes>
|
||||||
|
<username/>
|
||||||
|
<password/>
|
||||||
|
<clientID/>
|
||||||
|
<autoGenClientID>true</autoGenClientID>
|
||||||
|
</ConnectionAttributes>
|
||||||
|
<UseXACF>false</UseXACF>
|
||||||
|
</config>
|
||||||
|
</BWSharedResource>
|
||||||
24
LocalResources/alternativeTopic.sharedjmscon
Normal file
24
LocalResources/alternativeTopic.sharedjmscon
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<BWSharedResource>
|
||||||
|
<name>alternativeTopic</name>
|
||||||
|
<resourceType>ae.shared.JMSConnectionKey</resourceType>
|
||||||
|
<config>
|
||||||
|
<NamingEnvironment>
|
||||||
|
<UseJNDI>true</UseJNDI>
|
||||||
|
<ProviderURL>tcp://localhost:7222</ProviderURL>
|
||||||
|
<NamingURL>tibjmsnaming://localhost:7222</NamingURL>
|
||||||
|
<NamingInitialContextFactory>com.tibco.tibjms.naming.TibjmsInitialContextFactory</NamingInitialContextFactory>
|
||||||
|
<TopicFactoryName>TopicConnectionFactory</TopicFactoryName>
|
||||||
|
<QueueFactoryName>QueueConnectionFactory</QueueFactoryName>
|
||||||
|
<NamingPrincipal>admin</NamingPrincipal>
|
||||||
|
<NamingCredential/>
|
||||||
|
</NamingEnvironment>
|
||||||
|
<ConnectionAttributes>
|
||||||
|
<username/>
|
||||||
|
<password/>
|
||||||
|
<clientID/>
|
||||||
|
<autoGenClientID>true</autoGenClientID>
|
||||||
|
</ConnectionAttributes>
|
||||||
|
<UseXACF>false</UseXACF>
|
||||||
|
</config>
|
||||||
|
</BWSharedResource>
|
||||||
24
LocalResources/server.delete.sharedjmscon
Normal file
24
LocalResources/server.delete.sharedjmscon
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<BWSharedResource>
|
||||||
|
<name>server.delete</name>
|
||||||
|
<resourceType>ae.shared.JMSConnectionKey</resourceType>
|
||||||
|
<config>
|
||||||
|
<NamingEnvironment>
|
||||||
|
<UseJNDI>true</UseJNDI>
|
||||||
|
<ProviderURL>tcp://localhost:7222</ProviderURL>
|
||||||
|
<NamingURL>tibjmsnaming://localhost:7222</NamingURL>
|
||||||
|
<NamingInitialContextFactory>com.tibco.tibjms.naming.TibjmsInitialContextFactory</NamingInitialContextFactory>
|
||||||
|
<TopicFactoryName>TopicConnectionFactory</TopicFactoryName>
|
||||||
|
<QueueFactoryName>QueueConnectionFactory</QueueFactoryName>
|
||||||
|
<NamingPrincipal>server.delete</NamingPrincipal>
|
||||||
|
<NamingCredential/>
|
||||||
|
</NamingEnvironment>
|
||||||
|
<ConnectionAttributes>
|
||||||
|
<username/>
|
||||||
|
<password/>
|
||||||
|
<clientID/>
|
||||||
|
<autoGenClientID>true</autoGenClientID>
|
||||||
|
</ConnectionAttributes>
|
||||||
|
<UseXACF>false</UseXACF>
|
||||||
|
</config>
|
||||||
|
</BWSharedResource>
|
||||||
24
LocalResources/server.get.sharedjmscon
Normal file
24
LocalResources/server.get.sharedjmscon
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<BWSharedResource>
|
||||||
|
<name>server.get</name>
|
||||||
|
<resourceType>ae.shared.JMSConnectionKey</resourceType>
|
||||||
|
<config>
|
||||||
|
<NamingEnvironment>
|
||||||
|
<UseJNDI>true</UseJNDI>
|
||||||
|
<ProviderURL>tcp://localhost:7222</ProviderURL>
|
||||||
|
<NamingURL>tibjmsnaming://localhost:7222</NamingURL>
|
||||||
|
<NamingInitialContextFactory>com.tibco.tibjms.naming.TibjmsInitialContextFactory</NamingInitialContextFactory>
|
||||||
|
<TopicFactoryName>TopicConnectionFactory</TopicFactoryName>
|
||||||
|
<QueueFactoryName>QueueConnectionFactory</QueueFactoryName>
|
||||||
|
<NamingPrincipal>server.get</NamingPrincipal>
|
||||||
|
<NamingCredential/>
|
||||||
|
</NamingEnvironment>
|
||||||
|
<ConnectionAttributes>
|
||||||
|
<username/>
|
||||||
|
<password/>
|
||||||
|
<clientID/>
|
||||||
|
<autoGenClientID>true</autoGenClientID>
|
||||||
|
</ConnectionAttributes>
|
||||||
|
<UseXACF>false</UseXACF>
|
||||||
|
</config>
|
||||||
|
</BWSharedResource>
|
||||||
24
LocalResources/server.post.sharedjmscon
Normal file
24
LocalResources/server.post.sharedjmscon
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<BWSharedResource>
|
||||||
|
<name>server.post</name>
|
||||||
|
<resourceType>ae.shared.JMSConnectionKey</resourceType>
|
||||||
|
<config>
|
||||||
|
<NamingEnvironment>
|
||||||
|
<UseJNDI>true</UseJNDI>
|
||||||
|
<ProviderURL>tcp://localhost:7222</ProviderURL>
|
||||||
|
<NamingURL>tibjmsnaming://localhost:7222</NamingURL>
|
||||||
|
<NamingInitialContextFactory>com.tibco.tibjms.naming.TibjmsInitialContextFactory</NamingInitialContextFactory>
|
||||||
|
<TopicFactoryName>TopicConnectionFactory</TopicFactoryName>
|
||||||
|
<QueueFactoryName>QueueConnectionFactory</QueueFactoryName>
|
||||||
|
<NamingPrincipal>server.post</NamingPrincipal>
|
||||||
|
<NamingCredential/>
|
||||||
|
</NamingEnvironment>
|
||||||
|
<ConnectionAttributes>
|
||||||
|
<username/>
|
||||||
|
<password/>
|
||||||
|
<clientID/>
|
||||||
|
<autoGenClientID>true</autoGenClientID>
|
||||||
|
</ConnectionAttributes>
|
||||||
|
<UseXACF>false</UseXACF>
|
||||||
|
</config>
|
||||||
|
</BWSharedResource>
|
||||||
24
LocalResources/server.put.sharedjmscon
Normal file
24
LocalResources/server.put.sharedjmscon
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<BWSharedResource>
|
||||||
|
<name>server.put</name>
|
||||||
|
<resourceType>ae.shared.JMSConnectionKey</resourceType>
|
||||||
|
<config>
|
||||||
|
<NamingEnvironment>
|
||||||
|
<UseJNDI>true</UseJNDI>
|
||||||
|
<ProviderURL>tcp://localhost:7222</ProviderURL>
|
||||||
|
<NamingURL>tibjmsnaming://localhost:7222</NamingURL>
|
||||||
|
<NamingInitialContextFactory>com.tibco.tibjms.naming.TibjmsInitialContextFactory</NamingInitialContextFactory>
|
||||||
|
<TopicFactoryName>TopicConnectionFactory</TopicFactoryName>
|
||||||
|
<QueueFactoryName>QueueConnectionFactory</QueueFactoryName>
|
||||||
|
<NamingPrincipal>server.put</NamingPrincipal>
|
||||||
|
<NamingCredential/>
|
||||||
|
</NamingEnvironment>
|
||||||
|
<ConnectionAttributes>
|
||||||
|
<username/>
|
||||||
|
<password/>
|
||||||
|
<clientID/>
|
||||||
|
<autoGenClientID>true</autoGenClientID>
|
||||||
|
</ConnectionAttributes>
|
||||||
|
<UseXACF>false</UseXACF>
|
||||||
|
</config>
|
||||||
|
</BWSharedResource>
|
||||||
7
Processes/jms/.folder
Normal file
7
Processes/jms/.folder
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<Repository:repository xmlns:Repository="http://www.tibco.com/xmlns/repo/types/2002">
|
||||||
|
<folder resourceType="ae.designerfolder" name="jms" propLocks="" allowUserToChangeIcon="false" sortContents="false" acceptsResources="true" allowDuplicates="false">
|
||||||
|
<description/>
|
||||||
|
<fixedChildren/>
|
||||||
|
</folder>
|
||||||
|
</Repository:repository>
|
||||||
219
Processes/jms/JmsDelete.process
Normal file
219
Processes/jms/JmsDelete.process
Normal file
@@ -0,0 +1,219 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<pd:ProcessDefinition xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:pfx="http://www.demo.com/author" xmlns:pd="http://xmlns.tibco.com/bw/process/2003" xmlns:pfx2="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" xmlns:ns="http://www.tibco.com/namespaces/tnt/plugins/jms" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:ns1="http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2">
|
||||||
|
<xsd:import namespace="http://www.demo.com/author" schemaLocation="/Resources/schemas/author.xsd"/>
|
||||||
|
<xsd:import namespace="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" schemaLocation="/Resources/JmsErrorSchema/JmsStatusResponse.xsd"/>
|
||||||
|
<pd:name>Processes/jms/JmsDelete.process</pd:name>
|
||||||
|
<pd:startName>JMS Topic Subscriber</pd:startName>
|
||||||
|
<pd:startX>0</pd:startX>
|
||||||
|
<pd:startY>0</pd:startY>
|
||||||
|
<pd:returnBindings/>
|
||||||
|
<pd:starter name="JMS Topic Subscriber">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSTopicEventSource</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSTopicEventSource</pd:resourceType>
|
||||||
|
<pd:x>142</pd:x>
|
||||||
|
<pd:y>74</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>deleteRequest</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<ConnectionReference>/LocalResources/server.delete.sharedjmscon</ConnectionReference>
|
||||||
|
<OutDataxsdString>
|
||||||
|
<xsd:element name="root">
|
||||||
|
<xsd:complexType>
|
||||||
|
<xsd:sequence>
|
||||||
|
<xsd:element ref="pfx:author" minOccurs="0"/>
|
||||||
|
<xsd:element name="id" type="xsd:int"/>
|
||||||
|
</xsd:sequence>
|
||||||
|
</xsd:complexType>
|
||||||
|
</xsd:element>
|
||||||
|
</OutDataxsdString>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings/>
|
||||||
|
</pd:starter>
|
||||||
|
<pd:endName>End</pd:endName>
|
||||||
|
<pd:endX>614</pd:endX>
|
||||||
|
<pd:endY>67</pd:endY>
|
||||||
|
<pd:errorSchemas>
|
||||||
|
<DeleteError/>
|
||||||
|
</pd:errorSchemas>
|
||||||
|
<pd:processVariables/>
|
||||||
|
<pd:targetNamespace>http://xmlns.example.com/1724069617580</pd:targetNamespace>
|
||||||
|
<pd:activity name="Catch">
|
||||||
|
<pd:type>com.tibco.pe.core.CatchActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.catch</pd:resourceType>
|
||||||
|
<pd:x>307</pd:x>
|
||||||
|
<pd:y>221</pd:y>
|
||||||
|
<pd:handler>true</pd:handler>
|
||||||
|
<config>
|
||||||
|
<fault>localname=root namespace=http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2</fault>
|
||||||
|
</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>
|
||||||
|
<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>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<DeliveryDelay>0</DeliveryDelay>
|
||||||
|
<ConnectionReference>/LocalResources/server.post.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>
|
||||||
|
<Body>
|
||||||
|
<root>
|
||||||
|
<pfx2:response>
|
||||||
|
<pfx2:status>
|
||||||
|
<xsl:value-of select="$Catch/ns1:root/ns1:error"/>
|
||||||
|
</pfx2:status>
|
||||||
|
<pfx2:isError>
|
||||||
|
<xsl:value-of select="true()"/>
|
||||||
|
</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="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/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/sql/author/SqlDELETE.process</processName>
|
||||||
|
</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>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SqlDELETE</pd:from>
|
||||||
|
<pd:to>SendResponse</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:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>Catch</pd:from>
|
||||||
|
<pd:to>SendErrorResponse</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:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
</pd:ProcessDefinition>
|
||||||
218
Processes/jms/JmsGet.process
Normal file
218
Processes/jms/JmsGet.process
Normal file
@@ -0,0 +1,218 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<pd:ProcessDefinition xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:pfx="http://www.demo.com/author" xmlns:pd="http://xmlns.tibco.com/bw/process/2003" xmlns:pfx2="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" xmlns:ns="http://www.tibco.com/namespaces/tnt/plugins/jms" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:ns1="http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2">
|
||||||
|
<xsd:import namespace="http://www.demo.com/author" schemaLocation="/Resources/schemas/author.xsd"/>
|
||||||
|
<xsd:import namespace="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" schemaLocation="/Resources/JmsErrorSchema/JmsStatusResponse.xsd"/>
|
||||||
|
<pd:name>Processes/jms/JmsGet.process</pd:name>
|
||||||
|
<pd:startName>JMS Queue Receiver</pd:startName>
|
||||||
|
<pd:startX>0</pd:startX>
|
||||||
|
<pd:startY>0</pd:startY>
|
||||||
|
<pd:returnBindings/>
|
||||||
|
<pd:starter name="JMS Queue Receiver">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSQueueEventSource</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSQueueEventSource</pd:resourceType>
|
||||||
|
<pd:x>113</pd:x>
|
||||||
|
<pd:y>70</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>putRequest</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<ConnectionReference>/LocalResources/server.get.sharedjmscon</ConnectionReference>
|
||||||
|
<OutDataxsdString>
|
||||||
|
<xsd:element name="root">
|
||||||
|
<xsd:complexType>
|
||||||
|
<xsd:sequence>
|
||||||
|
<xsd:element ref="pfx:author" minOccurs="0"/>
|
||||||
|
<xsd:element name="id" type="xsd:int"/>
|
||||||
|
</xsd:sequence>
|
||||||
|
</xsd:complexType>
|
||||||
|
</xsd:element>
|
||||||
|
</OutDataxsdString>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings/>
|
||||||
|
</pd:starter>
|
||||||
|
<pd:endName>End</pd:endName>
|
||||||
|
<pd:endX>536</pd:endX>
|
||||||
|
<pd:endY>70</pd:endY>
|
||||||
|
<pd:errorSchemas/>
|
||||||
|
<pd:processVariables/>
|
||||||
|
<pd:targetNamespace>http://xmlns.example.com/1724069617580</pd:targetNamespace>
|
||||||
|
<pd:activity name="Catch">
|
||||||
|
<pd:type>com.tibco.pe.core.CatchActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.catch</pd:resourceType>
|
||||||
|
<pd:x>269</pd:x>
|
||||||
|
<pd:y>203</pd:y>
|
||||||
|
<pd:handler>true</pd:handler>
|
||||||
|
<config>
|
||||||
|
<fault>localname=root namespace=http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2</fault>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings/>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SendResponse">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSQueueSendActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSQueueSendActivity</pd:resourceType>
|
||||||
|
<pd:x>403</pd:x>
|
||||||
|
<pd:y>70</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>getResponse</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<DeliveryDelay>0</DeliveryDelay>
|
||||||
|
<ConnectionReference>/LocalResources/server.get.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-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSReplyTo">
|
||||||
|
<destinationQueue>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSReplyTo"/>
|
||||||
|
</destinationQueue>
|
||||||
|
</xsl:if>
|
||||||
|
<Body>
|
||||||
|
<root>
|
||||||
|
<xsl:copy-of select="$SqlGET/root/pfx:author"/>
|
||||||
|
<pfx2:response>
|
||||||
|
<pfx2:status>
|
||||||
|
<xsl:value-of select="$SqlGET/root/status"/>
|
||||||
|
</pfx2:status>
|
||||||
|
<pfx2:isError>
|
||||||
|
<xsl:value-of select="false()"/>
|
||||||
|
</pfx2:isError>
|
||||||
|
<pfx2:correlationID>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
|
||||||
|
</pfx2:correlationID>
|
||||||
|
</pfx2:response>
|
||||||
|
</root>
|
||||||
|
</Body>
|
||||||
|
</ns:ActivityInput>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SendeErrorResponse">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSQueueSendActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSQueueSendActivity</pd:resourceType>
|
||||||
|
<pd:x>403</pd:x>
|
||||||
|
<pd:y>201</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>getResponse</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<DeliveryDelay>0</DeliveryDelay>
|
||||||
|
<ConnectionReference>/LocalResources/server.get.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>
|
||||||
|
<Body>
|
||||||
|
<root>
|
||||||
|
<pfx2:response>
|
||||||
|
<pfx2:status>
|
||||||
|
<xsl:value-of select="$Catch/ns1:root/ns1:error"/>
|
||||||
|
</pfx2:status>
|
||||||
|
<pfx2:isError>
|
||||||
|
<xsl:value-of select="true()"/>
|
||||||
|
</pfx2:isError>
|
||||||
|
<pfx2:correlationID>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
|
||||||
|
</pfx2:correlationID>
|
||||||
|
</pfx2:response>
|
||||||
|
</root>
|
||||||
|
</Body>
|
||||||
|
</ns:ActivityInput>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SqlGET">
|
||||||
|
<pd:type>com.tibco.pe.core.CallProcessActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.process.subprocess</pd:resourceType>
|
||||||
|
<pd:x>269</pd:x>
|
||||||
|
<pd:y>70</pd:y>
|
||||||
|
<config>
|
||||||
|
<processName>/Processes/sql/author/SqlGET.process</processName>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings>
|
||||||
|
<root>
|
||||||
|
<id>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/Body/root/id"/>
|
||||||
|
</id>
|
||||||
|
</root>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>JMS Queue Receiver</pd:from>
|
||||||
|
<pd:to>SqlGET</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SqlGET</pd:from>
|
||||||
|
<pd:to>SendResponse</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:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>Catch</pd:from>
|
||||||
|
<pd:to>SendeErrorResponse</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SendeErrorResponse</pd:from>
|
||||||
|
<pd:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
</pd:ProcessDefinition>
|
||||||
215
Processes/jms/JmsPost.process
Normal file
215
Processes/jms/JmsPost.process
Normal file
@@ -0,0 +1,215 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<pd:ProcessDefinition xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:pfx="http://www.demo.com/author" xmlns:pd="http://xmlns.tibco.com/bw/process/2003" xmlns:pfx2="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" xmlns:ns="http://www.tibco.com/namespaces/tnt/plugins/jms" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:ns1="http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2">
|
||||||
|
<xsd:import namespace="http://www.demo.com/author" schemaLocation="/Resources/schemas/author.xsd"/>
|
||||||
|
<xsd:import namespace="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" schemaLocation="/Resources/JmsErrorSchema/JmsStatusResponse.xsd"/>
|
||||||
|
<pd:name>Processes/jms/JmsPost.process</pd:name>
|
||||||
|
<pd:startName>JMS Topic Subscriber</pd:startName>
|
||||||
|
<pd:startX>0</pd:startX>
|
||||||
|
<pd:startY>0</pd:startY>
|
||||||
|
<pd:returnBindings/>
|
||||||
|
<pd:starter name="JMS Topic Subscriber">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSTopicEventSource</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSTopicEventSource</pd:resourceType>
|
||||||
|
<pd:x>72</pd:x>
|
||||||
|
<pd:y>71</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>postRequest</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<ConnectionReference>/LocalResources/server.post.sharedjmscon</ConnectionReference>
|
||||||
|
<OutDataxsdString>
|
||||||
|
<xsd:element name="root">
|
||||||
|
<xsd:complexType>
|
||||||
|
<xsd:sequence>
|
||||||
|
<xsd:element ref="pfx:author" minOccurs="0"/>
|
||||||
|
<xsd:element name="id" type="xsd:int"/>
|
||||||
|
</xsd:sequence>
|
||||||
|
</xsd:complexType>
|
||||||
|
</xsd:element>
|
||||||
|
</OutDataxsdString>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings/>
|
||||||
|
</pd:starter>
|
||||||
|
<pd:endName>End</pd:endName>
|
||||||
|
<pd:endX>546</pd:endX>
|
||||||
|
<pd:endY>64</pd:endY>
|
||||||
|
<pd:errorSchemas/>
|
||||||
|
<pd:processVariables/>
|
||||||
|
<pd:targetNamespace>http://xmlns.example.com/1724069617580</pd:targetNamespace>
|
||||||
|
<pd:activity name="Catch">
|
||||||
|
<pd:type>com.tibco.pe.core.CatchActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.catch</pd:resourceType>
|
||||||
|
<pd:x>243</pd:x>
|
||||||
|
<pd:y>240</pd:y>
|
||||||
|
<pd:handler>true</pd:handler>
|
||||||
|
<config>
|
||||||
|
<fault>localname=root namespace=http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2</fault>
|
||||||
|
</config>
|
||||||
|
<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>398</pd:x>
|
||||||
|
<pd:y>64</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/server.post.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="$SqlPOST/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="SqlPOST">
|
||||||
|
<pd:type>com.tibco.pe.core.CallProcessActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.process.subprocess</pd:resourceType>
|
||||||
|
<pd:x>243</pd:x>
|
||||||
|
<pd:y>64</pd:y>
|
||||||
|
<config>
|
||||||
|
<processName>/Processes/sql/author/SqlPOST.process</processName>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings>
|
||||||
|
<root>
|
||||||
|
<xsl:copy-of select="$JMS-Topic-Subscriber/ns:ActivityOutput/Body/root/pfx:author"/>
|
||||||
|
</root>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SendResponse-1">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSTopicPublishActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSTopicPublishActivity</pd:resourceType>
|
||||||
|
<pd:x>411</pd:x>
|
||||||
|
<pd:y>239</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>postResponse</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<DeliveryDelay>0</DeliveryDelay>
|
||||||
|
<ConnectionReference>/LocalResources/server.post.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>
|
||||||
|
<Body>
|
||||||
|
<root>
|
||||||
|
<pfx2:response>
|
||||||
|
<pfx2:status>
|
||||||
|
<xsl:value-of select="$Catch/ns1:root/ns1:error"/>
|
||||||
|
</pfx2:status>
|
||||||
|
<pfx2:isError>
|
||||||
|
<xsl:value-of select="'true'"/>
|
||||||
|
</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:transition>
|
||||||
|
<pd:from>JMS Topic Subscriber</pd:from>
|
||||||
|
<pd:to>SqlPOST</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SqlPOST</pd:from>
|
||||||
|
<pd:to>SendResponse</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:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>Catch</pd:from>
|
||||||
|
<pd:to>SendResponse-1</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SendResponse-1</pd:from>
|
||||||
|
<pd:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
</pd:ProcessDefinition>
|
||||||
215
Processes/jms/JmsPut.process
Normal file
215
Processes/jms/JmsPut.process
Normal file
@@ -0,0 +1,215 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<pd:ProcessDefinition xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:pfx="http://www.demo.com/author" xmlns:pd="http://xmlns.tibco.com/bw/process/2003" xmlns:pfx2="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" xmlns:ns="http://www.tibco.com/namespaces/tnt/plugins/jms" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:ns1="http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2">
|
||||||
|
<xsd:import namespace="http://www.demo.com/author" schemaLocation="/Resources/schemas/author.xsd"/>
|
||||||
|
<xsd:import namespace="http://www.tibco.com/schemas/tibcoRepository/Resources/JmsErrorSchema/Schema.xsd" schemaLocation="/Resources/JmsErrorSchema/JmsStatusResponse.xsd"/>
|
||||||
|
<pd:name>Processes/jms/JmsPut.process</pd:name>
|
||||||
|
<pd:startName>JMS Queue Receiver</pd:startName>
|
||||||
|
<pd:startX>0</pd:startX>
|
||||||
|
<pd:startY>0</pd:startY>
|
||||||
|
<pd:returnBindings/>
|
||||||
|
<pd:starter name="JMS Queue Receiver">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSQueueEventSource</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSQueueEventSource</pd:resourceType>
|
||||||
|
<pd:x>124</pd:x>
|
||||||
|
<pd:y>65</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>putRequest</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<ConnectionReference>/LocalResources/server.put.sharedjmscon</ConnectionReference>
|
||||||
|
<OutDataxsdString>
|
||||||
|
<xsd:element name="root">
|
||||||
|
<xsd:complexType>
|
||||||
|
<xsd:sequence>
|
||||||
|
<xsd:element ref="pfx:author" minOccurs="0"/>
|
||||||
|
<xsd:element name="id" type="xsd:string"/>
|
||||||
|
</xsd:sequence>
|
||||||
|
</xsd:complexType>
|
||||||
|
</xsd:element>
|
||||||
|
</OutDataxsdString>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings/>
|
||||||
|
</pd:starter>
|
||||||
|
<pd:endName>End</pd:endName>
|
||||||
|
<pd:endX>570</pd:endX>
|
||||||
|
<pd:endY>65</pd:endY>
|
||||||
|
<pd:errorSchemas/>
|
||||||
|
<pd:processVariables/>
|
||||||
|
<pd:targetNamespace>http://xmlns.example.com/1724069617580</pd:targetNamespace>
|
||||||
|
<pd:activity name="Catch">
|
||||||
|
<pd:type>com.tibco.pe.core.CatchActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.catch</pd:resourceType>
|
||||||
|
<pd:x>279</pd:x>
|
||||||
|
<pd:y>225</pd:y>
|
||||||
|
<pd:handler>true</pd:handler>
|
||||||
|
<config>
|
||||||
|
<fault>localname=root namespace=http://www.tibco.com/schemas/httpRequest/Resources/schemas/Schema.xsd2</fault>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings/>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SendResponse">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSQueueSendActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSQueueSendActivity</pd:resourceType>
|
||||||
|
<pd:x>422</pd:x>
|
||||||
|
<pd:y>65</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/server.put.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-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSReplyTo">
|
||||||
|
<destinationQueue>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSReplyTo"/>
|
||||||
|
</destinationQueue>
|
||||||
|
</xsl:if>
|
||||||
|
<Body>
|
||||||
|
<root>
|
||||||
|
<pfx2:response>
|
||||||
|
<pfx2:status>
|
||||||
|
<xsl:value-of select="$SqlPUT/root/status"/>
|
||||||
|
</pfx2:status>
|
||||||
|
<pfx2:isError>
|
||||||
|
<xsl:value-of select="false()"/>
|
||||||
|
</pfx2:isError>
|
||||||
|
<pfx2:correlationID>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
|
||||||
|
</pfx2:correlationID>
|
||||||
|
</pfx2:response>
|
||||||
|
</root>
|
||||||
|
</Body>
|
||||||
|
</ns:ActivityInput>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SendeErrorResponse">
|
||||||
|
<pd:type>com.tibco.plugin.jms.JMSQueueSendActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.activities.JMSQueueSendActivity</pd:resourceType>
|
||||||
|
<pd:x>422</pd:x>
|
||||||
|
<pd:y>223</pd:y>
|
||||||
|
<config>
|
||||||
|
<PermittedMessageType>XML Text</PermittedMessageType>
|
||||||
|
<SessionAttributes>
|
||||||
|
<transacted>false</transacted>
|
||||||
|
<acknowledgeMode>1</acknowledgeMode>
|
||||||
|
<maxSessions>1</maxSessions>
|
||||||
|
<destination>putResponse</destination>
|
||||||
|
</SessionAttributes>
|
||||||
|
<ConfigurableHeaders>
|
||||||
|
<JMSDeliveryMode>PERSISTENT</JMSDeliveryMode>
|
||||||
|
<JMSExpiration>0</JMSExpiration>
|
||||||
|
<JMSPriority>4</JMSPriority>
|
||||||
|
</ConfigurableHeaders>
|
||||||
|
<DeliveryDelay>0</DeliveryDelay>
|
||||||
|
<ConnectionReference>/LocalResources/server.get.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>
|
||||||
|
<Body>
|
||||||
|
<root>
|
||||||
|
<pfx2:response>
|
||||||
|
<pfx2:status>
|
||||||
|
<xsl:value-of select="$Catch/ns1:root/ns1:error"/>
|
||||||
|
</pfx2:status>
|
||||||
|
<pfx2:isError>
|
||||||
|
<xsl:value-of select="true()"/>
|
||||||
|
</pfx2:isError>
|
||||||
|
<pfx2:correlationID>
|
||||||
|
<xsl:value-of select="$JMS-Queue-Receiver/ns:ActivityOutput/JMSHeaders/ns:JMSMessageID"/>
|
||||||
|
</pfx2:correlationID>
|
||||||
|
</pfx2:response>
|
||||||
|
</root>
|
||||||
|
</Body>
|
||||||
|
</ns:ActivityInput>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:activity name="SqlPUT">
|
||||||
|
<pd:type>com.tibco.pe.core.CallProcessActivity</pd:type>
|
||||||
|
<pd:resourceType>ae.process.subprocess</pd:resourceType>
|
||||||
|
<pd:x>279</pd:x>
|
||||||
|
<pd:y>65</pd:y>
|
||||||
|
<config>
|
||||||
|
<processName>/Processes/sql/author/SqlPUT.process</processName>
|
||||||
|
</config>
|
||||||
|
<pd:inputBindings>
|
||||||
|
<root>
|
||||||
|
<xsl:copy-of select="$JMS-Queue-Receiver/ns:ActivityOutput/Body/root/pfx:author"/>
|
||||||
|
</root>
|
||||||
|
</pd:inputBindings>
|
||||||
|
</pd:activity>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>JMS Queue Receiver</pd:from>
|
||||||
|
<pd:to>SqlPUT</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SqlPUT</pd:from>
|
||||||
|
<pd:to>SendResponse</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:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>Catch</pd:from>
|
||||||
|
<pd:to>SendeErrorResponse</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
<pd:transition>
|
||||||
|
<pd:from>SendeErrorResponse</pd:from>
|
||||||
|
<pd:to>End</pd:to>
|
||||||
|
<pd:lineType>Default</pd:lineType>
|
||||||
|
<pd:lineColor>-16777216</pd:lineColor>
|
||||||
|
<pd:conditionType>always</pd:conditionType>
|
||||||
|
</pd:transition>
|
||||||
|
</pd:ProcessDefinition>
|
||||||
Reference in New Issue
Block a user