EagleML and EJM require a series of infrastructure message streams. This page describes how to verify in Message Center Console that all required streams are installed and enabled and which message streams are required.
Note
The first time you install the monthly EagleML package In an environment, you should perform this check. It is not required for subsequent installs. This is applicable to both automated and manual install processes.
While this step is optional on subsequent installs, you may choose to do it after each install as an added verification point for manual installs.
In this page:
Verify that a Message Stream is Installed and Enabled
- Open Message Center Console in your Eagle environment.
- Click the Message Streams tab in the Message Center Console main window.
The Streams Query dialog box will be displayed. - In the Title text box, enter eagle_ml and click SEARCH.
All the message streams with the name eagle_ml will be displayed. - Check that the required streams are listed.
- Check that the Stream Statuses for all required streams are shown as Enabled.
Note
If you are installing the EagleML package for the first time on an environment that has Eagle versions 12.x, 13.x or V15R2.x, the streams will all be disabled and you will need to enable them.
If a stream is Disabled and you want to turn it on:
- Select the message stream you want to enable, right-click it and choose Enable Stream.
- The selected stream is now enabled and available for use.
Note
We recommend setting the Processing Rate parameter of these streams to “1” (if it is not set) to process them with normal priority. Setting “0” stands for low priority: the stream will not be processed by the Message Center until it finishes processing all the tasks in the queue with processing rate “1”.
If you want to set Processing rate "1" instead of "0":
- Select the message stream you want to switch to a higher priority and double click it
- Set Processing Rate to 1 in the pop-up window.
- Click OK to apply your changes.
Note
While reviewing the streams, you may also verify want to verify the instance id on the Message Stream properties.
Required Message Streams
The following table lists the stream ID, stream name, and description of the infrastructure streams installed with the EagleML/EJM Monthly Install.
Note
The counts below always represent the latest EagleML monthly release.
This stream uses a preprocessor rule file (*.prf), to sequentially execute transformation step from CSV to EagleML(XMLDBAPI)[SINGLE mode] and send a result message to the load step to the streameagle_ml-2-0_default_in_xml_warehouse or eagle_ml-2-0_default_in_xml_warehouse_preproc
Stream Count
| Stream Category | Count |
|---|---|
| EGL_EJM | 126 |
| EGL_EagleML | 27 |
| EGL_ExtractService | 5 |
| EGL_IWS | 18 |
| EGL_Generic | 16 |
| EGL_SSC | 1 |
| MC_INSTALL | 24 |
| TOTAL | 217 |
| Stream Title | Stream Category | MC2 Related | Description |
|---|---|---|---|
| eagle_default_bbca_helper | EGL_Generic | This stream performs transformation of Bloomberg Corporate Actions to TagValue format | |
| eagle_default_csv_raw_data_load | EGL_Generic | This stream is used to load Global Values (Columns) | |
| eagle_default_deploy_demand | MC_INSTALL | This stream is used to deploy rules and services manually | |
| eagle_default_deploy_restart_mc | MC_INSTALL | Stream is designed to restart MC services while deploying a snapshot or a release package | |
| eagle_default_deploy_service | MC_INSTALL | This stream is used to deploy services | |
| eagle_default_deploy_support | MC_INSTALL | The stream is intended for back up operations during installation. For example: stopping MCCOMMANDEXECUTOR, checking the installed version of the component, checking free disk space | |
| eagle_default_extractor_demand | EGL_EJM | This stream is used to run data extraction manually | |
| eagle_default_file_indexer | EGL_IWS | Finds all the references between different kinds of rules and builds dependency tree for internal use in EBS/IWS/MT | |
| eagle_default_file_move_or_copy | EGL_IWS | This stream is used to copy or move the file to a specified destination directory. It is primarily used by "task move" shape in IWS. | |
| eagle_default_in_csv_warehouse | EGL_Generic | This stream uses a preprocessor rule file (*.prf), to sequentially execute transformation from CSV to EagleML(XMLDBAPI)[BATCH mode] and send a result message for load to the stream eagle_ml-2-0_default_in_xml_warehouse or eagle_ml-2-0_default_in_xml_warehouse_preproc | |
| eagle_default_in_csv_warehouse_sm | EGL_Generic | This stream uses a preprocessor rule file (*.prf), to sequentially execute the transformation from CSV to EagleML (XMLDBAPI) [SINGLE mode] and send a result message for load to the stream eagle_ml-2-0_default_in_xml_warehouse or eagle_ml-2-0_default_in_xml_warehouse_preproc | |
| eagle_default_in_csv_warehouse_t | EGL_Generic | This stream performs transformation from CSV to EagleML(XMLDBAPI). | |
| eagle_default_in_csv_warehouse_upsert | EGL_Generic | This stream uses a preprocessor rule file (*.prf), to sequentially execute transformation from CSV to EagleML(XMLDBAPI)[UPSERT mode] and send a result message for load to the stream eagle_ml-2-0_default_in_xml_warehouse or eagle_ml-2-0_default_in_xml_warehouse_preproc | |
| eagle_default_in_pipe_performanceCLP | EGL_Generic | This stream uses a preprocessor rule file (*.prf), to sequentially execute transformation step from PIPE Performance to EagleML and send a result message for load load to the stream eagle_ml-2-0_default_in_xml_warehouse_preproc | |
| eagle_default_in_pipe_performanceCLP_t | EGL_Generic | This stream performs PIPE Performance to EagleML transformation | |
| eagle_default_in_pipe_pos | EGL_Generic | This stream uses a preprocessor rule file (*.prf), to sequentially execute transformation step from PIPE Position to EagleML and send a result message for load to the stream eagle_ml-2-0_default_in_xml_warehouse_preproc | |
| eagle_default_in_pipe_pos_t | EGL_Generic | This stream performs PIPE Position to EagleML transformation | |
| eagle_default_nuggetizer_restart | EGL_EJM | This stream is used to restart Eagle Nuggetizer. Eagle Nuggetizer is a schedule-based workflow and is run by a defined schedule. Eagle Nuggetizer Workflow runs the ‘eagle_ml-2-0_default_cm_nuggetizer’ stream, which collects EagleML files, concatenates them into nuggets and sends it for further processing | |
| eagle_default_raw_common_values_load | EGL_Generic | This stream is used to load Global Values (Columns) | |
| eagle_default_raw_create_table | EGL_Generic | ||
| eagle_default_raw_create_view | EGL_Generic | ||
| eagle_default_raw_data_header_load | EGL_Generic | ||
| eagle_default_rollback | MC_INSTALL | The stream is designed to roll back to a later version after installing an earlier version. For the case when the previous version of EagleML is installed the files in the package are compared by the manifest. If there are no such files in the installed package, they are deleted from the backend | |
| eagle_default_secmaster_resolution | EGL_EagleML | This stream is used to translate non-standard identifiers in the requestor file into vendor accepted identifiers, so that the vendor can identify security | |
| eagle_default_ruleservice | EGL_ExtractService | MC2 | This stream are used to execute requests in pyruleservice. It executes mc2_service_client.py Python script that uses the RTR sent to the stream and creates a TSR. It also saves the RTR and TSR information in orchestration tables so that it shows as a EJM task |
| eagle_iws_ruleservice | EGL_ExtractService | MC2 | |
| eagle_iws_cache | EGL_IWS | This stream is used to cache IWS resources | |
| eagle_iws_delete_file | EGL_IWS | This stream is used by IWS to remove local files | |
| eagle_iws_eagleml_panel | EGL_IWS | IWS uses this stream when it works with xpanels | |
| eagle_iws_export_solution | EGL_IWS | This stream compiles IWS solutions with the Java tool on back-end | |
| eagle_iws_export_solution_mcpkg | EGL_IWS | This stream compiles IWS solutions and sends pkg files for processed IWS solution | |
| eagle_iws_find_and_get_file | EGL_IWS | IWS uses this stream to find files | |
| eagle_iws_get_file | EGL_IWS | IWS uses this stream to download files | |
| eagle_iws_import_stream | EGL_IWS | This stream installs streams while migrating MC packages | |
| eagle_iws_import_stream_request | EGL_IWS | IWS uses this stream to start import processes | |
| eagle_iws_import_stream_w | EGL_IWS | This stream uses files processed by eagle_iws_import_stream_request and starts the process of the stream installation | |
| eagle_iws_info | EGL_IWS | This is the IWS authorization stream | |
| eagle_iws_list_files | EGL_IWS | IWS uses this stream to download the list of files for a specific directory | |
| eagle_iws_monitoring_api | EGL_IWS | EJM Monitoring Tool uses this stream to download task statistics | |
| eagle_iws_rename_file | EGL_IWS | IWS uses this stream to rename solution files | |
| eagle_iws_save_file | EGL_IWS | IWS uses this stream to upload files to the box | |
| eagle_iws_server_installer | MC_INSTALL | eagle_iws_import_stream_w uses this stream to install processed streams | |
| eagle_iws_server_support | MC_INSTALL | eagle_iws_import_stream_w uses this stream to copy source files for installing streams | |
| eagle_iws_service_data_empty | EGL_EJM | This stream is used to group rule and include files that do not require an execution stream | |
| eagle_iws_shell | EGL_IWS | This is the IWS utils stream | |
| eagle_mc_alerts | EGL_EagleML | This stream is used to send email alerts by MsgDetailId | |
| eagle_mc_import_stream_request | MC_INSTALL | This stream is used to send a combined zip with a .files.b64 and a .pkg.b64 files to the mc_import_stream_w stream | |
| eagle_mc_import_stream_w | MC_INSTALL | This stream is used to import streams. The incoming file is a ZIP which has two types of files: *.files.b64 - a base64 encoded ZIP with files to be installed, starting from estar/ *.pkg.b64 - a base64 encoded ZIP with *.pkg files to create the streams. We'll first copy the files then run the installation scripts for .pkg | |
| eagle_mc_import_support_data | MC_INSTALL | This stream is used to load sources/code categories/code values/code transaction object | |
| eagle_mc_server_installer | MC_INSTALL | This stream is used to deploy a snapshot or a release | |
| eagle_mc_server_installer_ftp | MC_INSTALL | This stream is used to deploy a snapshot or a release from FTP | |
| eagle_mc_server_installer_mq | MC_INSTALL | This stream is used to read JMS/MQ and send file to stream | |
| eagle_mc_server_installer_mq_decoder | MC_INSTALL | This stream is used to decode base64 file to zip archive and send zip to eagle_mc_server_installer | |
| eagle_mc_server_support | MC_INSTALL | This stream is used to perform basic comands during deployment. For example CHMOD, MKDIR, REINIT etc. | |
| eagle_mc_server_support_amq_monitor | MC_INSTALL | This stream is used to send email notifications about actuall stream information. The stream is out of date. We have to keep it for backward compatibility | |
| eagle_mc_server_support_import_dataflow | MC_INSTALL | This stream is used to install Data Vendor Console dataflows | |
| eagle_mc_server_support_import_stream | MC_INSTALL | This stream is used to apply stream | |
| eagle_mc_server_support_jms | MC_INSTALL | This stream is used to perform basic comands for jms using broadcast. This stream also performs eagle_mc_server_support_jms_exec in all instanses | |
| eagle_mc_server_support_jms_exec | MC_INSTALL | This stream is used to perform basic comands for jms. For example: JMSSTATUS, JMSLIST, JMSSTOP, JMSSTART, JMSPROCINFO etc. | |
| eagle_mc_server_support_reporter | MC_INSTALL | This stream is used to send Outbound Topic of Build Installation LOG files | |
| eagle_mc_stream_installer | MC_INSTALL | Stream is used to install streams from zip archive. It is the old version of stream installer | |
| eagle_ml-2-0_default_cm_acquire_data | EGL_EJM | The stream receives the information provided to the control message, adds the end of workflow trigger file and delivers all details the Load Flow Control stream to orchestrate data loads | |
| eagle_ml-2-0_default_cm_concat | EGL_EJM | Concatenates several incoming file into one outgoing with a set name | |
| eagle_ml-2-0_default_cm_construct_request | EGL_EJM | This stream generates the requestor file from EagleML Generic SMF identifiers to load the details from Bloomberg. Used in ‘generic_load_enrichment’ workflow | |
| eagle_ml-2-0_default_cm_control_message | EGL_EJM | This stream receives and parses control messages. The control message is an XML-formatted input message that EJM recognizes and processes as a command to execute a specific message stream, STAR event, or PACE event | |
| eagle_ml-2-0_default_cm_control_process | EGL_EJM | This stream is used to stop / kill workflows or MC streams | |
| eagle_ml-2-0_default_cm_data_file_splitter | EGL_EJM | The main purpose of the developed stream is to increase the performance of the incoming GICSV formatted file's loading by splitting incoming file into several smaller and distributing files into Message Center processes in order to run parallel processing. | |
| eagle_ml-2-0_default_cm_data_load_cmw_in | EGL_EJM | This is a helper stream used by the Message Center Console to deliver data files to the incoming folder (/cmw/in) | |
| eagle_ml-2-0_default_cm_datafile_control | EGL_EJM | This stream reads the trigger file from eagle_ml-2-0_default_cm_datafile_task makes a specified copy in the staging folder and then moves to the specified stream for processing. | |
| eagle_ml-2-0_default_cm_datafile_task | EGL_EJM | This stream creates trigger file with necessary information(stream name, file name, source stream name etc.) and send it to the stream eagle_ml-2-0_default_cm_datafile_control | |
| eagle_ml-2-0_default_cm_dfa | EGL_EJM | MC2 | This stream receives data files for MC2 workflow execution. |
| eagle_ml-2-0_default_cm_dishub2spoke_client | EGL_EJM | These are EagleAccessFTP streams used by i2i delivery | |
| eagle_ml-2-0_default_cm_dishub_client | EGL_EJM | ||
| eagle_ml-2-0_default_cm_disribute_to_nuggetizer | EGL_EJM | This stream sends the incoming file into the nuggetizer folder, configured by W_NGTZR_DIST_FOLDER setting | |
| eagle_ml-2-0_default_cm_ea_ftp_reader | EGL_EJM | This stream performs the following tasks: Sends a request to the database SITESEE about the files received on the FTP, Gets files from the FTP, Updates the status in SITESEE database about the files, Sends the files for processing to the eagle_ml-2-0_default_cm_control_message stream | |
| eagle_ml-2-0_default_cm_eas_distribution | EGL_EJM | This stream gets EAS alerts as TSR message, convert TSR to format in accordance with the list of templates and send alerts via mail | |
| eagle_ml-2-0_default_cm_ejm_reporter | EGL_EJM | MC2 | This MC2 stream generates acknowledgement and task status reply messages. Task statuses are SUCCESS, FAILED, and NO_DATA (for a data extract that found no database records). This stream is also the last one in the execution sequence (Load Flow Control Rule), posting the processing status of the completed workflow as a success or a failure; this stream also triggers final reporting to the external system by dropping a trigger file to the /REP folder) |
| eagle_ml-2-0_default_cm_email_distribution | EGL_EJM | This stream receives the EJM Notifications for sending and send notifications via email | |
| eagle_ml-2-0_default_cm_eofw | EGL_EJM | This stream is last in the execution sequence (Load Flow Control Rule), reporting the processing status of the completed workflow as a success or a failure; this stream also triggers final reporting to an external system by dropping a trigger file into the /REP folder | |
| eagle_ml-2-0_default_cm_execebs | EGL_ExtractService | MC2 | This stream is used to execute EBS requests |
| eagle_ml-2-0_default_cm_execute_pace_event | EGL_EJM | This stream is used to invoke a specific PACE event by name | |
| eagle_ml-2-0_default_cm_execute_star_event | EGL_EJM | This stream is used to invoke a specific STAR Accounting event by name | |
| eagle_ml-2-0_default_cm_execwkfl | EGL_EJM | This is the main stream in workflow execution | |
| eagle_ml-2-0_default_cm_file_distribution | EGL_EJM | This stream is used to deliver files. For example, for i2i workflow | |
| eagle_ml-2-0_default_cm_load_flow_control | EGL_EJM | This stream uses a preprocessor rule file (*.prf), to sequentially execute a set of data loads in logical database order, launching the appropriate supported message stream interface for each available input file | |
| eagle_ml-2-0_default_cm_mc2_healthcheck | EGL_EJM | This stream is used by Extract Service (MC2).One of the inner streams | |
| eagle_ml-2-0_default_cm_monitoring | EGL_EJM | This stream is monitoring ALERTS and sends a notification to the eagle_ml-2-0_default_cm_email_distribution stream if an alert happened | |
| eagle_ml-2-0_default_cm_ndfa | EGL_EJM | This stream receives data files for workflow execution | |
| eagle_ml-2-0_default_cm_ndfa_exec | EGL_EJM | This stream determines for which workflow incoming data file is intended and generates an event for this workflow | |
| eagle_ml-2-0_default_cm_notif_email | EGL_EJM | This stream transform TSR to plain text format and send it via email | |
| eagle_ml-2-0_default_cm_nuggetizer | EGL_EJM | This stream collects EagleML files, concatenates them into nuggets and sends it for further processing. Used in 'eagle_nuggetizer_workflow’ workflow | |
| eagle_ml-2-0_default_cm_nuggetizer_recover | EGL_EJM | This stream is used in troubleshooting for eagle_nuggetizer_workflow. Also purges generic_load_enrichment. | |
| eagle_ml-2-0_default_cm_pacepoll | EGL_EJM | MC2 | This stream is used to poll-check status of Pace reports |
| eagle_ml-2-0_default_cm_packer | EGL_EJM | This stream is used to compress files to ZIP archive | |
| eagle_ml-2-0_default_cm_parallel_exec | EGL_EJM | This stream is involved into loading files in parallel | |
| eagle_ml-2-0_default_cm_purge_archive | EGL_EJM | This stream is used to purge or archive files from local and FTP folders | |
| eagle_ml-2-0_default_cm_queue_poster | EGL_EJM | This stream is used to add information to the queue | |
| eagle_ml-2-0_default_cm_realtime_ejm_stat | EGL_EJM | This stream is used to display information in the EJM task tab correctly and check if the data was processed for the received RTR | |
| eagle_ml-2-0_default_cm_refresh_engine_cache | EGL_EagleML | This stream is used to automate engine cache clearing during runtime | |
| eagle_ml-2-0_default_cm_self_system_check | EGL_SSC | This stream is used to self-check the configuration | |
| eagle_ml-2-0_default_cm_send_to_wrf | EGL_EJM | This stream is used to send data files to workflow loader when profiled generic load is used | |
| eagle_ml-2-0_default_cm_sequencer | EGL_EJM | The stream is used to check whether to process the message in queue | |
| eagle_ml-2-0_default_cm_sequencer_cleanup | EGL_EJM | This stream is used to clean up all the message in the queue for a workflow and to remove current workflow from the queue | |
| eagle_ml-2-0_default_cm_sequencer_sch | EGL_EJM | The stream is used to check messages in the queue and send messages for processing | |
| eagle_ml-2-0_default_cm_task_executor | EGL_EJM | This stream receives dataflow state from DB and stops processing if the workflow status is negative acknowledgement (NACK). This stream derives the stream name to execute, using the task type and feed type, and triggers execution using an ACQUIRE style message stream | |
| eagle_ml-2-0_default_cm_task_reporter | EGL_EJM | This stream generates acknowledgement and task status reply messages. Task statuses are SUCCESS, FAILED, and NO_DATA (for a data extract that found no database records.) Also this stream is last in the execution sequence (Load Flow Control Rule), posting the processing status of the completed workflow as a success or a failure; this stream also triggers final reporting to the external system by dropping a trigger file to the /REP folder | |
| eagle_ml-2-0_default_cm_transform_report | EGL_EJM | The stream is used to transform TSR | |
| eagle_ml-2-0_default_cm_tsr | EGL_EJM | The stream is used to create and manage dependencies between multiple EJM tasks and oversees fork and join functionality within the stream flow | |
| eagle_ml-2-0_default_cm_unpacker | EGL_EJM | This stream is used to decompress files from any archive type (ZIP,GZIP,TARGZIP,TAR) | |
| eagle_ml-2-0_default_cm_unpacker_exec | EGL_EJM | This stream collects information about extracted files from archive and update workflow state | |
| eagle_ml-2-0_default_cm_uploader_dlvr | EGL_EJM | This stream is used to send data files to PACE Uploader for processing | |
| eagle_ml-2-0_default_cm_user_sync | EGL_EJM | This stream is used to synchronize the userID information defined on Eagle with the credentials required for the MicroStrategy application | |
| eagle_ml-2-0_default_cm_validate_by_xsd | EGL_EJM | This stream is used to perform XSD validation of data files | |
| eagle_ml-2-0_default_cm_w_setup | EGL_EJM | This stream is used to configure environment after the first EagleML installation. It creates cmw folders and sets EagleVersion variable in w_config_version.inc | |
| eagle_ml-2-0_default_cm_wrkfl_executor | EGL_EJM | MC2 | This stream executes workflow rules |
| eagle_ml-2-0_default_cm_wrkfl_listener | EGL_EJM | MC2 | This stream receives and parses MC2 control messages. The control message is an XML-formatted input message that EJM recognizes and processes as a command to execute a specific message stream, STAR event, or PACE event |
| eagle_ml-2-0_default_cm_wrkfl_reporter | EGL_EJM | This stream creates a consolidated TSR for ALL workflow | |
| eagle_ml-2-0_default_cm_xslt_exceptions_acc | EGL_EJM | The XSLT Exceptions stream can be used in workflows after the XSLT transformation for Accounting Transaction object and its main purpose is to catch exceptions generated by XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errors | |
| eagle_ml-2-0_default_cm_xslt_exceptions_ent | EGL_EJM | The XSLT Exceptions stream can be used in workflows after the XSLT transformation for Entity Transaction object and its main purpose is to catch exceptions generated by XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errors | |
| eagle_ml-2-0_default_cm_xslt_exceptions_ref | EGL_EJM | The XSLT Exceptions stream can be used in workflows after the XSLT transformation for Reference Transaction object and its main purpose is to catch exceptions generated by XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errors | |
| eagle_ml-2-0_default_cm_xslt_exceptions_wrh | EGL_EJM | The XSLT Exceptions stream can be used in workflows after the XSLT transformation for Warehouse Transaction object and its main purpose is to catch exceptions generated by XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errors | |
| eagle_ml-2-0_default_in_xml_acct_cash | EGL_EagleML | This stream is used to load Accounting Cash objects | |
| eagle_ml-2-0_default_in_xml_acct_cash_no_split | EGL_EagleML | This stream is used to load accounting cash objects.The incoming messages are processed sequentially in the order in which they are in the data file | |
| eagle_ml-2-0_default_in_xml_acct_trades | EGL_EagleML | This stream is used to load Accounting Trade objects | |
| eagle_ml-2-0_default_in_xml_acct_trades_no_split | EGL_EagleML | This stream is used to load Accounting Cash objects sequentially | |
| eagle_ml-2-0_default_in_xml_costbasis_adj | EGL_EagleML | This stream is used to load the Cost Basis Adjustment object | |
| eagle_ml-2-0_default_in_xml_delete_objects | EGL_EJM | The stream is used to delete records from DB. Supported object type groups: SMF, Entity, Warehouse, Reference | |
| eagle_ml-2-0_default_in_xml_delete_splitter_isr_mi | EGL_EJM | This stream is used to split Generic Issuer file into several Issuer files and send them to the eagle_ml-2-0_default_in_xml_delete_objects stream | |
| eagle_ml-2-0_default_in_xml_delete_splitter_smf_mi | EGL_EJM | This stream is used to split Generic SMF file into several Reference and SMF files and send them to the eagle_ml-2-0_default_in_xml_delete_objects stream | |
| eagle_ml-2-0_default_in_xml_ent_no_split | EGL_EagleML | This stream is used to load Entity objects sequentially | |
| eagle_ml-2-0_default_in_xml_entity | EGL_EagleML | This stream is used to load Entity objects | |
| eagle_ml-2-0_default_in_xml_impairments | EGL_EagleML | This stream is used to load the Impairments object | |
| eagle_ml-2-0_default_in_xml_issuer_mi | EGL_EagleML | This stream is used to split Generic Issuer file into several Issuer files and send them to the eagle_ml-2-0_default_in_xml_reference stream | |
| eagle_ml-2-0_default_in_xml_ref_ext | EGL_EagleML | This stream is used to load extended schedule objects | |
| eagle_ml-2-0_default_in_xml_ref_no_split | EGL_EagleML | This stream is used to load Reference objects.The incoming messages are processed sequentially in the order in which they are in the data file | |
| eagle_ml-2-0_default_in_xml_reference | EGL_EagleML | This stream is used to load Reference objects | |
| eagle_ml-2-0_default_in_xml_smf_custom | EGL_EagleML | This stream is used to load customSMF object. The stream is out of date. We have to keep it for backward compatibility | |
| eagle_ml-2-0_default_in_xml_smf_generic | EGL_EagleML | This stream is used to load Generic SMF object | |
| eagle_ml-2-0_default_in_xml_smf_mi | EGL_EagleML | This stream is used to split Generic SMF file into several Reference and SMF files and send them to the eagle_ml-2-0_default_in_xml_smf_generic and eagle_ml-2-0_default_in_xml_reference streams | |
| eagle_ml-2-0_default_in_xml_user | EGL_EagleML | This stream is used to load User objects | |
| eagle_ml-2-0_default_in_xml_warehouse | EGL_EagleML | This stream is used to load Warehouse objects (XMLDBAPI format) | |
| eagle_ml-2-0_default_in_xml_warehouse_preproc | EGL_EagleML | This stream is used to load Warehouse objects (EagleML format) | |
| eagle_ml-2-0_default_in_xml_washsale | EGL_EagleML | This stream is used to load accounting washSale object | |
| eagle_ml-2-0_default_out_extract_service | EGL_ExtractService | MC2 | This MC2 stream is used to extract data |
| eagle_ml-2-0_default_out_q | EGL_EagleML | This stream is the first stage of data export and manages the query process within the EJM framework | |
| eagle_ml-2-0_default_out_star_extracts | EGL_EagleML | This stream is used to extract data in STAR format | |
| eagle_ml-2-0_default_out_streaming_t | EGL_EagleML | This stream is similar to eagle_ml-2-0_default_out_t, as this stream is the second stage of the data export and manages the transformation process within the EJM framework. It uses new Eagle technology which allows tasks to be executed faster to improve throughput | |
| eagle_ml-2-0_default_out_t | EGL_EagleML | This stream is the second stage of data export and manages the transformation process within the EJM framework | |
| eagle_ml-2-0_default_validatepackage | EGL_EagleML | Validates package integrity | |
| eagle_ml-2-0_extract_service_control_message | EGL_ExtractService | This stream receives and parses control messages. The control message is an XML-formatted input message that EJM recognizes and processes as a command to execute a specific MC2 events | |
| eagle_service_data_empty | EGL_IWS | This stream is used to group rule and include files that do not require an execution stream | |
| eagle_sv_key_inst_distrib | EGL_Generic | These streams are Distribution streams using entity and instance folder | |
| eagle_sv_key_inst_proc | EGL_Generic | ||
| eagle_tba_extract_cons_records | EGL_EJM | These streams are used to maintain the ”eagle_wrf_tba” workflow. ”eagle_wrf_tba” is a set of five independent workflows that can be run consecutively in straight-through mode or selectively in user/manual execution. The final step of each workflow allows execution of the next logical series of events to be automated. The ”eagle_wrf_tba_approve” workflow is broadly responsible for matching the records that have been placed in the TRADE_CONSOLIDATION table. The ”eagle_wrf_tba_process” workflow is responsible for processing of each record that that matches others by the means of the consolidationFlag. The ”eagle_wrf_tba_mgr_alloc” workflow allocates consolidated records amongst qualified managers so that it is possible to track the payoffs for each manager | |
| eagle_tba_extract_mgr_alloc_records | EGL_EJM | ||
| eagle_tba_extract_records_1 | EGL_EJM | ||
| eagle_tba_extract_t_mgr_alloc | EGL_EJM | ||
| eagle_tba_group_by_position | EGL_EJM | ||
| eagle_tba_run_cons | EGL_EJM | ||
| eagle_tba_run_earnings | EGL_EJM | ||
| eagle_tba_t_consolidated | EGL_EJM | ||
| eagle_tba_t_mgr_alloc | EGL_EJM | ||
| eagle_tba_t_records_1 | EGL_EJM | ||
| eagle_tba_update_status_1 | EGL_EJM | ||
| eagle_trr_extract_cxl | EGL_EJM | These streams are used to maintain the "TRR SWAPS CXL RESET" workflow. Where multiple swaps can be targeted to be cancelled based on the swap underlying asset and update the current reset process where multiple swaps can be targeted to reset based on the swap underlying asset id. This process can be triggered thru panels or automated using IWS via control message | |
| eagle_trr_extract_qtrr | EGL_EJM | ||
| eagle_trr_t_cxl | EGL_EJM | ||
| eagle_trr_t_qtrr | EGL_EJM | ||
| eagle_trs_common_preproc | EGL_EJM | These streams are used to maintain the "eagle_wrf_trs_upsize" workflow | |
| eagle_trs_filter_error | EGL_EJM | ||
| eagle_trs_reply_t | EGL_EJM | ||
| eagle_trs_t_csv_trades_eml | EGL_EJM | ||
| eagle_trs_upsize_preproc | EGL_EJM | ||
| eagle_trs_xslt_cost_basis_adj | EGL_EJM | ||
| eagle_wrf_cloud_extract_schd | EGL_EJM | This stream is used to restart eagle_wrf_cloud_extract workflow | |
| eagle_wrf_csv_benchmark_returns_tsk | EGL_EJM | These streams transform CSV to EagleML format using rule service | |
| eagle_wrf_csv_calendar_holiday_tsk | EGL_EJM | ||
| eagle_wrf_csv_calendar_tsk | EGL_EJM | ||
| eagle_wrf_csv_entity_generic_tsk | EGL_EJM | ||
| eagle_wrf_csv_entity_to_composite_tsk | EGL_EJM | ||
| eagle_wrf_csv_issue_fx_pc_rate_tsk | EGL_EJM | ||
| eagle_wrf_csv_issue_fx_rate_tsk | EGL_EJM | ||
| eagle_wrf_csv_issue_pc_price_tsk | EGL_EJM | ||
| eagle_wrf_csv_issue_price_tsk | EGL_EJM | ||
| eagle_wrf_csv_issuer_role_tsk | EGL_EJM | ||
| eagle_wrf_csv_position_generic_tsk | EGL_EJM | ||
| eagle_wrf_csv_smf_generic_tsk | EGL_EJM | ||
| eagle_wrf_csv_warehouse_nav_tsk | EGL_EJM | ||
| eagle_wrf_csv_warehouse_openlot_tsk | EGL_EJM | ||
| eagle_wrf_csv_wh_cash_activity_tsk | EGL_EJM | ||
| eagle_wrf_csv_wh_cash_flow_projection_tsk | EGL_EJM | ||
| eagle_wrf_csv_wh_close_lot_tsk | EGL_EJM | ||
| eagle_wrf_csv_wh_gl_balances_tsk | EGL_EJM | ||
| eagle_wrf_csv_wh_nav_month_end_tsk | EGL_EJM | ||
| eagle_wrf_csv_wh_trade_tsk | EGL_EJM | ||
| eagle_wrf_ebs_reload_datacache_schd | EGL_EJM | ||
| eagle_wrf_delta_extract_restart | EGL_EJM | This stream is used to restart eagle_wrf_delta_extract workflow | |
| eagle_wrf_full_extract_restart | EGL_EJM | This stream is used to restart eagle_wrf_full_extract workflow | |
| eagle_wrf_generic_extract_mc2_schd | EGL_EJM | This stream is used to restart eagle_wrf_generic_extract_mc2 workflow | |
| eagle_wrf_generic_extract_restart | EGL_EJM | This stream is used to restart eagle_wrf_generic_extract workflow | |
| eagle_wrf_generic_purge_archive_restart | EGL_EJM | This stream is used to restart eagle_wrf_generic_purge_archive workflow | |
| eagle_wrf_generic_purge_restart | EGL_EJM | This stream is used to restart eagle_wrf_generic_purge workflow | |
| eagle_wrf_i2i_message_distribution | EGL_EJM | This stream is used to deliver RTR/TSR/Data files (base64) | |
| eagle_wrf_i2i_restart | EGL_EJM | This stream is used to restart eagle_wrf_i2i workflow | |
| eagle_wrf_i2i_sec_alias_sync_restart | EGL_EJM | This stream is used to restart eagle_wrf_i2i_sec_alias_sync workflow | |
| eagle_wrf_pending_trades_extract | EGL_EJM | These streams are used to maintain the "eagle_wrf_pending_trades" workflow | |
| eagle_wrf_pending_trades_t | EGL_EJM | ||
| eagle_wrf_pending_trades_restart | EGL_EJM | This stream is used to restart eagle_wrf_pending_trades workflow | |
| eagle_wrf_tba_approve_restart | EGL_EJM | This stream is used to restart eagle_wrf_tba_approve workflow | |
| eagle_wrf_tba_consolidation_restart | EGL_EJM | This stream is used to restart eagle_wrf_tba_consolidation workflow | |
| eagle_wrf_tba_mgr_alloc_restart | EGL_EJM | This stream is used to restart eagle_wrf_tba_mgr_alloc workflow | |
| eagle_wrf_tba_process_restart | EGL_EJM | This stream is used to restart eagle_wrf_tba_process workflow | |
| eagle_wrf_trr_reset_restart | EGL_EJM | These streams are used to restart eagle_wrf_trr_reset workflow | |
| eagle_wrf_trr_reset_demand | EGL_EJM | ||
| reload_datacache_tsk | EGL_EJM | This stream is used to reload EBS cache | |
| eagle_ml_file_distribution | EGL_EJM | This stream was used to deliver files to another server. For example, within i2i workflow. The stream is out of date | |
| eagle_default_deploy | MC_INSTALL | This stream was used to install EagleML services. Obsolete. | |
| eagle_default_deploy_monitoring | MC_INSTALL | This stream was used to install the monitoring, it is considered obsolete now |