Using the TIBCO ActiveSpaces Operators

The TIBCO ActiveSpaces connectivity solution is implemented as a suite of 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 adapter configuration file. The following example is the ActiveSpaces.conf file used in the ActiveSpaces Operator sample:

name = "ActiveSpaces.conf"
type = "com.tibco.ep.streambase.configuration.adapter"
version = "1.0.0"
configuration = {
        
  // An adapter group type defines a collection of EventFlow adapter 
  // configurations, indexed by adapter type.
  AdapterGroup = {
        
    // A collection of EventFlow adapter configurations, indexed by adapter type. 
    // This key is required and must contain at least one configuration.
    adapters = {
  
      // The root section for an EventFlow adapter configuration.
      activespaces = {
        
        // Section list. This key is optional and has no default value.
        sections = [
        
          // A configuration for an EventFlow adapter named section.
          {     
            // Section name. The value does not have to be unique; that is, 
            // you can have multiple sections with the same name in the  
            // same array of sections. This key is required.
            name = "datagrid-definition"
            // Section property bag. All values must be strings. This 
            // key is optional and has no default value.
            settings = {
              id = "TestGrid"
              binding-strategy = "-1"
              connect-numresponses = "-1"
              connect-proxynames = ""
              connect-retries = "-1"
              connect-wait-time-seconds = "-1"
              connection-timeout-seconds = "-1"
              datagrid-id = "_default"
              datagrid-secondary-url = "http://localhost:8081"
              datagrid-url = "http://localhost:8080"            
              transacted-session = "false"
              datagrid-id = "_default"
              connect-numresponses = "-1"
              connect-proxynames = ""
              authentication-username = "YourUserName"
              authentication-password = "YourPassword"
              trust-all = "true"
              trust-filename = "C:/filename"
            }
          }
        ]
      }
    }
  }
}

In each section named datagrid-definition, the value of the id setting identifies this particular section (in other words, this particular data grid definition) and will be listed in the Operator Properties tab's DataGrid Definition drop-down setting in each operator's Properties view. Multiple operators can be made to share a single connection to a data grid by using the same value for this DataGrid Definition setting.

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.

In addition to the adapter configuration discussed above, use a configuration file of type sbengine.conf to configure lines like those below to point to your ActiveSpaces installation. The following example is the file used in the ActiveSpaces Operator sample:

name = "activespaces-adapter"
version = 1.0.0
type = "com.tibco.ep.streambase.configuration.sbengine"

//
// Configuration for ActiveSpaces adapter.  This configuration 
// assumes that AS 4.x is installed into /opt/tibco/as or c:/TIBCO/as.
// This can be overridden using the TIBDG_ROOT substitution 
// variable.
//
configuration =
{
    StreamBaseEngine =
    {
        //
        //    Configure native AS library path for each platform
        //
        externalNativeLibraryPath =
        {        
            windows_x86_64 =
            [
                "${TIBDG_ROOT:-c:/TIBCO/as/4.0}/bin"
            ]
            //osx_x86_64 =
            //[
            //    "${TIBDG_ROOT:-/opt/tibco/as/4.0}/lib"
            //]    
            //linux_x86_64 = 
            //[
            //    "${TIBDG_ROOT:-/opt/tibco/as/4.0}/lib"
            //]
        }
        externalNativeLibraryPath =
        {       
            windows_x86_64 =
            [
                "${FTL_ROOT:-c:/TIBCO/ftl/5.4}/bin"
            ]
            //osx_x86_64 =
            //[
            //  "${TIBDG_ROOT:-/opt/tibco/ftl/5.4}/lib"
            //] 
            //linux_x86_64 = 
            //[
            //  "${TIBDG_ROOT:-/opt/tibco/ftl/5.4}/lib"
            //]
        }
        //
        // Add ActiveSpaces JAR to class path
        //
        externalClassPath =
        [
            "${TIBDG_ROOT:-c:/TIBCO/as/4.0}/lib/tibdg.jar"
        ]
        
        jvmArgs =
        [
            "-XX:+UseParNewGC",
            "-XX:+UseConcMarkSweepGC",
            "-XX:+CMSParallelRemarkEnabled"
        ]
    }
}

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>Import Samples and Community Content and look under the Other TIBCO Product Connectivity category for an entry called ActiveSpaces Operator.

Back to Top ^