Contents
The TIBCO StreamBase® Adapters for TIBCO FTL® map operations allow a StreamBase application to perform various operations on FTL maps, including getting and setting messages, iterating through a map's messages and removing messages from a map.
-
TIBCO StreamBase® Map Get Operator For TIBCO FTL, which allows a StreamBase application to retrieve a message with a specific key from a specified FTL map.
-
TIBCO StreamBase® Map Iterate Operator For TIBCO FTL, which allows a StreamBase application to add a message with a specific key to a specified FTL map.
-
TIBCO StreamBase® Map Remove Operator For TIBCO FTL, which allows a StreamBase application to retrieve all messages from a specified FTL map in one operation.
-
TIBCO StreamBase® Map Set Operator For TIBCO FTL, which allows a StreamBase application to remove a message with a specific key from a specified FTL map.
These adapters connect to the FTL realm server on start-up, and can additionally be disconnected and reconnected via their Control input port.
The adapters support a subset of StreamBase data types that contains tuples and lists, though lists may not contain elements of type list.
The adapters are configured through several properties set in their Properties view in StreamBase Studio. The properties include parameters used to connect to the realm server and the application and endpoint names.
This adapter requires access to the JAR file that implements the TIBCO FTL Java API on your system, and any files referenced
by that JAR file.
The adapter has been tested with FTL version 3.1, though it will likely work with newer FTL API versions as well. To make
the TIBCO FTL Java API
available to the adapter, copy TIBFTL_ROOT/lib/tibftl.jar to $STREAMBASE_HOME/lib/ext.
The tibftl.jar file, in turn, relies on various native libraries, such as tibftljni.dll on Windows
and tibftljni.so on Linux. As with tibftl.jar, these native libraries are supplied as part of your TIBCO
FTL installation and are not shipped with StreamBase. Make sure these files are locatable by the FTL JAR file
by placing their parent directory on the PATH.
All four adapters have the following adapter properties:
| Property | Description |
|---|---|
| Connect on Startup | If enabled, the adapter connects to the realm server when it starts. |
| Realm Server URLs | A pipe-delimited ("|") list of realm server URLs to which to connect (e.g. http://localhost:8080|http://localhost:8181). Should the first server in the list become unavailable, the adapter will automatically try to connect to the next one in
the list, and so on.
|
| Username | The realm server username. |
| Password | The realm server password. |
| Application Name | The FTL application, which includes a set of endpoints and formats as configured in the realm server. |
| Application Instance | The FTL application instance. |
| Endpoint Name | The FTL endpoint, which abstracts the transport details. |
| Remove Map On Disconnect | When checked, this causes the adapter to remove the map from the FTL realm before disconnecting from it. |
| Log Level | Controls the level of verbosity the adapter uses to send notifications to the console. This setting can be higher than the containing application's log level. If set lower, the system log level is used. Available values, in increasing order of verbosity, are: OFF, ERROR, WARN, INFO, DEBUG, TRACE. |
| FTL Library Log Level | The log level used by the FTL library. Multiple FTL input and output adapter instances share the most verbose level configured in any adapter. |
Some of the adapters also offer additional properties:
| Property | Description |
|---|---|
| Edit Schema Tab | These adapters have an additional tab named "Edit Schema", where the expected schema of incoming FTL messages must be specified. |
| Property | Description |
|---|---|
| Message Formats Tab | Use this tab to specify the names of the message formats used by the adapter. Top-level Message Format describes the name of the FTL message, and the Nested Message Formats list specifies the format names of any nested messages (i.e. fields of type Message). |
Each of the four FTL Map adapters have at least one input port, with schemas described in this section.
This adapter only has one input port, which receives various commands described in this section. The port has the following schema:
| Field Name | Field Type | Description |
|---|---|---|
| Command | string | The name of the operation to be performed. Valid values are:
|
| FTLMapName | string | Name of the FTL map from which to retrieve the message (used by the Get commmand). If the map doesn't exist, it will be automatically created before executing the operation.
|
| FTLKeyName | string | Key of the message to fetch in the FTL map (used by the Get commmand).
|
| GroupID | string | Identifier of the group to join or leave (used by the JoinGroup and LeaveGroup commmands).
|
| IsObserver | boolean | Whether to join the group as a member (false) or an observer (true) (used by the JoinGroup commmand).
|
| GroupMemberDescriptor | string | JSON string to use as a group member decriptor (used by the JoinGroup commmand).
|
| GroupActivationInterval | double | Number of milliseconds to use as an activation interval (used by the JoinGroup commmand).
|
This adapter only has one input port, which receives various commands described in this section. The port has the following schema:
| Field Name | Field Type | Description |
|---|---|---|
| Command | string | The name of the operation to be performed. Valid values are:
|
| FTLMapName | string | Name of the FTL map from which to retrieve the messages (used by the Iterate commmand). If the map doesn't exist, it will be automatically created before executing the operation.
|
| FTLLockMap | boolean | If set to true, the FTL map will be locked during the operation to avoid contention from other adapters.
|
| GroupID | string | Identifier of the group to join or leave (used by the JoinGroup and LeaveGroup commmands).
|
| IsObserver | boolean | Whether to join the group as a member (false) or an observer (true) (used by the JoinGroup commmand).
|
| GroupMemberDescriptor | string | JSON string to use as a group member decriptor (used by the JoinGroup commmand).
|
| GroupActivationInterval | double | Number of milliseconds to use as an activation interval (used by the JoinGroup commmand).
|
This adapter only has one input port, which receives various commands described in this section. The port has the following schema:
| Field Name | Field Type | Description |
|---|---|---|
| Command | string | The name of the operation to be performed. Valid values are:
|
| FTLMapName | string | Name of the FTL map from which to remove the message (used by the Remove commmand). If the map doesn't exist, it will be automatically created before executing the operation.
|
| FTLKeyName | string | Key of the message to remove from the FTL map (used by the Remove commmand).
|
| FTLLockMap | string | If set to true, the FTL map will be locked during the operation to avoid contention from other adapters.
|
| GroupID | string | Identifier of the group to join or leave (used by the JoinGroup and LeaveGroup commmands).
|
| IsObserver | boolean | Whether to join the group as a member (false) or an observer (true) (used by the JoinGroup commmand).
|
| GroupMemberDescriptor | string | JSON string to use as a group member decriptor (used by the JoinGroup commmand).
|
| GroupActivationInterval | double | Number of milliseconds to use as an activation interval (used by the JoinGroup commmand).
|
This adapter has two input ports, one which receives various commands (described in this section), and one which receives tuples to be placed in the FTL map as messages.
The Command port has the following schema:
| Field Name | Field Type | Description |
|---|---|---|
| Command | string | The name of the operation to be performed. Valid values are:
|
| FTLMapName | string | Name of the FTL map from which to retrieve the message (used by the Get commmand). If the map doesn't exist, it will be automatically created before executing the operation.
|
| FTLKeyName | string | Key of the message to fetch in the FTL map (used by the Get commmand).
|
| GroupID | string | Identifier of the group to join or leave (used by the JoinGroup and LeaveGroup commmands).
|
| IsObserver | boolean | Whether to join the group as a member (false) or an observer (true) (used by the JoinGroup commmand).
|
| GroupMemberDescriptor | string | JSON string to use as a group member decriptor (used by the JoinGroup commmand).
|
| GroupActivationInterval | double | Number of milliseconds to use as an activation interval (used by the JoinGroup commmand).
|
The second input port, used to set messages in an FTL map, expects its schema to have at least the following fields:
| Field Name | Field Type | Description |
|---|---|---|
| FTLMapName | string | Name of the FTL map on which to set the message. If the map doesn't exist, it will be automatically created before executing the operation. |
| FTLKeyName | string | Key to assign to the message in the FTL map. |
All other fields will be treated as values to be set on the outgoing FTL message.
Each of the four FTL Map adapters have at least one output port, to issue status, information and error tuples. The schema for this port is the same for all four adapters and is as follows:
| Field Name | Field Type | Description |
|---|---|---|
| Status | string | Describes the type of event (Error, Success, etc.) |
| Time | timestamp | The time at which this status tuple was emitted. |
| Info | list<tuple> | A list of additional information strings, each contained in a tuple with a name / value pair. |
In addition to this status output port, some adapters also have other output port as described in the follwing subsections.
This adapter has a second output port to emit incoming FTL messages as tuples.
When it receives a Get command, the MapGet adapter emits a tuple on its second output port representing the FTL message it retrieved from the map.
The port's schema is derived from the Edit Schema tab of the adapter's property view and can contain a subset of StreamBase
data types, including lists and (nested) tuples to accommodate hierarchy in FTL messages. FTL message fields are mapped to
tuple fields by case-sensitive name. List fields may contain elements of type double, long, string, timestamp, or tuple. In
addition to the fields specified on the Edit Schemas tab, each tuple will also have two extra fields set automatically to
indicate the map it came from and the key it was assigned in the map:
| Field Name | Field Type | Description |
|---|---|---|
| FTLMapName | string | Name of the FTL map from which this tuple was retrieved. If no message was found in the FTL map with the FTLKeyName specified in the Get command, this field will be set to null.
|
| FTLKeyName | string | Key of the message in the FTL map. If no message was found in the FTL map with the FTLKeyName specified in the Get command, this field will be set to null.
|
This adapter has a second output port to emit incoming FTL messages as tuples.
When it receives an Iterate command, the MapIterate adapter emits a tuple on its second output port for each FTL message contained in the specified map,
ending with a marker tuple that has null values in its FTLMapName and FTLKeyName fields to indicate the end of the iteration
process.
The port's schema is derived from the Edit Schema tab of the adapter's property view and can contain a subset of StreamBase data types, including lists and (nested) tuples to accommodate hierarchy in FTL messages. FTL message fields are mapped to tuple fields by case-sensitive name. List fields may contain elements of type double, long, string, timestamp, or tuple. In addition to the fields specified on the Edit Schemas tab, each tuple will also have two extra fields set automatically to indicate the map it came from and the key it was assigned in the map:
| Field Name | Field Type | Description |
|---|---|---|
| FTLMapName | string | Name of the FTL map from which this tuple was retrieved, or null if this is the end of the iteration operation.
|
| FTLKeyName | string | Key of the message in the FTL map, or null if this is the end of the iteration operation.
|
In processing incoming FTL messages, the adapters convert FTL data types to StreamBase data types (or vice-versa). As shown in the table below, each FTL type has a single corresponding StreamBase type. When an attempt to perform an invalid conversion occurs, a one-time warning for the field is displayed and the corresponding field in the tuple is set to null (or in the case of StreamBase-to-FTL conversions, the FTL field is omitted from the message).
| FTL Type | StreamBase Type |
|---|---|
| DATETIME | timestamp |
| DATETIME_ARRAY | list<timestamp> |
| DOUBLE | double |
| DOUBLE_ARRAY | list<double> |
| LONG | long |
| LONG_ARRAY | list<long> |
| MESSAGE | tuple |
| MESSAGE_ARRAY | list<tuple> |
| OPAQUE | blob |
| STRING | string |
| STRING_ARRAY | list<string> |
The TIBCO FTL Subscribing Input adapter uses typecheck messages to help you configure the adapter in your StreamBase application. In particular, the adapter generates typecheck messages when a required property has not been specified, the control input schema is missing a required field, or an input or output schema contains unsupported StreamBase data types.
The adapter generates messages on the status port during runtime under various conditions, including:
-
The adapter connects, or fails to connect, to the realm server during start-up.
-
An FTL message is acknowledged.
-
The adapter is administratively disabled by the realm server.
-
The adapter receives an advisory message.
-
The adapter fails to dispatch an event on its event queue.
-
The adapter fails to process an incoming FTL message.
-
The adapter is suspended or resumed.
When suspended, the TIBCO FTL Subscribing Input Adapter disconnects from the realm server and stops processing incoming FTL messages.
When resumed, the adapter re-connects to the realm server, if it had been connected before being suspended, and resumes processing incoming FTL messages.