Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

EagleML and EJM require a series of infrastructure message streams. This page describes how to verify in the Message Center Console that all of the required streams are installed and enabled and which message streams are required.

Info
titleNote

The first time you install the monthly EagleML package In an environment, this check should be performed. It is not required for subsequent installs. This is applicable to both the automated and the manual install processes.

While this step is optional on subsequent installs, it may be conducted after each install as an additional verification point for manual installs

In this page:

...

  1. Open the Message Center Console in your Eagle environment.
  2. Click the Message Streams tab in the Message Center Console main window.
    The Streams Query dialog box will be displayed.
  3. In the Title text box, enter eagle_ml and click SEARCH.
    All of the message streams with the name eagle_ml will be displayed.
  4. Check that the required streams are listed.
  5. Check that the Stream Statuses for all of the required streams are shown as Enabled.


Info
titleNote
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. 

...

Info
titleNote
 While reviewing the streams, you may also verify want to verify the instance id on the Message Stream properties.

Anchor

...

Streams

...

Streams
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.

...

This stream uses a preprocessor rule file (*.prf), to sequentially execute the 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 CategoryCount
EGL_EJM
126
129
EGL_EagleML
27
31
EGL_ExtractService5
EGL_IWS
19
20
EGL_Generic16
EGL_SSC1
MC_INSTALL
24TOTAL218

...

23
EGL_PROD_PAR (Uncategorized)2
EIS1
TOTAL226

Anchor
Streams
Streams

Stream
Title
NameStream Category
MC2 Related
CommentsStream Description
eagle_default_
bbca
secmaster_
helper
resolutionEGL_
Generic
EagleML
This stream
performs transformation of the Bloomberg Corporate Actions to TagValue format
is used to translate the non-standard identifiers in the requestor file into vendor accepted identifiers, so that the vendor may identify the security
eagle_
default_csv_raw_data_load
mc_alertsEGL_
Generic
EagleML
This stream is used to
load Global Values (Columns)eagle
send email alerts by MsgDetailId
eagle_ml-2-0_default_
deploy
cm_exec_
demand
eds
MC
EGL_
INSTALL
EagleML
This stream is used to
deploy the rules and services manuallyeagle_default_deploy_restart_mcMC_INSTALLThis stream is designed to restart MC services while deploying a snapshot or a release packageeagle_default_deploy_serviceMC_INSTALL
execute any types of EDS processes.
eagle_ml-2-0_default_cm_profiled_load_validationEGL_EagleML         
This stream validates profiled generic load results.
eagle_ml-2-0_default_cm_refresh_engine_cacheEGL_EagleML
This stream is used to
deploy services
automate engine cache clearing during runtime
eagle_ml-2-0_default_in_
deploy
xml_acct_
support
cash
MC
EGL_
INSTALL
EagleML
This stream is
intended for back up operations during installation.
For example: stopping MCCOMMANDEXECUTOR, checking the installed version of the component, checking free disk spaceeagle_default_extractor_demandEGL_EJM
used to load the Accounting Cash objects
eagle_ml-2-0_default_in_xml_acct_cash_no_splitEGL_EagleML
This stream is used to
run the data extraction manually
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_
file
acct_
distribution
tradesEGL_
EJM
EagleML
This stream is used to
deliver files using external connection. Only FTP delivery type supported. (Note: it is part of eagle_ml_file_distribution package).eagle_default_file_indexerEGL_IWSThis stream identifies all references between different rules and creates a dependency tree for internal use in EBS/IWS/MTeagle_default_file_move_or_copyEGL_IWS
load the Accounting Trade objects
eagle_ml-2-0_default_in_xml_acct_trades_no_splitEGL_EagleML
This stream is used to load Accounting Cash objects sequentially
eagle_ml-2-0_default_in_xml_costbasis_adjEGL_EagleML
This stream is used to
copy or move the file to a specified destination directory. It is primarily used by the "task move" shape in IWS. eagle
load the Cost Basis Adjustment object
eagle_ml-2-0_default_in_xml_ent_
csv
no_
warehouse
splitEGL_
Generic
EagleML
This stream
uses a preprocessor rule file (*.prf), to sequentially execute the transformation from CSV to EagleML(XMLDBAPI)[BATCH mode] and send a result message for load to the stream
is used to load the Entity objects sequentially
eagle_ml-2-0_default_in_xml
_warehouse or eagle
_entityEGL_EagleML
This stream is used to load the Entity objects
eagle_ml-2-0_default_in_xml_
warehouse_preproceagle
impairmentsEGL_EagleML
This stream is used to load the Impairments object
eagle_ml-2-0_default_in_
csv
xml_
warehouse
issuer_
sm
miEGL_
Generic
EagleML
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
is used to split the Generic Issuer file into several Issuer files and route them to the eagle_ml-2-0_default_in_xml_
warehouse or
reference stream
eagle_ml-2-0_default_in_xml_
warehouse
ref_
preproceagle
ext
eagle_default_in_csv_warehouse_tEGL_GenericThis stream performs transformation from CSV to EagleML(XMLDBAPI)
EGL_EagleML
This stream is used to load the extended schedule objects
eagle_ml-2-0_default_in_xml_ref_no_splitEGL_EagleML
This stream is used to load the 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_
csv
xml_
warehouse_upsert
referenceEGL_
Generic
EagleML
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
is used to load the Reference objects
eagle_ml-2-0_default_in_xml
_warehouse or
_smf_customEGL_EagleMLObsoleteThis stream was used to load the customSMF object. It is obsolete, but documented for backwards compatibility.
eagle_ml-2-0_default_in_xml_smf_
warehouse_preproceagle
genericEGL_EagleML
This stream is used to load the Generic SMF object
eagle_ml-2-0_default_in_xml_
pipe
smf_
performanceCLP
miEGL_
Generic
EagleML
This stream
uses a preprocessor rule file (*.prf), to sequentially execute the transformation step from PIPE Performance to EagleML and sends a result message for load to the stream
is used to split the Generic SMF file into several Reference and SMF files and route them to the eagle_ml-2-0_default_in_xml
_warehouse_preproceagle
_smf_generic and eagle_ml-2-0_default_in_xml_reference streams
eagle_ml-2-0_default_in_
pipe
xml_
performanceCLP_t
userEGL_
Generic
EagleML
This stream
performs PIPE Performance to EagleML transformation
is used to load the User objects
eagle_ml-2-0_default_in_
pipe
xml_
pos
warehouseEGL_
Generic
EagleML
This stream
uses a preprocessor rule file (*.prf), to sequentially execute the transformation step from PIPE Position to EagleML and sends a result message for load to the stream
is used to load the Warehouse objects (XMLDBAPI format)
eagle_ml-2-0_default_in_xml_warehouse_preprocEGL_EagleML
This stream is used to load the Warehouse objects (EagleML format)
eagle_ml-2-0_default_in_
pipe
xml_
pos_t
washsaleEGL_
Generic
EagleML
This stream
performs PIPE Position to EagleML transformation
is used to load the Accounting washSale object
eagle_ml-2-0_default_
nuggetizer
out_
restart
qEGL_
EJM
EagleML
This stream is
used to restart the Eagle Nuggetizer. The Eagle Nuggetizer is a schedule-based workflow and is run by a defined schedule. The Eagle Nuggetizer Workflow runs the
the first stage of the data export and manages the query process within the EJM framework
eagle_ml-2-0_default
_cm_nuggetizer’ stream, which collects EagleML files, concatenates them into nuggets and sends it for further processingeagle_default_raw_common_values_loadEGL_GenericThese streams are used to load Global Values (Columns)eagle_default_raw_create_tableEGL_Genericeagle_default_raw_create_viewEGL_Genericeagle_default_raw_data_header_loadEGL_Genericeagle_default_rollbackMC_INSTALLThis 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_resolutionEGL_EagleMLThis stream is used to translate the non-standard identifiers in the requestor file into vendor accepted identifiers, so that the vendor may identify the securityeagle_default_ruleserviceEGL_ExtractServiceMC2

This stream are used to execute requests in pyruleservice. It executes the 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 the orchestration tables to show it as an EJM task.

eagle_iws_ruleserviceEGL_ExtractServiceMC2eagle_iws_cacheEGL_IWSThis stream is used to cache IWS resourceseagle_iws_delete_fileEGL_IWSThis stream is used by IWS to remove local fileseagle_iws_eagleml_panelEGL_IWSThis stream is used by IWS to interact and execute the Xpanelseagle_iws_export_solutionEGL_IWSThis stream compiles IWS solutions with the Java tool on the back-endeagle_iws_export_solution_mcpkgEGL_IWSThis stream compiles IWS solutions and sends the pkg files for the processed IWS solutioneagle_iws_find_and_get_fileEGL_IWSThis stream is used by IWS to locate fileseagle_iws_get_fileEGL_IWSThis stream is used by IWS to download fileseagle_iws_import_streamEGL_IWSThis stream installs streams while migrating MC packageseagle_iws_import_stream_requestEGL_IWSThis stream is used by IWS to start the import process requestseagle_iws_import_stream_wEGL_IWSThis stream uses files processed by the eagle_iws_import_stream_request and starts the process of the stream installationeagle_iws_infoEGL_IWSThis stream is the IWS authorization streameagle_iws_list_filesEGL_IWSThis stream is used by IWS to download the list of files for a specific directoryeagle_iws_monitoring_apiEGL_IWSThis stream is used by the EJM Monitoring Tool to download task statisticseagle_iws_rename_fileEGL_IWSThis stream is used by IWS to rename solution fileseagle_iws_save_fileEGL_IWSThis stream is used by IWS to upload files to the boxeagle_iws_server_installerMC_INSTALLThis stream uses the eagle_iws_import_stream_w to the install processed streamseagle_iws_server_supportMC_INSTALLThis stream uses the eagle_iws_import_stream_w to copy source files for installing streamseagle_iws_service_data_emptyEGL_EJMThis stream is used to group rule and include files that do not require an execution streameagle_iws_shellEGL_IWSThis is the IWS utils streameagle_mc_alertsEGL_EagleMLThis stream is used to send email alerts by MsgDetailIdeagle_mc_import_stream_requestMC_INSTALLThis stream is used to send a combined zip with a .files.b64 and a .pkg.b64 files to the mc_import_stream_w streameagle_mc_import_stream_wMC_INSTALLThis 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.
      The process first copies the files then runs the installation scripts for .pkgeagle_mc_import_support_dataMC_INSTALLThis stream is used to load sources/code categories/code values/code transaction objecteagle_mc_server_installerMC_INSTALLThis stream is used to deploy a snapshot or a releaseeagle_mc_server_installer_ftpMC_INSTALLThis stream is used to deploy a snapshot or a release from FTPeagle_mc_server_installer_mqMC_INSTALLThis stream is used to read JMS/MQ  and send files to the appropriate streameagle_mc_server_installer_mq_decoderMC_INSTALLThis stream is used to decode base64 file to zip archive and send the zip to eagle_mc_server_installereagle_mc_server_supportMC_INSTALLThis stream is used to perform basic commands during deployment. For example CHMOD, MKDIR, REINIT etc.eagle_mc_server_support_amq_monitorMC_INSTALLThis stream is used to send email notifications about actual stream information. The stream is out of date. It is maintained for backward compatibility.eagle_mc_server_support_import_dataflowMC_INSTALLThis stream is used to install the Data Vendor Console dataflowseagle_mc_server_support_import_streamMC_INSTALLThis stream is used to import a stream package in Message Centereagle_mc_server_support_jmsMC_INSTALLThis stream is used to perform  basic commands for JMS using broadcast. This stream also performs eagle_mc_server_support_jms_exec in all instances.eagle_mc_server_support_jms_execMC_INSTALLThis stream is used to perform  basic commands for JMS. For example: JMSSTATUS, JMSLIST, JMSSTOP, JMSSTART, JMSPROCINFO etc.eagle_mc_server_support_reporterMC_INSTALLThis stream is used to send Outbound Topic of Build Installation LOG fileseagle_mc_stream_installerMC_INSTALLThis stream is used to install streams from zip archive. It is the old version of stream installer.
_out_star_extractsEGL_EagleML
This stream is used to extract data in STAR format
eagle_ml-2-0_default_out_streaming_tEGL_EagleML
This stream is similar to the 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 the latest Eagle technology which enables tasks to be executed faster improving throughput
eagle_ml-2-0_default_out_tEGL_EagleML
This stream is the second stage of the data export and manages the transformation process within the EJM framework
eagle_ml-2-0_default_validatepackageEGL_EagleML
This stream validates package integrity
eagle_ml-2-0_default_in_xml_sink_schd_managerEGL_EagleML
This stream is used to manage SINK Schedules
eagle_default_eds_warehouseEGL_EJM
This stream is used to represent errors in MC from Warehouse object load via pyruleservice correctly and to support reprocessing of failed records.
eagle_default_extractor_demandEGL_EJM
This stream is used to run the data extraction manually
eagle_default_file_distributionEGL_EJM
This stream is used to deliver files using external connection. Only FTP delivery type supported. (Note: it is part of eagle_ml_file_distribution package).
eagle_default_nuggetizer_restartEGL_EJM
This stream is used to restart the Eagle Nuggetizer. The Eagle Nuggetizer is a schedule-based workflow and is run by a defined schedule. The 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_iws_service_data_emptyEGL_EJM
This stream is used to group rule and include files that do not require an execution stream
eagle_ml-2-0_default_cm_acquire_dataEGL_EJM
The stream receives the information provided to the control message, adds the end of workflow trigger file and delivers all details of the Load Flow Control stream to orchestrate data loads
eagle_ml-2-0_default_cm_concatEGL_EJM
This stream concatenates several incoming files into one outgoing with a set name
eagle_ml-2-0_default_cm_construct_requestEGL_EJM
This stream generates the requester file from the EagleML Generic SMF identifiers to load the details from Bloomberg. It is used in the generic_load_enrichment workflow
eagle_ml-2-0_default_cm_control_messageEGL_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_processEGL_EJM
This stream is used to stop / kill workflows or MC streams
eagle_ml-2-0_default_cm_data_file_splitterEGL_EJM
The main purpose of the this stream is to increase the performance of the incoming GICSV (Generic Interface CSV) formatted files loading by splitting the 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_inEGL_EJM
This stream is a helper stream used by the Message Center Console and Automation Center to deliver data files to the incoming folder (/cmw/in)
eagle_ml-2-0_default_cm_datafile_controlEGL_EJM
This stream reads the trigger file from the eagle_ml-2-0_default_cm_datafile_task and makes a specified copy in the staging folder and then moves it to the specified stream for processing
eagle_ml-2-0_default_cm_datafile_taskEGL_EJM
This stream creates a trigger file with necessary information(stream name, file name, source stream name etc.) and sends it to the stream eagle_ml-2-0_default_cm_datafile_control
eagle_ml-2-0_default_cm_dfaEGL_EJMMC2This stream receives data files for the MC2 workflow execution
eagle_ml-2-0_default_cm_dishub_clientEGL_EJM
These streams are the EagleAccessFTP streams used to execute i2i delivery
eagle_ml-2-0_default_cm_dishub2spoke_clientEGL_EJM
eagle_ml-2-0_default_cm_disribute_to_nuggetizerEGL_EJM
This stream sends the incoming file into the nuggetizer folder, configured by the W_NGTZR_DIST_FOLDER setting
eagle_ml-2-0_default_cm_ea_ftp_readerEGL_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; and Sends the files for processing to the eagle_ml-2-0_default_cm_control_message stream
eagle_ml-2-0_default_cm_eas_distributionEGL_EJM
This stream gets EAS alerts as a TSR message, converts the TSR to format in accordance with the list of defined templates and send alerts via mail
eagle_ml-2-0_default_cm_ejm_reporterEGL_EJMMC2This 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_distributionEGL_EJM
This stream is used to distribute the results of the workflow to email
eagle_ml-2-0_default_cm_eofwEGL_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_execextractEGL_EJMMC2This stream is used to evaluate group condition and fill list of filter values, fill group prefix, build RTR for generic extract based on incoming task parameters, execute asynchronously generic extract workflow as a sub-process using the built RTR.
eagle_ml-2-0_default_cm_exectransformEGL_EJMMC2
MC2loadprofileexecutortransformstream
eagle_ml-2-0_default_cm_execute_pace_eventEGL_EJM
This stream is used to invoke a specific PACE event by name
eagle_ml-2-0_default_cm_execute_star_eventEGL_EJM
This stream is used to invoke a specific STAR Accounting event by name
eagle_ml-2-0_default_cm_execwkflEGL_EJM
This is the main stream in workflow execution
eagle_ml-2-0_default_cm_extract_validationEGL_EJMMC2This stream validates result of extraction – according to validation definition that should be defined for this task (task if more like framework that will execute validation logic).
It is designed to allow clients to validate extract and abort extract delivery in case if extract is invalid – if it lack viable information, if extract differ too much from baseline (or previous day) extract.
eagle_ml-2-0_default_cm_file_distributionEGL_EJM
This stream is used to deliver files. For example, for i2i workflow
eagle_ml-2-0_default_cm_
acquire
load_flow_
data
controlEGL_EJM
The stream receives the information provided to the control message, adds the end of workflow trigger file and delivers all details of the Load Flow Control stream to orchestrate data loads

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_
concat
healthcheckEGL_EJM
This
stream concatenates several incoming files into one outgoing with a set name
Message Center stream is used to validate MC2 is up and running, checks the health of MC2
eagle_ml-2-0_default_cm_
construct_request
monitoringEGL_EJM
This stream
generates the requester file from the EagleML Generic SMF identifiers to load the details from Bloomberg. It is used in the generic_load_enrichment workflow
monitors ALERTS and sends a notification to the eagle_ml-2-0_default_cm_
control_messageEGL_EJMThis 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
email_distribution stream if an alert occurs
eagle_ml-2-0_default_cm_
control_process
ndfaEGL_EJM
This stream is used to
stop / kill workflows or MC streams
initiate EJM workflows based on the file names being dropped in this stream
eagle_ml-2-0_default_cm_
data
ndfa_
file_splitter
execEGL_EJM
The main purpose of the this stream is to increase the performance of the incoming GICSV (Generic Interface CSV) formatted files loading by splitting the incoming file into several smaller and distributing files into Message Center processes in order to run parallel processing.

This stream determines for which workflow the incoming data file is intended and generates an event for this workflow
eagle_ml-2-0_default_cm_
data_load_cmw_in
notif_emailEGL_EJM
This stream
is a helper stream used by the Message Center Console and Automation Center to deliver data files to the incoming folder (/cmw/in)eagle_ml-
transforms the TSR to plain text format and sends it via email
eagle_ml-2-0_default_cm_
datafile_control
nuggetizerEGL_EJM
This stream
reads the trigger file from the
collects EagleML files, concatenates them into nuggets and sends them for further processing. It is used in the eagle_nuggetizer_workflow
eagle_ml-2-0_default_cm_nuggetizer_
datafile_task and makes a specified copy in the staging folder and then moves it to the specified stream for processing.
recoverEGL_EJM
This stream is used in troubleshooting for the eagle_nuggetizer_workflow. It also purges generic_load_enrichment stream
eagle_ml-2-0_default_cm_
datafile_task
pacepollEGL_EJM
This stream creates a trigger file with necessary information(stream name, file name, source stream name etc.) and sends it to the stream
MC2This stream is used to poll and check the status of Pace reports
eagle_ml-2-0_default_cm_
datafile_control
packerEGL_EJM
This stream is used to compress files to a ZIP archive
eagle_ml-2-0_default_cm_parallel_
dfa
execEGL_EJM
MC2

This stream
receives data files for the MC2 workflow execution.
is part of workflow of loading files in parallel
eagle_ml-2-0_default_cm_
dishub2spoke
purge_
client
archiveEGL_EJM
These streams are the EagleAccessFTP streams used to execute i2i delivery

This stream is used to purge or archive files from the local and FTP folders
eagle_ml-2-0_default_cm_
dishub
queue_
client
posterEGL_EJM
This stream is used to add information to the queue
eagle_ml-2-0_default_cm_
disribute
realtime_
to
ejm_
nuggetizer
statEGL_EJM
This stream
sends the incoming file into the nuggetizer folder, configured by the W_NGTZR_DIST_FOLDER setting
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_
ea
send_
ftp
to_
reader
wrfEGL_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; and Sends the files for processing to the eagle_ml-2-0_default_cm_control_message stream.
is used to send data files to the workflow loader when the profiled generic load is used
eagle_ml-2-0_default_cm_
eas_distribution
sequencerEGL_EJM
This stream
gets EAS alerts as a TSR message, converts the TSR to format in accordance with the list of defined templates and send alerts via mail
is used to check whether to process the message in queue
eagle_ml-2-0_default_cm_
ejm
sequencer_
reporter
cleanupEGL_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)
stream is used to clean up all the message in the queue for a workflow and to remove the current workflow from the queue
eagle_ml-2-0_default_cm_
email
sequencer_
distribution
schEGL_EJM
This stream is used to
distribute the results of the workflow to email.
check messages in the queue and send messages for processing
eagle_ml-2-0_default_cm_task_
eofw
executorEGL_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
receives the dataflow state from the database and stops processing if the workflow status is a negative acknowledgement (NACK). This stream derives the stream name to execute, using the task type and feed type, and triggers the execution using an ACQUIRE style message stream
eagle_ml-2-0_default_cm_task_
execebs
reporterEGL_
ExtractServiceMC2This stream is used to execute EBS requestseagle_ml-2-0_default_cm_execute_pace_eventEGL_EJMThis stream is used to invoke a specific PACE event by nameeagle_ml-2-0_default_cm_execute_star_eventEGL_EJMThis stream is used to invoke a specific STAR Accounting event by name
EJM
This stream generates acknowledgement (ACK / NACK) and task status reply messages. Task statuses are SUCCESS, FAILED, and NO_DATA (for a data extract that retrieved no database records). 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_
execwkfl
reportEGL_EJM
This stream is
the main stream in workflow execution
used to transform the TSR
eagle_ml-2-0_default_cm_
file_distribution
tsrEGL_EJM
This stream is used to
deliver files. For example, for i2i workflow
create and manage dependencies between multiple EJM tasks and oversees the fork and join functionality within the stream flow
eagle_ml-2-0_default_cm_
load_flow_control
unpackerEGL_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
is used to decompress files from any archive type (ZIP,GZIP,TARGZIP,TAR)
eagle_ml-2-0_default_cm_
mc2
unpacker_
healthcheck
execEGL_EJM
This
Message Center stream is used to validate MC2 is up and running, checks the health of MC2.
stream collects information about the extracted files from the archive and the update workflow state
eagle_ml-2-0_default_cm_uploader_
monitoring
dlvrEGL_EJM
This stream
monitors ALERTS and sends a notification to the
is used to send data files to the PACE Uploader for processing
eagle_ml-2-0_default_cm_user_
email_distribution stream if an alert occurs
syncEGL_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_
ndfa
xsdEGL_EJM
This stream is used to
initiate EJM workflows based on the file names being dropped in this stream.
perform the XSD validation of data files
eagle_ml-2-0_default_cm_
ndfa
w_
exec
setupEGL_EJM
This stream
determines for which workflow the incoming data file is intended and generates an event for this workflow
is used to configure the environment after the first EagleML installation. It creates cmw folders and sets the EagleVersion variable in the w_config_version.inc
eagle_ml-2-0_default_cm_
notif
wrkfl_
email
executorEGL_EJMMC2This stream
transforms the TSR to plain text format and sends it via email
executes the workflow rules
eagle_ml-2-0_default_cm_wrkfl_
nuggetizer
listenerEGL_EJMMC2This stream
collects EagleML files, concatenates them into nuggets and sends them for further processing. It is used in the eagle_nuggetizer_workflow.
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_
nuggetizer
wrkfl_
recover
reporterEGL_EJM
This stream
is used in troubleshooting for the eagle_nuggetizer_workflow.  It also purges the generic_load_enrichment.
creates a consolidated TSR for ALL workflows
eagle_ml-2-0_default_cm_xslt_exceptions_
pacepoll
accEGL_EJM
MC2This stream is used to poll and check the status of Pace reports

The XSLT Exceptions stream may be used in workflows after the XSLT transformation for Accounting Transaction object.  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_
packer
entEGL_EJM
This stream is used to compress files to a ZIP archive

The XSLT Exceptions stream may be used in workflows after the XSLT transformation for Entity Transaction object.  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_
parallel
exceptions_
execeagle_ml-2-0_default_cm_purge_archiveEGL_EJMThis stream is used to purge or archive files from the local and FTP folders
refEGL_EJM
This stream is part of workflow of loading files in parallel

The XSLT Exceptions stream may be used in workflows after the XSLT transformation for the Reference Transaction object.  Its main purpose is to catch exceptions generated by the XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errors
eagle_ml-2-0_default_cm_
queue
xslt_exceptions_
poster
wrhEGL_EJM
This stream is used to add information to the queue

The XSLT Exceptions stream may be used in workflows after the XSLT transformation for the Warehouse Transaction object.  Its main purpose is to catch exceptions generated by  the XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errors
eagle_ml-2-0_default_
cm
in_
realtime
xml_
ejm
delete_
stat
objectsEGL_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
delete records from the database. Supported object type groups include: SMF, Entity, Warehouse, Reference
eagle_ml-2-0_default_in_xml_
cm
delete_
refresh
splitter_
engine
isr_
cache
miEGL_
EagleML
EJM
This stream is used to
automate engine cache clearing during runtime
split the Generic Issuer file into several Issuer files and route them to the eagle_ml-2-0_default_
cm
in_
self
xml_
system_checkEGL_SSCThis stream is used to self-check the configuration
delete_objects stream
eagle_ml-2-0_default_in_xml_
cm
delete_
send
splitter_
to
smf_
wrf
miEGL_EJM
This stream is used to
send data files to the workflow loader when the profiled generic load is used
split the Generic SMF file into several Reference and SMF files and route them to the eagle_ml-2-0_default_in_xml_
cm
delete_
sequencerEGL_EJMThis stream is used to check whether to process the message in queueeagle_ml-2-0_default_cm_sequencer_cleanupeagle_ml-2-0_default_cm_transform_reportEGL_EJMThis stream is used to transform the TSReagle_ml-2-0_default_cm_tsrEGL_EJMThis stream is used to create and manage dependencies between multiple EJM tasks and oversees the fork and join functionality within the stream floweagle_ml-2-0_default_cm_unpackerEGL_EJMThis stream is used to decompress files from any archive type (ZIP,GZIP,TARGZIP,TAR)eagle_ml-2-0_default_cm_unpacker_execEGL_EJMThis stream collects information about the extracted files from the archive and the update workflow stateeagle_ml-2-0_default_cm_uploader_dlvrEGL_EJMThis stream is used to send data files to the PACE Uploader for processingeagle_ml-2-0_default_cm_user_syncEGL_EJMThis stream is used to synchronize the userID information defined on Eagle with the credentials required for the MicroStrategy applicationeagle_ml-2-0_default_cm_validate_by_xsdEGL_EJMThis stream is used to perform the XSD validation of data fileseagle_ml-2-0_default_cm_w_setupEGL_EJMThis stream is used to configure the environment after the first EagleML installation. It creates cmw folders and sets the EagleVersion variable in the w_config_version.inceagle_ml-2-0_default_cm_wrkfl_executorEGL_EJMMC2This stream executes the workflow ruleseagle_ml-2-0_default_cm_wrkfl_listenerEGL_EJMMC2This 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 eventeagle_ml-2-0_default_cm_wrkfl_reporterEGL_EJMThis stream creates a consolidated TSR for ALL workflowseagle_ml-2-0_default_cm_xslt_exceptions_accEGL_EJMThe XSLT Exceptions stream may be used in workflows after the XSLT transformation for Accounting Transaction object.  Its main purpose is to catch exceptions generated by XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errorseagle_ml-2-0_default_cm_xslt_exceptions_entEGL_EJMThe XSLT Exceptions stream may be used in workflows after the XSLT transformation for Entity Transaction object.  Its main purpose is to catch exceptions generated by XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errorseagle_ml-2-0_default_cm_xslt_exceptions_refEGL_EJMThe XSLT Exceptions stream may be used in workflows after the XSLT transformation for the Reference Transaction object.  Its main purpose is to catch exceptions generated by the XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errorseagle_ml-2-0_default_cm_xslt_exceptions_wrhEGL_EJMThe XSLT Exceptions stream may be used in workflows after the XSLT transformation for the Warehouse Transaction object.  Its main purpose is to catch exceptions generated by  the XSLT EditChecks from the transformed message and exclude records with exceptions, which are specified as errorseagle_ml-2-0_default_in_xml_acct_cashEGL_EagleMLThis stream is used to load the Accounting Cash objectseagle_ml-2-0_default_in_xml_acct_cash_no_splitEGL_EagleMLThis stream is used to load accounting cash objects.The incoming messages are processed sequentially in the order in which they are in the data fileeagle_ml-2-0_default_in_xml_acct_tradesEGL_EagleMLThis stream is used to load the Accounting Trade objectseagle_ml-2-0_default_in_xml_acct_trades_no_splitEGL_EagleMLThis stream is used to load Accounting Cash objects sequentiallyeagle_ml-2-0_default_in_xml_costbasis_adjEGL_EagleMLThis stream is used to load the Cost Basis Adjustment objecteagle_ml-2-0_default_in_xml_delete_objectsEGL_EJMThis stream is used to delete records from the database. Supported object type groups include: SMF, Entity, Warehouse, Referenceeagle_ml-2-0_default_in_xml_delete_splitter_isr_miEGL_EJMThis stream is used to split the Generic Issuer file into several Issuer files and route them to the eagle_ml-2-0_default_in_xml_delete_objects streameagle_ml-2-0_default_in_xml_delete_splitter_smf_mi
objects stream
eagle_tba_extract_cons_recordsEGL_EJM
This stream is used to clean up all the message in the queue for a workflow and to remove the current workflow from the queueeagle_ml-2-0_default_cm_sequencer_schEGL_EJMThis stream is used to check messages in the queue and send messages for processingeagle_ml-2-0_default_cm_task_executorEGL_EJMThis stream receives the dataflow state from the database and stops processing if the workflow status is a negative acknowledgement (NACK). This stream derives the stream name to execute, using the task type and feed type, and triggers the execution using an ACQUIRE style message streameagle_ml-2-0_default_cm_task_reporterEGL_EJMThis stream generates acknowledgement (ACK / NACK) and task status reply messages. Task statuses are SUCCESS, FAILED, and NO_DATA (for a data extract that retrieved no database records). 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

These streams are used to maintain the eagle_wrf_tba workflow. eagle_wrf_tba is a set of five independent workflows that may be run consecutively in straight-through mode or selectively in user/manual execution. The final step of each workflow allows the 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 to track the payoffs for each manager
eagle_tba_extract_mgr_alloc_recordsEGL_EJM
eagle_tba_extract_records_1EGL_EJM
eagle_tba_extract_t_mgr_allocEGL_EJM
eagle_tba_group_by_positionEGL_EJM
eagle_tba_run_consEGL_EJM
eagle_tba_run_earningsEGL_EJM
eagle_tba_t_consolidatedEGL_EJM
eagle_tba_t_mgr_allocEGL_EJM
eagle_tba_t_records_1EGL_EJM
eagle_tba_update_status_1EGL_EJM
eagle_trr_extract_cxlEGL_EJM
These streams are used to maintain the TRR SWAPS CXL RESET workflow. Multiple swaps may be targeted to be cancelled based on the swap underlying asset. This workflow updates the current reset process where multiple swaps may be targeted to reset based on the swap underlying asset id.  This process may be triggered thru panels or automated using IWS via the control message
eagle_trr_extract_qtrrEGL_EJM
eagle_trr_t_cxlEGL_EJM
eagle_trr_t_qtrrEGL_EJM
eagle_trs_common_preprocEGL_EJM
These streams are used to maintain the eagle_wrf_trs_upsize workflow
eagle_trs_filter_errorEGL_EJM
eagle_trs_reply_tEGL_EJM
eagle_trs_t_csv_trades_emlEGL_EJM
eagle_trs_upsize_preprocEGL_EJM
eagle_trs_xslt_cost_basis_adjEGL_EJM
eagle_wrf_cloud_extract_schdEGL_EJM
This stream is used to restart the eagle_wrf_cloud_extract workflow
eagle_wrf_csv_benchmark_returns_tskEGL_EJM
These streams transform CSV format to EagleML format using the rule service
eagle_wrf_csv_calendar_holiday_tskEGL_EJM
eagle_wrf_csv_calendar_tskEGL_EJM
eagle_wrf_csv_entity_generic_tskEGL_EJM
eagle_wrf_csv_entity_to_composite_tskEGL_EJM
eagle_wrf_csv_issue_fx_pc_rate_tskEGL_EJM
eagle_wrf_csv_issue_fx_rate_tskEGL_EJM
eagle_wrf_csv_issue_pc_price_tskEGL_EJM
eagle_wrf_csv_issue_price_tskEGL_EJM
eagle_wrf_csv_issuer_role_tskEGL_EJM
eagle_wrf_csv_position_generic_tskEGL_EJM
eagle_wrf_csv_smf_generic_tskEGL_EJM
eagle_wrf_csv_warehouse_nav_tskEGL_EJM
eagle_wrf_csv_warehouse_openlot_tskEGL_EJM
eagle_wrf_csv_wh_cash_activity_tskEGL_EJM
eagle_wrf_csv_wh_cash_flow_projection_tskEGL_EJM
eagle_wrf_csv_wh_close_lot_tskEGL_EJM
eagle_wrf_csv_wh_gl_balances_tskEGL_EJM
eagle_wrf_csv_wh_nav_month_end_tskEGL_EJM
eagle_wrf_csv_wh_trade_tskEGL_EJM
eagle_wrf_delta_extract_restartEGL_EJM
This stream is used to restart the eagle_wrf_delta_extract workflow
eagle_wrf_ebs_reload_datacache_schdEGL_EJM
This stream is used to
split the Generic SMF file into several Reference and SMF files and route them to
restart the eagle_
ml-2-0_default_in_xml_delete_objects streameagle_ml-2-0_default_in_xml_ent_no_splitEGL_EagleML
wrf_ebs_reload_datacache workflow
eagle_wrf_full_extract_restartEGL_EJM
This stream is used to
load the Entity objects sequentiallyeagle_ml-2-0_default_in_xml_entityEGL_EagleML
restart the eagle_wrf_full_extract workflow
eagle_wrf_generic_extract_mc2_schdEGL_EJM
This stream is used to
load the Entity objects
restart the eagle_wrf_generic_extract_mc2 workflow
eagle_
ml-2-0_default_in_xml_impairments
wrf_generic_extract_restartEGL_
EagleML
EJM
This stream is used to
load the Impairments object
restart the eagle_wrf_generic_extract workflow
eagle_
ml-2-0_default_in_xml_issuer_mi
wrf_generic_purge_archive_restartEGL_
EagleML
EJM
This stream is used to
split the Generic Issuer file into several Issuer files and route them to the eagle_ml-2-0_default_in_xml_reference streameagle_ml-2-0_default_in_xml_ref_extEGL_EagleML
restart the eagle_wrf_generic_purge_archive workflow
eagle_wrf_generic_purge_restartEGL_EJM
This stream is used to
load
restart the
extended schedule objects
eagle_
ml-2-0_default_in_xml_ref_no_split
wrf_generic_purge workflow
eagle_wrf_i2i_message_distributionEGL_
EagleML
EJM
This stream is used to
load the Reference objects. The incoming messages are processed sequentially in the order in which they are in the data fileeagle_ml-2-0_default_in_xml_referenceEGL_EagleML
deliver RTR/TSR/Data files (base64) 
eagle_wrf_i2i_restartEGL_EJM
This stream is used to
load the Reference objects
restart the eagle_wrf_i2i workflow
eagle_
ml-2-0_default_in_xml_smf_generic
wrf_i2i_sec_alias_sync_restartEGL_
EagleML
EJM
This stream is used to
load
restart the
Generic SMF objecteagle_ml-2-0_default_in_xml_smf_miEGL_EagleMLThis stream is used to split the Generic SMF file into several Reference and SMF files and route them to the eagle_ml-2-0_default_in_xml_smf_generic and eagle_ml-2-0_default_in_xml_reference streamseagle_ml-2-0_default_in_xml_userEGL_EagleML
eagle_wrf_i2i_sec_alias_sync workflow
eagle_wrf_pending_trades_extractEGL_EJM
These streams are used to maintain the eagle_wrf_pending_trades workflow
eagle_wrf_pending_trades_restartEGL_EJM
eagle_wrf_pending_trades_tEGL_EJM
eagle_wrf_tba_approve_restartEGL_EJM
eagle_wrf_tba_consolidation_restartEGL_EJM
This stream is used to
load the User objects
restart the eagle_wrf_tba_consolidation workflow
eagle_
ml-2-0_default_in_xml_warehouse
wrf_tba_mgr_alloc_restartEGL_
EagleML
EJM
This stream is used to
load the Warehouse objects (XMLDBAPI format)eagle_ml-2-0_default_in_xml_warehouse_preprocEGL_EagleML
restart the eagle_wrf_tba_mgr_alloc workflow
eagle_wrf_tba_process_restartEGL_EJM
This stream is used to
load the Warehouse objects (EagleML format)
restart the eagle_wrf_tba_process workflow
eagle_
ml-2-0_default_in_xml_washsale
wrf_trr_reset_demandEGL_
EagleMLThis stream is
EJM
These streams are used to
load the Accounting washSale object
restart the eagle_wrf_trr_reset workflow
eagle_
ml-2-0_default_out_extract_service
wrf_trr_reset_restartEGL_
ExtractServiceMC2This MC2 stream is used to extract data eagle_ml-2-0_default_out_q
EJM
reload_datacache_tskEGL_
EagleML
EJM
This stream is
the first stage of the data export and manages the query process within the EJM framework
used to reload EBS cache
eagle_ml-2-0_default_in_xml_
out
route_
star
to_
extracts
edsEGL_
EagleML
EJM
This stream is used to
extract data in STAR format
route EagleML data to EDS for load
eagle_
ml-2-0_
default
_out_streaming
_
t
ruleserviceEGL_
EagleMLThis stream is similar to the 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 the latest Eagle technology which enables tasks to be executed faster improving throughput.
ExtractServiceMC2These streams are used to execute requests in pyruleservice. It executes the 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 the orchestration tables to show it as an EJM task
eagle_iws_ruleserviceEGL_ExtractServiceMC2
eagle_ml-2-0_default_
out
cm_
t
execebsEGL_
EagleML
ExtractServiceMC2This stream is
the second stage of the data export and manages the transformation process within the EJM framework
used to execute EBS requests
eagle_ml-2-0_default_out_
validatepackage
extract_serviceEGL_
EagleML
ExtractServiceMC2This
stream validates package integrity
MC2 stream is used to extract data 
eagle_ml-2-0_extract_service_control_messageEGL_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 specific MC2 events
eagle
_service
_default_bbca_helperEGL_Generic
This stream performs transformation of the Bloomberg Corporate Actions to TagValue format
eagle_default_csv_raw_data_
empty
loadEGL_
IWS
Generic
This stream is used to
group the rules and include files that do not require an execution stream
load Global Values (Columns)
eagle_
tba
default_
extract
in_
cons
csv_
records
warehouseEGL_
EJMThese streams are used to maintain the eagle_wrf_tba workflow. eagle_wrf_tba is a set of five independent workflows that may be run consecutively in straight-through mode or selectively in user/manual execution. The final step of each workflow allows the 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 to track the payoffs for each manager.eagle_tba_extract_mgr_alloc_recordsEGL_EJMeagle_tba_extract_records_1EGL_EJMeagle_tba_extract_t_mgr_allocEGL_EJMeagle_tba_group_by_positionEGL_EJMeagle_tba_run_consEGL_EJMeagle_tba_run_earningsEGL_EJMeagle_tba_t_consolidatedEGL_EJMeagle_tba_t_mgr_allocEGL_EJMeagle_tba_t_records_1EGL_EJMeagle_tba_update_status_1EGL_EJMeagle_trr_extract_cxlEGL_EJMThese streams are used to maintain the TRR SWAPS CXL RESET workflow. Multiple swaps may be targeted to be cancelled based on the swap underlying asset. This workflow updates the current reset process where multiple swaps may be targeted to reset based on the swap underlying asset id.  This process may be triggered thru panels or automated using IWS via the control message.eagle_trr_extract_qtrrEGL_EJMeagle_trr_t_cxlEGL_EJMeagle_trr_t_qtrrEGL_EJMeagle_trs_common_preprocEGL_EJMThese streams are used to maintain the eagle_wrf_trs_upsize workfloweagle_trs_filter_errorEGL_EJMeagle_trs_reply_tEGL_EJMeagle_trs_t_csv_trades_emlEGL_EJMeagle_trs_upsize_preprocEGL_EJMeagle_trs_xslt_cost_basis_adjEGL_EJMeagle_wrf_cloud_extract_schdEGL_EJMThis stream is used to restart the eagle_wrf_cloud_extract workfloweagle_wrf_csv_benchmark_returns_tskEGL_EJMThese streams transform CSV format to EagleML format using the rule serviceeagle_wrf_csv_calendar_holiday_tskEGL_EJMeagle_wrf_csv_calendar_tskEGL_EJMeagle_wrf_csv_entity_generic_tskEGL_EJMeagle_wrf_csv_entity_to_composite_tskEGL_EJMeagle_wrf_csv_issue_fx_pc_rate_tskEGL_EJMeagle_wrf_csv_issue_fx_rate_tskEGL_EJMeagle_wrf_csv_issue_pc_price_tskEGL_EJMeagle_wrf_csv_issue_price_tskEGL_EJMeagle_wrf_csv_issuer_role_tskEGL_EJMeagle_wrf_csv_position_generic_tskEGL_EJMeagle_wrf_csv_smf_generic_tskEGL_EJMeagle_wrf_csv_warehouse_nav_tskEGL_EJMeagle_wrf_csv_warehouse_openlot_tskEGL_EJMeagle_wrf_csv_wh_cash_activity_tskEGL_EJMeagle_wrf_csv_wh_cash_flow_projection_tskEGL_EJMeagle_wrf_csv_wh_close_lot_tskEGL_EJMeagle_wrf_csv_wh_gl_balances_tskEGL_EJMeagle_wrf_csv_wh_nav_month_end_tskEGL_EJMeagle_wrf_csv_wh_trade_tskEGL_EJMeagle_wrf_ebs_reload_datacache_schdEGL_EJMeagle_wrf_delta_extract_restartEGL_EJMThis stream is used to restart the eagle_wrf_delta_extract workfloweagle_wrf_full_extract_restartEGL_EJMThis stream is used to restart the eagle_wrf_full_extract workfloweagle_wrf_generic_extract_mc2_schdEGL_EJMThis stream is used to restart the eagle_wrf_generic_extract_mc2 workfloweagle_wrf_generic_extract_restartEGL_EJMThis stream is used to restart the eagle_wrf_generic_extract workfloweagle_wrf_generic_purge_archive_restartEGL_EJMThis stream is used to restart the eagle_wrf_generic_purge_archive workfloweagle_wrf_generic_purge_restartEGL_EJMThis stream is used to restart the eagle_wrf_generic_purge workfloweagle_wrf_i2i_message_distributionEGL_EJMThis stream is used to deliver RTR/TSR/Data files (base64) eagle_wrf_i2i_restartEGL_EJMThis stream is used to restart the eagle_wrf_i2i workfloweagle_wrf_i2i_sec_alias_sync_restartEGL_EJMThis stream is used to restart the eagle_wrf_i2i_sec_alias_sync workfloweagle_wrf_pending_trades_extractEGL_EJMThese streams are used to maintain the eagle_wrf_pending_trades workfloweagle_wrf_pending_trades_tEGL_EJMeagle_wrf_pending_trades_restartEGL_EJMThis stream is used to restart the eagle_wrf_pending_trades workfloweagle_wrf_tba_approve_restartEGL_EJMThis stream is used to restart the eagle_wrf_tba_approve workfloweagle_wrf_tba_consolidation_restartEGL_EJMThis stream is used to restart the eagle_wrf_tba_consolidation workfloweagle_wrf_tba_mgr_alloc_restartEGL_EJMThis stream is used to restart the eagle_wrf_tba_mgr_alloc workfloweagle_wrf_tba_process_restartEGL_EJMThis stream is used to restart the eagle_wrf_tba_process workfloweagle_wrf_trr_reset_restartEGL_EJMThese streams are used to restart the eagle_wrf_trr_reset workfloweagle_wrf_trr_reset_demandEGL_EJMreload_datacache_tskEGL_EJMThis stream is used to reload EBS cacheeagle_default_file_distributionEGL_EJMThis stream was used to deliver files to another server. For example, within i2i workflow.
It is obsolete now, but documented for backwards compatibility.eagle_default_deployMC_INSTALLThis stream was used to install EagleML services.  It is obsolete now, but documented for backwards compatibility.eagle_default_deploy_monitoringMC_INSTALLThis stream was used to install the monitoring.  It is obsolete now, but documented for backwards compatibility.eagle_ml-2-0_default_in_xml_smf_customEGL_EagleMLThis stream was used to load the customSMF object. It is obsolete, but documented for backwards compatibility.eagle_sv_key_inst_distribEGL_Generic

These streams are Distribution streams utilizing the entity and instance folder. Were used to group and deliver data to pre-created MC instances. They are obsolete now, but documented for backwards compatibility.

eagle_sv_key_inst_procEGL_Generic
Generic
This stream uses a preprocessor rule file (*.prf), to sequentially execute the 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_smEGL_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_tEGL_Generic
This stream performs transformation from CSV to EagleML(XMLDBAPI)
eagle_default_in_csv_warehouse_upsertEGL_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_performanceCLPEGL_Generic
This stream uses a preprocessor rule file (*.prf), to sequentially execute the transformation step from PIPE Performance to EagleML and sends a result message for load to the stream eagle_ml-2-0_default_in_xml_warehouse_preproc
eagle_default_in_pipe_performanceCLP_tEGL_Generic
This stream performs PIPE Performance to EagleML transformation
eagle_default_in_pipe_posEGL_Generic
This stream uses a preprocessor rule file (*.prf), to sequentially execute the transformation step from PIPE Position to EagleML and sends a result message for load to the stream eagle_ml-2-0_default_in_xml_warehouse_preproc
eagle_default_in_pipe_pos_tEGL_Generic
This stream performs PIPE Position to EagleML transformation
eagle_default_raw_common_values_loadEGL_Generic
These streams are used to load Global Values (Columns)
eagle_default_raw_create_tableEGL_Generic
eagle_default_raw_create_viewEGL_Generic
eagle_default_raw_data_header_loadEGL_Generic
eagle_sv_key_inst_distribEGL_GenericObsoleteThese streams are Distribution streams utilizing the entity and instance folder. Were used to group and deliver data to pre-created MC instances. They are obsolete now, but documented for backwards compatibility
eagle_sv_key_inst_procEGL_GenericObsolete
eagle_default_file_indexerEGL_IWS
This stream identifies all references between different rules and creates a dependency tree for internal use in EBS/IWS/MT
eagle_default_file_move_or_copyEGL_IWS
This stream is used to copy or move the file to a specified destination directory. It is primarily used by the "task move" shape in IWS
eagle_iws_cacheEGL_IWS
This stream is used to cache IWS resources
eagle_iws_db_apiEGL_IWS
Allows some Integration and Workflow Studio requests to be converted into safe bind-based alternatives.
eagle_iws_delete_fileEGL_IWS
This stream is used by IWS to remove local files
eagle_iws_eagleml_panelEGL_IWS
This stream is used by IWS to interact and execute the Xpanels
eagle_iws_export_solutionEGL_IWS
This stream compiles IWS solutions with the Java tool on the back-end
eagle_iws_export_solution_mcpkgEGL_IWS
This stream compiles IWS solutions and sends the pkg files for the processed IWS solution
eagle_iws_find_and_get_fileEGL_IWS
This stream is used by IWS to locate files
eagle_iws_get_fileEGL_IWS
This stream is used by IWS to download files
eagle_iws_import_streamEGL_IWS
This stream installs streams while migrating MC packages
eagle_iws_import_stream_requestEGL_IWS
This stream is used by IWS to start the import process requests
eagle_iws_import_stream_wEGL_IWS
This stream uses files processed by the eagle_iws_import_stream_request and starts the process of the stream installation
eagle_iws_infoEGL_IWS
This stream is the IWS authorization stream
eagle_iws_list_filesEGL_IWS
This stream is used by IWS to download the list of files for a specific directory
eagle_iws_monitoring_apiEGL_IWS
This stream is used by the EJM Monitoring Tool to download task statistics
eagle_iws_rename_fileEGL_IWS
This stream is used by IWS to rename solution files
eagle_iws_save_fileEGL_IWS
This stream is used by IWS to upload files to the box
eagle_iws_shellEGL_IWS
This is the IWS utils stream
eagle_service_data_emptyEGL_IWS
This stream is used to group the rules and include files that do not require an execution stream
eagle_ml-2-0_default_cm_self_system_checkEGL_SSC
This stream is used to self-check the configuration
eagle_default_deployMC_INSTALLObsoleteThis stream was used to install EagleML services.  It is obsolete now, but documented for backwards compatibility
eagle_default_deploy_demandMC_INSTALL
This stream is used to deploy the rules and services manually
eagle_default_deploy_restart_mcMC_INSTALL
This stream is designed to restart MC services while deploying a snapshot or a release package
eagle_default_deploy_serviceMC_INSTALL
This stream is used to deploy services
eagle_default_deploy_supportMC_INSTALL
This 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_rollbackMC_INSTALL
This 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_iws_server_installerMC_INSTALL
This stream uses the eagle_iws_import_stream_w to the install processed streams
eagle_iws_server_supportMC_INSTALL
This stream uses the eagle_iws_import_stream_w to copy source files for installing streams
eagle_mc_import_stream_requestMC_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_wMC_INSTALL
This stream is used to import streams. The incoming file is a ZIP which has two types of files: *.files.b64 - base64 encoded ZIPs with files to be installed, starting from estar/  ; *.pkg.b64 - base64 encoded ZIPs with *.pkg files to create the streams. The process first copies the files then runs the installation scripts for .pkg
eagle_mc_import_support_dataMC_INSTALL
This stream is used to load sources/code categories/code values/code transaction object
eagle_mc_server_installerMC_INSTALL
This stream is used to deploy a snapshot or a release
eagle_mc_server_installer_ftpMC_INSTALL
This stream is used to deploy a snapshot or a release from FTP
eagle_mc_server_installer_mqMC_INSTALL
This stream is used to read JMS/MQ  and send files to the appropriate stream
eagle_mc_server_installer_mq_decoderMC_INSTALL
This stream is used to decode base64 file to zip archive and send the zip to eagle_mc_server_installer
eagle_mc_server_supportMC_INSTALL
This stream is used to perform basic commands during deployment. For example CHMOD, MKDIR, REINIT etc.
eagle_mc_server_support_amq_monitorMC_INSTALLObsoleteThis stream is used to send email notifications about actual stream information. The stream is out of date. It is maintained for backward compatibility
eagle_mc_server_support_import_dataflowMC_INSTALL
This stream is used to install the Data Vendor Console dataflows
eagle_mc_server_support_import_streamMC_INSTALL
This stream is used to import a stream package in Message Center
eagle_mc_server_support_jmsMC_INSTALL
This stream is used to perform  basic commands for JMS using broadcast. This stream also performs eagle_mc_server_support_jms_exec in all instances
eagle_mc_server_support_jms_execMC_INSTALL
This stream is used to perform  basic commands for JMS. For example: JMSSTATUS, JMSLIST, JMSSTOP, JMSSTART, JMSPROCINFO etc.
eagle_mc_server_support_reporterMC_INSTALL
This stream is used to send Outbound Topic of Build Installation LOG files
eagle_mc_stream_installerMC_INSTALL
This stream is used to install streams from zip archive. It is the old version of stream installer
prod_parallel_deployment_serviceEGL_PROD_PAR
This stream is used to receive Production Parallel endpoint requests to execute the installation and manage the Production Parallel service
prod_parallel_broadcast_manageEGL_PROD_PAR
This stream is used to broadcast Production Parallel endpoint requests