Using the TIBCO ActiveSpaces Operators

The TIBCO ActiveSpaces connectivity solution is implemented as a suite of six global Java operators that allow a StreamBase application to connect to an ActiveSpaces Data Grid, and that allow the application to perform operations on the tables and rows of that grid.

In addition to the ability to get, put and delete tuples to and from a data grid, a number of other operations are supported using the appropriate operator. The complete list of supported operations and operators is described below.

The different ActiveSpaces operators share a connection to the same data grid (and optionally the same table), provided they are configured to do so. Each operator lists the data grids available in corresponding combo box settings (see Properties: Operator Properties Tab). The lists are specified in a dedicated section of the application's sbd.sbconf file. Here is an example of such a section, containing all possible settings (either active or commented out):

<?xml version="1.0" encoding="UTF-8"?>

<streambase-configuration xmlns:xi="http://www.w3.org/2001/XInclude"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="http://www.streambase.com/schemas/sbconf/">

  <java-vm>
    <param name="jvm-args" value="            
      -XX:+UseParNewGC
      -XX:+UseConcMarkSweepGC
      -XX:+CMSParallelRemarkEnabled
    "/>

    <!-- Edit the following lines to reflect your TIBCO ActiveSpaces 
         installation directory. -->
    <jar file="${TIBDG_ROOT}/lib/tibdg.jar"/>
    <library path="${TIBDG_ROOT}/bin"/>
    <library path="${TIBDG_ROOT}/lib"/>
  </java-vm>

  <adapter-configurations>
        
    <!-- This section contains the configuration settings for the ActiveSpaces 
         operators -->
    <adapter-configuration name="activespaces">
        
      <section name="datagrid-definition">
        <!-- ALWAYS REQUIRED. This is the ID that will appear in the 
             adapter's 'DataGrid Definition' drop-down -->
        <setting name="id" val="TestGrid"/>

        <!-- This is the DataGrid ID as specified by the AS server. 
             Leave empty to connect to the default grid -->                
        <setting name="datagrid-id" val="_default"/>
                
        <setting name="datagrid-url" val="http://localhost:8080"/>
        <setting name="datagrid-secondary-url" val="http://localhost:8081"/>
                
        <setting name="transacted-session" val="false"/>
                
        <!-- -1 means use default value -->
          <!-- 
             When set, these get passed along to the ActiveSpaces Connection 
             object as the following properties:
             connection-timeout-seconds: 
                 Connection.TIBDG_CONNECTION_PROPERTY_DOUBLE_TIMEOUT             
                 ("com.tibco.tibdg.timeout", introduced in ActiveSpaces 3.0.0)
             connect-wait-time-seconds:  
                 Connection.TIBDG_CONNECTION_PROPERTY_DOUBLE_CONNECT_WAIT_TIME   
                 ("com.tibco.tibdg.connectwaittime", introduced in ActiveSpaces 3.2.0)
             connect-retries:            
                 Connection.TIBDG_CONNECTION_PROPERTY_LONG_REALM_CONNECT_RETRIES 
                 ("com.tibco.tibdg.realmconnectretries", introduced in ActiveSpaces 4.1.0)
          -->
        <setting name="connection-timeout-seconds" val="-1"/>
        <setting name="connect-wait-time-seconds" val="-1"/>
        <setting name="connect-retries" val="-1"/>
                
        <!-- Binding strategy-related settings. -1 means use default value -->
        <setting name="binding-strategy" val="-1"/> <!-- 0: RANDOM, 1: NAMED -->
        <setting name="connect-numresponses" val="-1"/> 
            <!-- RANDOM strategy only, otherwise ignored -->
        <setting name="connect-proxynames" val=""/> 
            <!-- Pipe-delimited list of names. NAMED strategy only, otherwise ignored -->

        <!--
        <setting name="authentication-username" val="YourUserName"/>
        <setting name="authentication-password" val="YourPassword"/>
        <setting name="trust-all" val="true"/>
        <setting name="trust-filename" val="C:/filename"/>
        -->
      </section>
        
      <!-- Define other DataGrids here -->
                
    </adapter-configuration>
  </adapter-configurations>
</streambase-configuration>

In each <section name="datagrid-definition">, the <setting id="SomeName"> tag will be listed in the Operator Properties tab of each operator's Properties view.

A best practice is to define your data grid before placing operator instances on the canvas, so that the lists are already available in the Properties view and the operators can be configured right away.

This section describes the properties you can set for a TIBCO ActiveSpaces operator, using the various tabs of the Properties view in StreamBase Studio.

Each operator has only one input port, used to receive commands describing an operation to be performed on the ActiveSpaces data grid (such as Get, Put, Connect, and so on). The schema for each operator is different because different operations require different parameters.

Every operator has only one fixed output port, used to deliver the results of executing operator commands. The Get, Put, Delete and Query operators additionally have one optional Status output port if the operator's Enable Status Port option is checked.

When operating on ActiveSpaces rows, the fields of the StreamBase tuple and corresponding columns of ActiveSpaces rows are expected to match in the following ways:

The table below lists all the type translations supported by the operator.

The StreamBase installation comes with a sample demonstrating the use of this operator. To load the sample in StreamBase Studio, select File → Load StreamBase Sample and look under the Extending StreamBase section for an entry called ActiveSpaces Operator.

Back to Top ^