The Spotfire Streaming Adapter for EMS is implemented as a suite of five single-purpose global Java operators, each handling one of the following actions:
-
EMS Consumer, which connects to a EMS destination on the target server and reads messages from it.
-
EMS Producer, which connects to a EMS destination on the target server and sends messages to it.
-
EMS Connect, which manually connects or disconnects from the target EMS server.
-
EMS Ack, which acknowledges receipt of messages from the server (when using the
CLIENT_ACKNOWLEDGEor other explicit acknowledgement mode). -
EMS Commit, which either commits or rolls back transactions on a transacted EMS session.
The EMS operators allow a StreamBase application to connect to a Spotfire EMS server and exchange messages with it. The five EMS operators are based on the JMS suite of operators and as such have an identical configuration and usage model. The JMS and EMS operators are described together on the following page of the Authoring Guide: Using the JMS and TIBCO EMS Operators.