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 Create Data Source. Note:

   Click the Data Source Image Added icon on the existing ActiveMQ connection.

   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.

   Warning
   When you try to exit the Data Source screen, before saving the configured ActiveMQ data source, a warning pop-up message appears, as shown in the following screen shot: Image Added Click Cancel, if you do not want to exit the Data Source screen. Click Ok, if you want to exit the Data Source screen.

   
   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){ }