Page Comparison

Perform the following steps after creating the ActiveMQ connection to transfer messages to the ActiveMQ server using Canvas Sigma Studio:

1. Right-click the created ActiveMQ server connection and select the Create Data

   Source. Note:

   Source option.
   

   Note
   Refer Connectors - ActiveMQ for more information on creating an ActiveMQ connection.

   Image Removed

   
   Image Added
   
   The Create Request page appears.
   

   Image Removed

   
   Image Added
   
   

2. Enter a unique data source name in the Data Source Name field. In this example, ActiveMQ_DS is provided as the datasource data source name.
3. Enter the queue name in Queue Name field. Here, Transaction is provided as the queue name.
4. Select Receive Message as the message transfer type field.

5. Now, select an activity chain from the Activity Chain dropdown list, e.g. LIBRARY and select an action if required from the Current Action drop-down list, e.g.

   
   Image RemovedClick Save.
   

   SUBMIT.

   Note
   The available Activity Chain options are: LIBRARY, STUDIO_MAINT (STUDIO MAINTENANCE) and NEW_CONNECTION_SCREEN (NEW CONNECTION SCREEN), whereas the available Current Action options are: PREINIT (PREINITIALIZATION), SAVE_DRAFT (SAVE_DRAFT), SUBMIT and DELETE.

   
   Image Added
   
   

6. Click Save to save the ActiveMQ data source.
   
   Image Added
   
   A success message for creating the datasource data source appears as shown in the following screenshot:
   Image Removed
   Image Added
   
   

7. Click Ok.

   Note

   In order to trigger the ActiveMQ service connection, the CT platform's server-side API, CT.ftp must be used while passing the ExecutionContext action in a Java Handler class. Refer the following sample code snippet for better understanding on the triggering process: Here, on the following sample code snippet a new ExecutionContext action is created within which a map (HashMap) is built. The ActiveMQ datasource ID is passed along with the message as inputs to activate the connection request within which the CT.ftp API is passed to trigger this process. Code Block language js ExecutionContext ec = new ExecutionContext(); Map inputParams1 = new HashMap(); inputParams1.put("DATA_SRC_ID","ActiveMQ_DS"); // Here, ActiveMQ_DS refers to the Datasource ID. inputParams1.put("STREAM_MESSAGE","HI Team!"); // Here, Hi Team! refers to the message. ec.setInitialRequestData(inputParams1); try { CT.ftp(ec); } catch(Exception e){ }