Wednesday, 22 August 2018

patch bay info or ATG messaging info Dynamo Messaging


We have to change the following files for patch functionality or any asynchronous calls

1)atg\dynamo\messaging\dynamoMessagingSystem.xml
2)\atg\dynamo\messaging\SqlJmsProvider.properties

1)dynamoMessagingSystem.xml

We have to add the Source and sink code as part of this file. Generaaly the source code will be executed at frontend sources.
Sink will be executed at backend/AUX instances.


Sample Souce Code (Generally it will be part of front end servers/services code/module)

<?xml version="1.0" encoding="ISO-8859-1" ?>
<dynamo-message-system>
<patchbay>
<message-source>
<nucleus-name>/com/xxxpath/message/messageSource/XXXMessageSource</nucleus-name>
<output-port>
<port-name>XXXSourceYYY</port-name>
<output-destination>
<provider-name>sqldms</provider-name>
<destination-name>sqldms:/XXXXXQueue</destination-name>
<destination-type>Queue</destination-type>
</output-destination>
</output-port>
</message-source>

</patchbay>
</dynamo-message-system>


Sample Sink Code (Ideally the sink code will be part of the Backend/Aux instances)

<?xml version="1.0" encoding="ISO-8859-1" ?>
<dynamo-message-system>
<patchbay>
<message-sink>
<message-sink>
<nucleus-name>/com/xxx/message/messageSink/xxxMessageSink</nucleus-name>
<input-port>
<port-name>xxxSinkyyy</port-name>
<input-destination>
<provider-name>sqldms</provider-name>
<destination-name>sqldms:/aaaQueue</destination-name>
<destination-type>Queue</destination-type>
<redelivery>
<max-attempts>3</max-attempts>
<delay>60000</delay>
<failure-output-port>xxxError</failure-output-port>
</redelivery>
</input-destination>
</input-port>
<redelivery-port>
<port-name>xxxError</port-name>
<output-destination>
<provider-name>sqldms</provider-name>
<destination-name>sqldms:/xxxxErrorQueue</destination-name>
<destination-type>Queue</destination-type>
</output-destination>
</redelivery-port>
</message-sink>
</patchbay>
</dynamo-message-system>

(Need to add the destination name which mentioned in the dynamo messaging file in the  SqlJmsProvider.properties file)
2)SqlJmsProvider.properties   (in Sounce module)
requiredQueueNames+=\XXXXXQueue,\
                    \yyyQueue1   (some other destination name, not related to this )

  SqlJmsProvider.properties   (in sink module)
requiredQueueNames+=\aaaQueue,\
                    \xxxxErrorQueue

No comments:

Post a Comment