From 3forge Documentation
Jump to navigation Jump to search

AMI Remote Procedure Calling (RPC)

AMI Remote Procedure Calling (RPC) Overview

AMI RPC leverages the HTTP CORS (Cross Origin Resource Sharing) standard to provide a mechanism for separate AMI dashboards within the same domain to communicate with each other.  As such, different teams working on distinct dashboards/use cases can easily integrate them.  For example, there are two teams, one building a dashboard for viewing orders and a second team building an order analytics dashboard. The first team could configure the order-dashboard such that when the user clicks on an order, an RPC instruction is sent to the other team’s dashboard, which in turn  displays analytics about the selected order. This paradigm promotes seamless integration across any number of dashboards at scale, providing users with a simple workflow accordingly.

How AMI RPC Works (User Perspective)

If a user is logged into two or more dashboards built on the AMI platform, then it's possible for the dashboards to call ami script across those dashboards.

Dashboards must be opened in the same browser space. For example, if one dashboard is opened in Chrome then the other dashboard must be opened in Chrome as well. Additionally, if one dashboard is opened in non-cognito mode then the other must also be opened in non-cognito mode.

Although it is not necessary for both dashboards to be logged in with same user ID, it can be enforced if necessary.

How AMI RPC Works (Configuration Perspective)

This is done by way of configuring custom AmiScript methods such that one dashboard can execute a custom AmiScript Method on another dashboard.  Communication supports full round trip, meaning the calling dashboard sends arguments to the receiving dashboard and then the receiving dashboard can respond to the call with data as well.

The target of such a call is identified using a host and method name combination.  It is common for the builder of the target dashboard to properly determine the host(s), method(s) and structure of the request and response payloads, which in aggregate is considered an API. This "API" is then communicated to those teams wishing to use the API.

For further reading on the general usage of CORS visit

Please note that both dashboards must be hosted within the same domain, ex: and are both in the so they can communicate via CORS, despite having different subdomains.  It's important that the all references to the domains use the fully qualified domain.

Creating a Method for being remotely called

Create a custom method with a predetermined "well-known" name that returns a Map, and takes an RpcRequest object as a single Argument of the form:

Map myMethod (RpcRequest request){
    Map requestArgs = request.getArguments();
    //Do something here
    Map responseArgs = new Map("key","someReturnValue");
    return responseArgs;

Important: Please note that the return type of Map and argument type of RpcRequest is required and specifically indicates that the method can be called remotely.

Calling a Method remotely

Use the callRpcSnyc(RpcRequest) method on the session object. The RpcRequest constructor takes these 3 arguments.

target - URL of the host that you wish to call the method on.

methodName - Name of the method to call (in the example above, it's myMethod).

Arguments - Key/value pair of data to send. Note that the data will be transported using JSON, so complex objects, such as panels, cannot be referenced.

For Example, let’s say the example above is running on a dashboard at This would call that method:

Map requestArgs=new Map("key","someRequestValue");

String host="";

RpcRequest request=new RpcRequest(host,"myMethod",requestArgs);

RpcResponse response = session.callRpcSync(request);

Map responseArgs=response.getReturnValues();

HOW AMI RPC Transport Works

  1. The Source dashboard calls session.callRpcSync(...)
  2. The Source dashboard creates a JSON request that is sent to the dashboard via websockets
  3. AMI's javascript forwards the JSON to the target Server (the browser will do CORS authentication against the target web server, which AMI is compatible with)
  4. The target webserver will receive the JSON, confirm headers and create an RpcRequest object for processing
  5. The target dashboard's amiscript custom method will process the request and produce a response
  6. The reply from the target server is sent back to the web browser in the http response as JSON
  7. The response is forwarded back to the source webserver via web sockets
  8. AMI converts the JSON to an RpcResponse which is passed back to the dashboard for processing




Error Condition Handling

The session.callRpcSync(...) method will always return an RpcResponse object. You can inspect the Error for the success or failure status.

Here are the possible return values of getError:

Return Value Description
null The rpc call executed successfully
"NO_RESPONSE" The server failed to respond, this is generally caused if the user refreshes the webpage while the rpc request is inflight, which will reset the connection.
"CONNECTION_FAILED" The CORS could not successfully establish a connection. This may be because the target url does not point to an existing AMI instance.
"INVALID_URL" The format of the target url is not valid.
"ERROR_FROM_SERVER" The server responded with an error.
"ERROR_FROM_SERVER_ORIGIN_NOT_PERMITTED" The origin was not permitted (based on the option)
"ERROR_FROM_SERVER_USER_NOT_LOGGED_IN" The user does not have a browser open which is logged into the server
"ERROR_FROM_SERVER_NO_SUCH_METHOD" The dashboard does not have a custom method of the supplied name. Or the method does not return a Map, or the method does not take an RpcRequest as it's single argument.
"ERROR_FROM_SERVER_METHOD_EXCEPTION" The method was executed but threw an unhandled exception.
"ERROR_FROM_SERVER_USERNAME_MISMATCH" The RpcRequest constructor was supplied a requiredUserName, which did not match the username currently logged in on the target dashboard.
"ERROR_FROM_SERVER_LAYOUT_NAME_MISMATCH" The RpcRequest constructor was supplied a requiredLayoutName, which did not match the name of the layout on the target dashboard.
"ERROR_FROM_SERVER_LAYOUT_NAME_MISMATCH" The RpcRequest constructor was supplied a requiredSessionId, which did not match the sessionId of the layout on the target dashboard.

Please Note, you can look at RpcResponse::getErrorMessage for further details.


The option can be supplied (in the ami web's properties) to control which origins are accepted. See the Access-Control-Allow-Origin header for further information on how CORS origins works. Here are 3 separate examples:

# Disable CORS, no origins will be allowed to remotely call functions

# All origins are allowed*

# Allow a specific host|

Encrypting and Decrypting using

The pdf below contains instructions on how to encrypt and decrypt using

File:Instructions for encrypting and decrypting using

AMI Center Replication

This document details how to replicate data from one AMI Center to another AMI Center using its built-in support for data replication. It supports subscription to tables and replication to another AMI Center.

This document provides an example on how to use AMI Center Replication.


  • Have at least 2 AMI centers running, e.g.
    • host:center_port eg. localhost:3270 & localhost:4270
  • Tables to be replicated in the individual centers
    • Table schema in the source center must be identical to replicated table in destination center
    • The target table should have no PersistEngine

Replication Procedures

__ADD_CENTER(CenterName String, Url String, Certfile String, Password String)

  • CenterName (Required): Specified name for center (source)
  • Url (Required): Url of center (host:
  • Certfile: Path to the certfile (optional)
  • Password: Password if a certfile is given (optional)

__REMOVE_CENTER(CenterName String)

__ADD_REPLICATION(Definition String, Name String, Mapping String, Options String)

  • Definition (nonull): Target_TableName=Source_CenterName.Source_TableName or Source_CenterName.TableName (if both source and target has same table name)
  • Name: Name for the replication
  • Mapping: Mappings to be applied for the tables, (key value delimited by comma) ex: "target_col_name=source_col_name" or ex: "(act=account,symbol=symbol,value=(px*qty))"
  • Options: options to clear the replication on
    • "Clear=onConnect" or "Clear=onDisconnect"
      • Note: If configured the replicated table will clear when the center connects or disconnec



  • Shows properties of all replication sources. Properties shown include:
    • CenterName (String)
    • URL (String)
    • CertFile (String)
    • Password (String)
    • Status (String): shows whether the replication source is connected or not
    • ReplicatedTables (int): Number of replicated tables
    • ReplicatedRows (int): Number of replicated rows


  • Shows properties of all replications. Properties shown include:
    • ReplicationName (String)
    • TargetTable (String)
    • SourceCenter (String)
    • SourceTable (String)
    • Mapping (String): shows the mapping for the replication
    • Options (String): shows options to clear replications on
    • ReplicatedRows (int): Number of replicated rows
    • Status (String): shows whether a successful connection is established to the target table

Note: When replicating from the source AMI Center and the source table, ensure the table is a Public table with Broadcast Enabled.

Note 2: Configuring the RefreshPeriodMs will allow you to adjust for throughput, performance and how often updates are pushed.

See the following documentation: create_public_table_clause

Lower RefreshPeriodMs means updates are pushed more frequently which potentially means lower throughput.

Higher RefreshPeriodMs could mean higher throughput and better performance but fewer updates.

Note 3: Removing the replication will clear all the copied entries on the target side’s table, regardless of the options.

Replication Sample Guide

To replicate data from one AMI Center to a destination AMI Center, first we need to `add` the source AMI Center in the destination AMI Center. After which we can replicate target tables from the source to the destination.


call __ADD_CENTER("source", "localhost:3270");

__ADD_CENTER Adds the source center you want to copy from. So if your AMI Center Port is 3270, and you call __ADD_CENTER on the destination AMI Center, that means you plan to replicate data from 3270 to 4270.

call __ADD_REPLICATION("dest_table=source.mytable","myReplication"," account=account", "Clear=onConnect");

__ADD_REPLICATION specifies which table on the source side the target side wants to replicate. The data travels from source to target, from 3270 to 4270.

AMI Center Persist Files

There are two persist files responsible for maintaining the replications, __REPLICATION.dat and __CENTER.dat. We do not recommend modifying the contents of these files manually, these files may have strict formatting and could cause serious issues if altered incorrectly.

Persist File Location

By default these files are located in the default persist directory. This may not be the case if the persist dir has been changed by the property: ami.db.persist.dir or the system tables directory has been changed by the property: ami.db.persist.dir.system.tables.

To change only the __REPLICATION.dat or __CENTER.dat locations add the following property.

ami.db.persist.dir.system.table.__REPLICATION=path ami.db.persist.dir.system.table.__CENTER=path

__REPLICATION.dat Format

ReplicationName|TargetTable|SourceCenter|SourceTable|Mapping|Options| "ReplicationName"|"SourceTableName"|"SourceName"|"TargetTableName"|"TableMapping"|"ClearSetting"|

__CENTER.dat Format

CenterName|Url|CertFile|Password| "CenterName"|"CenterURL"|"CertFileIfProvided"|"PasswordForCertFile"|

List of available AMI procedures

Parameters in bold indicate no null.

For the following procedure calls, refer to the pdf document in the previous section, AMI Center Replication





Note: to call a procedure in the frontend, e.g. in a datamodel, or an AMI editor, use this syntax:

use ds=AMI execute call... (your procedure here);

to use this in the AMIDB console, just use:

call... (your procedure here)

Example frontend usage:

use ds=AMI execute __RESET_TIMER_STATS("mytimer",true,true);

Example console usage:

call __RESET_TIMER_STATS("mytimer",true,true);


__ADD_DATASOURCE(String name, String adapter_type, String url, String username, String password, String options1, String relayId2, String permittedOverrides3)

1options refer to values under the Advanced section. Must be a comma delimited list.

Ex: “DISABLE_BIGDEC=true,URL_OVERRIDE=jdbc:mysql://serverUrl:1234/databaseName”

2relayId refers to “Relay to Run on” under the Configuration section.

3permittedOverrides refers to the checkboxes under the Security section. Must be a comma delimited list. The available values are URL, USERNAME, PASSWORD, OPTIONS, RELAY.

Ex: “URL,USERNAME” <- this will tick the URL and USERNAME checkbox.
Supported Adapter Types
Name Alias (to be used in the procedure call)
AMI datasource __AMI
Shell Command SHELL
SSH Command SSH
Redis Redis
Flat File Reader FLAT_FILE


Use show datasources to see a list of datasources.
This procedure removes the specified datasource.


Call __RESET_TIMER_STATS(String timerName, Boolean executedStats, Boolean errorStats)
Use show timers to see information for all timers..
This procedure clears NextRunTime. Optionally clears ExecutedCount, MillisSpent, and AvgMillisSpent if ExecutedStats is set to true, and optionally clears ErrorCounts if ErrorStats is set to true.

Screenshot showing timer stats.png


Call __RESET_TRIGGER_STATS(String triggerName)
Use show triggers to see information for all triggers.
This procedure will reset ExecutedCount, MillisSpent, AvgMillisSpent, ErrorsCount, ReturnedFalseCount for a particular trigger.

Screenshot of trigger stats.png


Call __SCHEDULE_TIMER(String timerName, Long delayMillis)
This procedure schedules the timer to run after the specified number of milliseconds passes. For instance, call __SCHEDULE_TIMER(“mytimer”, 5000) means mytimer will start running after 5000 milliseconds, or 5 seconds.


Call __SHOW_TIMER_ERROR(String timerName)
This procedure shows you the last error the specified timer encountered in a table format.


Call __SHOW_TRIGGER_ERROR(String triggerName)
This procedure shows you the last error the specified trigger encountered in a table format.

OMAS Installation Instructions

The OMAS architecture allows realtime streaming of FIX messages into AMI for easy visualization and analystics.

OMAS Installation Instructions 01.jpg

1. Download the fix2ami.<version>.<type>.tar.gz file from your 3forge account and extract. 2. Configure properties in the config/fix2ami folder

a. - FIX session properties OMAS Installation Instructions 02.jpg

b. - AMI DB properties

  • host, port, login values can be obtained from your local AMI settings

OMAS Installation Instructions 03.jpg

  • Optionally, configure AMI table names for OMAS using the same property

OMAS Installation Instructions 04.jpg

3. Run the script located in the scripts folder and connect to the FIX sessions. To connect multiple sessions, add session names to the sessions variable and configure properties for each session

OMAS Installation Instructions 05.jpg

Now, FIX messages will be processed to AMI and you can begin creating visualizations in the AMI dashboard:

OMAS Installation Instructions 06.jpg

4. To stop, run the script


  • If you change AMI table names for OMAS in the file later, the old tables will still be

defined in AMI DB.

  • Fix2Ami sequence numbers are stored in the data/fix2ami folder.

Encrypted System Tables

This section details how to create encrypted AMI tables, including system tables. Adding decrypters on existing encrypted tables is also supported.

Creating a Encrypted User Table

To create an encrypted user table, add persist_encrypter="default" to the CREATE TABLE statement containing PersistEngine. This will encrypt the data stored for the persistent user table. By default the encrypter should be "default". Example:

CREATE PUBLIC TABLE MyTable(c1 Integer, c2 Short, c3 Long, c4 Double, c5 Character, c6 Boolean, c7 String) USE PersistEngine="FAST" persist_encrypter="default" RefreshPeriodMs="100"

  • persist_encrypter(required): name of encrypter

Adding Decrypters

To add decrypters, add the following option to the file (found in amione/scripts):

  • DECRYPTER_NAME: name of decrypter
  • ClassName: name of decrypter Java class

Encrypting System Tables

To encrypt system tables, add either of the following lines to the file (found in amione/config):




  • encryptername: name of encrypter used

NOTE: The old unencrypted .dat persist files will not be deleted after encryption, and will be appended with .deleteme

Azure Vault AMI


Required version: >

Following credentials are to be generated

Quickstart: Create a new tenant in Azure Active Directory - Refer to this guide to generate the following credentials

Required VM Option:


VM Option for enabling debugging:

  • DAzureDebug=true

VM Options for Authentication (Use one of the following)

  • DAzureAuth=[Token, ClientSecret, or Identity]

VM Options for Token

  • DAzureAuth=Token
  • DAzureBearerToken=[your generated token]

VM Options for Client Secret

  • DAzureAuth=ClientSecret
  • DAzureTenant=[Tenant, e.g. 218f57a4-c14b-4be5-a57… ]
  • DAzureClientId=[AppId, e.g. 14752cd8-e62d-484d-b11a… ]
  • DAzureClientSecret=[Password, e.g. wLr6evrQBmgPkb6d9… ]
  • DAzureScope=

VM Options for Managed Identity

  • DAzureAuth=Identity
  • DAzureIdentityApiVersion=[ 2018-02-01 ]
  • DAzureIdentityResource=[ ]
  • DAzureIdentityObjectId=[ optional ]
  • DAzureIdentityClientId=[ optional ]
  • DAzureIdentityMiResId=[ optional ]

VM Options for Decryption

  • DAzureUrlBase=[Vault base url, e.g.]
  • DAzureDecrypterKeyName=[Key name]
  • DAzureDecrypterKeyVersion=[Key Version]
  • DAzureDecrypterApiVersion=[Azure API version, default 7.2]
  • DAzureDecrypterAlg=[Encryption algorithm, e.g. RSA1_5]
  • DAzureDecrypterCharset=[Charset, e.g. UTF-8 (default)]

Add the encrypted text in file


Example: amiscript.variable.secret1=${CIPHER:AZURE:QNEdUh7jWNW_LJZTFN6gocxyxDmuZSMhikSATAmzEqpH1X3nrNVAIA5PJONottcr6O7L3XlO1T1_0OWeaT5xP2i3lOFHg4fl39YzgNb4w_T1dupL22RC9185xADDSeY6dHcfFIVcJuGE78PlN1EA1shi6vQv4JtAcjFjSaFfv40X5LOWNZFEah6z3MhkPuTP7XrfauNheKQunRt_-bTKV9CNHSEReWAvaTv8sEt67EDHasKSM1Uz3FK9nwoUmS2_wksjMPGCSrkF67DD66pZU03BRGLAuLF51qp8-GWfY9lxKaLJdatD2LdEm3K17cx1v526XZoYX88uOBlwdA4-mQ==}





Required version: >

Following credentials are to be generated

Getting Started with AWS Key Management Service - Refer to this guide to generate the following credentials

Required VM Option:


VM Option for enabling debugging:

  • DAwsKmsDebug=true

VM Options for Client Secret

  • DAwsKmsAccessKey=[Access key Id, e.g. AKIAZV…]
  • DAwsKmsSecret=[Secret access key, e.g. FDNa3B61gyKOK…]

VM Options for Decryption

  • DAwsKmsEndpoint=[Aws Endpoint]
  • DAwsKmsKeyId=[Key id, e.g. arn:aws:kms:us-east-1:6646…]
  • DAwsKmsRegion=[Region]
  • DAwsKmsHost=[Hostname]
  • DAwsKmsDecrypterCharset=[Charset, e.g. UTF-8 (default)]

Add the encrypted text in file




On Login

Decrypted values would be shown in AMI session variables


AMI Replay Plugin

This document details the use of the Replay plugin, which allows the user to “replay” real-time data streams from a AMI messages log file (e.g. AmiMessages.log).

Replay can be used for retrieving and rendering data from otherwise hard-to-read data from AMI real-time message log files.

Logging in to AMI real-time stream

Before using this plugin, run AMI and connect to the real-time port:

1. Telnet into the platform’s real-time streaming port

  • The default port (3289) can be found in file, under property ami.port

2. Login with unique process identity string


AMI Replay Plugin.01.jpg

Using Replay

Sample Replay command:


Instruction Description
T="Replay" To indicate a Replay command
LOGIN="xxx" Required login instruction for replay file
FILE="/path/xxx.log" Name and path to AMI messages log file to replay

You can also use the relative path from the AMI application installation directory (amione/)

MAXDELAY=xxx (long) OPTIONAL - delay between each line read from log file
MAX_PER_SECOND=xxx (long) OPTIONAL - maximum stream commands from log file per second

Multiple files can be replayed within the same command, with the file names and paths delimited with a comma. For example:


Using AMI script to change column types on tables loaded from a data model

If your table in a data model has a String column called Quantity but you would like to change it to a Long, you can use this query in the data model:

alter Table myTable add Quantity2 long=Quantity, drop Quantity;

Then if you would like to keep the same name, you can do:

alter table myTable rename Quantity2 to Quantity;

You can also do this in one line:

alter Table myTable add Quantity2 long=Quantity, drop Quantity, rename Quantity2 to Quantity;

Here is a screenshot showing how it looks in AMI

Column type conversion.png

However, if your String column contains commas, then you need to remove them before converting the column to a numeric type:

alter Table myTable add Quantity2 long=Quantity.replaceAll(",",""), drop Quantity;

Here, the String method repalceAll replaces all instances of `,` with an empty string.

Storing a datamodel table to AMI DB

If you have a table that only exists in AMI Web and you want to store it to AMI DB, here are the steps:

  // create an example table
  create table Sample (symbol String, quantity int);   
  // insert some values
  INSERT INTO Sample Values("MSFT",100),("IBM",200),("AAPL",400);   
  // store the table schema as a string
  string s = describe table Sample;    
  // s = "CREATE TABLE Sample (symbol String,quantity Integer)"
  // use `strAfter` to extract the string after a delimiter
  s = strAfter(s, "CREATE TABLE", false);   
  // s = "Sample (symbol String,quantity Integer)"
  // ensure AMI DB does not have a duplicate table with the same name
  use ds="AMI" execute DROP TABLE IF EXISTS Sample;   
  // create a public table. Any AMI DB table that is public will be visible in AMI Web. Conversely non-public AMI DB table will NOT be visible in AMI Web
  use ds="AMI" execute CREATE PUBLIC TABLE ${s};    
  // using the `use ... insert` syntax to insert a AMI Web table to the AMI DB.
  use ds="AMI" insert into Sample SELECT * FROM Sample;    
  // sanity check
  create table t as use ds="AMI" execute SELECT * FROM Sample;

Here is the output: The left table, Sample, lives in the web. Right table, t, is pulled from AMI DB.


In AMI DB, we can see that the table has been inserted.

AMI DB view

Explanation of AMI's Dashboard Resource Indication (DRI)