JMS CSV Input Adapter Configuration

Configure the JMS CSV Input adapter by specifying values for the ESP connector, formatter, and transporter modules in the adapter configuration file.

Logging

Parameter Description
Log4jProperty

Type: string

(Optional) Specify the path to the log4j.properties logging file you wish to use. The default value is $ESP_HOME/adapters/framework/config/log4j.properties.

Transporter Module: JMS Input Transporter

Parameter Description
Module

(Required) Section containing all information for this module. It contains a type attribute for specifying the module type.

For example, transporter.

InstanceName

Type: string

(Required) Specify the instance name of the specific module you wish to use. For example, MyInputTransporter.

Name

Type: string

(Required) The name of the module as defined in the modulesdefine.xml file. For example, <TransporterType>InputTransporter.

Next

Type: string

(Required) Specify the instance name of the module that follows this one.

BufferMaxSize

Type: integer

(Advanced) Specify the capacity of the buffer queue between the transporter module and the next module. The default value is 10240.

Parameters

(Required) Section containing the JMSInputTransporterParameters element.

JMSInputTransporterParameters

(Required) Section containing parameters for the JMS Input transporter.

ConnectionFactory

Type: string

(Required) Specify the connection factory class name. No default value.

JndiContextFactory

Type: string

(Required) Specify the context factory for JNDI context initialization. No default value.

JndiUrl

Type: string

(Required) Specify the JNDI URL. No default value.

Destination Type

Type: string

(Required) Specify the destination type. Valid values are: QUEUE and TOPIC. The default value is QUEUE.

DestinationName

Type: string

(Required) Specify the destination name. No default value.

MessageType

Type: string

(Required) Specify the message type you want the JMS transporter to process. These types are supported:
  • TEXT - for receiving and sending messages in text string
  • OBJARRAY - for receiving and sending messages in custom format
No default value.
SubscriptionMode

Type: string

(Optional) Specify the subscription mode for TOPIC (see the Destination Type parameter). Valid values are DURABLE and NONDURABLE.

Default value is NONDURABLE.

ScanDepth

Type: integer

(Optional) Specify the depth of the schema discovery. The adapter reads the number of rows specified by this parameter value when discovering the input data schema.

The default value is three.

ClientID

Type: string

(Required for DURABLE subscription mode only) Specifies the client identifier for a JMS client. Required for creating a durable subscription in JMS. Can be any string, but must be unique for each topic. No default value.

Example: client1 .

SubscriptionName

Type: string

(Required for DURABLE subscription mode only) Specifies a unique name identifying a durable subscription. Required for creating a durable subscription in JMS. Can be any string, but must be unique within a given client ID. No default value.

Example: subscription1.

Formatter Module: CSV String to ESP Formatter

Parameter Description
Module

(Required) Section containing all information for this module. It contains a type attribute for specifying the module type.

For example, formatter.

InstanceName

Type: string

(Required) Specify the instance name of the specific module you wish to use. For example, MyInputTransporter.

Name

Type: string

(Required) The name of the module as defined in the modulesdefine.xml file. For example, <TransporterType>InputTransporter.

Next

Type: string

(Required) Specify the instance name of the module that follows this one.

Parallel

Type: boolean

(Optional) If set to true, the module runs as a separated thread. The default value is true.

Parameters

(Required) Section containing the CSVStringToEspFormatterParameters parameter.

CSVStringToEspFormatterParameters

(Required) Section containing the CSV String to ESP formatter parameters.

ExpectStreamNameOpcode

Type: boolean

(Required) If set to true, the adapter interprets the first two fields of the incoming CSV line as stream name and opcode respectively. The adapter discards messages with unmatched stream names.

The accepted opcodes are:
  • i or I: INSERT
  • d or D: DELETE
  • u or U: UPDATE
  • p or P: UPSERT
  • s or S: SAFEDELETE

The default value is false.

Delimiter

Type: string

(Advanced) The symbols used to separate the column. The default value is a comma (,).

HasHeader

Type: boolean

(Advanced) Determines whether the first line of the file contains the description of the fields. Default value is false.

DateFormat

Type: string

(Advanced) The format string for parsing date values. For example, yyyy-MM-dd'T'HH:mm:ss.

TimestampFormat

Type: string

(Advanced) Format string for parsing timestamp values. For example, yyyy-MM-dd'T'HH:mm:ss.SSS.

ESP Connector Module: ESP Publisher

Parameter Description
Module

(Required) Section containing all information for this module. It contains a type attribute for specifying the module type.

For example, formatter.

InstanceName

Type: string

(Required) Specify the instance name of the specific module you wish to use. For example, MyInputTransporter.

Name

Type: string

(Required) The name of the module as defined in the modulesdefine.xml file. For example, <TransporterType>InputTransporter.

Parameters

(Required) Section containing the EspPublisherParameters parameter.

EspPublisherParameters

(Required) Section containing parameters for the ESP publisher.

ProjectName

Type: string

(Required if running adapter in standalone mode; optional if running in managed mode) Name of the ESP project to which the adapter is connected. For example, EspProject2.

This is the same project tag that you specify later in the adapter configuration file in the Name parameter of the Event Stream Processor (EspProjects) parameters section.

If you are starting the adapter with the ESP project to which it is attached (running the adapter in managed mode), you do not need to set this property as the adapter automatically detects the project name.

StreamName

Type: string

(Required if running adapter in standalone mode; optional if running in managed mode) Name of the ESP stream to which the adapter publishes data.

If you are starting the adapter with the ESP project to which it is attached (running the adapter in managed mode), you do not need to set this property as the adapter automatically detects the stream name.

MaxPubPoolSize

Type: positive integer

(Optional) Specifies the maximum size of the record pool. Record pooling, also referred to as block or batch publishing, allows for faster publication since there is less overall resource cost in publishing multiple records together compared to publishing records individually.

Block publishing (record pooling or batch publishing) is disabled if this value is set to 1. The default value is 256.

MaxPubPoolTime

Type: positive integer

(Optional) Specifies the maximum period of time, in milliseconds, for which records are pooled before being published. If not set, pooling time is unlimited and the pooling strategy is governed by maxPubPoolSize. No default value.

UseTransactions

Type: boolean

(Optional) If set to true, pooled messages are published to Event Stream Processor in transactions. If set to false, they are published in envelopes. Default value is false.

SafeOps

Type: boolean

(Advanced) Converts the opcodes INSERT and UPDATE to UPSERT, and converts DELETE to SAFEDELETE. The default value is false.

SkipDels

Type: boolean

(Advanced) Skips the rows with opcodes DELETE or SAFEDELETE. The default value is false.

Event Stream Processor Parameters

Event Stream Processor parameters configure communication between Event Stream Processor and the JMS CSV Input adapter.

Parameter Description
EspProjects

Section containing parameters for connecting to Event Stream Processor.

EspProject

Section containing the Name and Uri parameters. Specifies information for the ESP project to which the adapter is connected.

Name

Type: string

(Required) Specifies the unique project tag of the ESP project which the espconnector (publisher/subscriber) module references.

Uri

Type: string

(Required) Specifies the total project URI to connect to the Event Stream Processor cluster. For example, esp://localhost:19011/ws1/p1.

Security

Section containing all the authentication parameters below. Specifies details for the authentication method used for Event Stream Processor.

User

Type: string

(Required) Specifies the user name required to log in to Event Stream Processor (see AuthType). No default value.

Password

Type: string

(Required) Specifies the password required to log in to Event Stream Processor (see espAuthType).

Includes an "encrypted" attribute indicating whether the Password value is encrypted. Default value is false. If set to true, the password value is decrypted using RSAKeyStore and RSAKeyStorePassword.

AuthType

Type: string

(Required) Specifies method used to authenticate to the Event Stream Processor. Valid values are:
  • server_rsa – RSA authentication using keystore
  • kerberos – Kerberos authentication using ticket-based authentication
  • user_password – LDAP, SAP BI, and Native OS (user name/password) authentication

If the adapter is operated as a Studio plug-in, AuthType is overridden by the Authentication Mode Studio start-up parameter.

RSAKeyStore

Type: string

(Dependent required) Specifies the location of the RSA keystore, and decrypts the password value. Required if AuthType is set to server_rsa, or the encrypted attribute for Password is set to true, or both.

RSAKeyStorePassword

Type:string

(Dependent required) Specifies the keystore password, and decrypts the password value. Required if AuthType is set to server_rsa, or the encrypted attribute for Password is set to true, or both.

KerberosKDC

Type: string

(Dependent required) Specifies host name of Kerberos key distribution center. Required if AuthType is set to kerberos.

KerberosRealm

Type: string

(Dependent required) Specifies the Kerberos realm setting. Required if AuthType is set to kerberos.

KerberosService

Type: string

(Dependent required) Specifies the Kerberos principal name that identifies an Event Stream Processor cluster. Required if AuthType is set to kerberos.

KerberosTicketCache

Type: string

(Dependent required) Specifies the location of the Kerberos ticket cache file. Required if AuthType is set to kerberos.

EncryptionAlgorithm

Type: string

(Optional) Used when the encrypted attribute for Password is set to true. If left blank, RSA is used as default.

Related reference
Adapter Support for Schema Discovery