stream

In a subscription section in an output adapter map file, identifies the stream from which the adapter gets the data it publishes to RMDS.

Summary

adapter                       (required, limit one)
  |----rfa                               (required, limit one)
  '----subscriptions                     (required, limit one)
         '----subscription               (required)
                '----stream              (required)
                       |----name         (required, limit one)
                       |----stale        (optional)
                       |----field        (required)
                       '----constant     (optional)

Parent

subscription

Children

Name Requirement
name One
stale Optional
field One or more
constant Optional

Attributes

Name Description Requirement
exitOnStreamExit This is a boolean attribute. When true, esp_rmdsomm terminates if the stream exits, Event Stream Processor exits, or the connection is lost. Optional (default is false)
finalizer This string specifies an action to take if the specified number of heartbeat milliseconds elapse without an event being published to Event Stream Processor. Optional
heartbeat This integer specifies how many milliseconds to wait without an event being published to Event Stream Processor before executing the finalizer action . Optional
name The name of the stream from which the adapter receives the data it publishes on RMDS Required
ESPExitOnStreamDrop This is a boolean attribute. When true, Event Stream Processor exits if this subscription drops its connection. Optional (default is false)
ESPQueueSize The size, in bytes, of Event Stream Processor queue Optional (default is 8000)

Notes

The value of the name attribute must be defined in Event Stream Processor project.

Any stream in Event Stream Processor project can map to only one stream section in the map file.

Example

<stream name="stream1">
        <name column="0"/>
        <field column="4" name="TRDPRC_1"/>
        <field column="9" name="BID" precision="5"/>
</stream>

This example configures Event Stream Processor to publish data from a stream named stream1.