AsapSource Properties

The AsapSource component subscribes to data from the Event Stream Processor stream name specified in the adapter configuration.

ClassName=com.sybase.esp.adapter.asap.AsapSource

Property Description

ProjectUri

(Dependent required) Connect to the Server running in cluster mode. For example, esp://localost:19011/ws1/p1.

User (Required) The initial connection between AsapSource and Event Stream Processor requires authentication. Enter a valid user name known to Event Stream Processor.
Passwd (Required) The initial connection between AsapSource and Event Stream Processor requires authentication. Enter a valid password for the user name. If the IsEncrypted property is set to true, the user and password information is passed to Event Stream Processor before the SSL connection is set up. These details are passed in plain text.
IsEncrypted

(Optional) If this property is set to true, AsapSource attempts to use an SSL socket connection to Event Stream Processor.

UseServerRSA

(Optional) If true, server RSA authentication is used to connect to the Server. If you specify this property, also provide the KeyStore and KeyStorePassword properties.

The Open adapter uses the Bouncy Castle Java security implementation. Ensure that Bouncy Castle is listed among other security providers in the java.security file of your Java Runtime Environment directory:
=org.bouncycastle.jce.provider.BouncyCastleProvider

KeyStore

(Optional) Used for server RSA authentication. Specifies the location of the keystore (.jks file). Set this property if you specify UseServerRSA.

KeyStorePassword

(Optional) Specify the keystore password. This is used for server RSA authentication. Set this property if you specify UseServerRSA.

UseKerberos

(Optional) If true, Kerberos authentication is used to connect to the Server. If you specify this property, also provide the KerberosKDC, KerberosRealm, KerberosService, and KerberosTicketCache properties.

KerberosKDC

(Optional) Used for Kerberos authentication. Specifies the host name of Kerberos key distribution center. Set this property if you specify UseKerberos.

KerberosRealm

(Optional) Used for Kerberos authentication. Specifies the Kerberos realm setting. Set this property if you specify UseKerberos.

KerberosService

(Optional) Used for Kerberos authentication. Specifies the Kerberos principal name that identifies an Event Stream Processor cluster. Set this property if you specify UseKerberos.

KerberosTicketCache

(Optional) Used for Kerberos authentication. Specifies the location of the Kerberos ticket cache. Set this property if you specify UseKerberos.

UseUserPassword

(Optional) If set to true, User and Password authentication (for example, Kerberos) is used to connect to the Server. If you specify this, provide values for User and Password.

Stream++ (Optional) Name of stream to subscribe to.
MaxBlockBuildTime (milliseconds) (Optional) AsapSource sends records in blocks for better performance. A block is built of individual records until the MaxBlockSize is reached or MaxBlockBuildTime elapses, whichever occurs first. Then, the block is sent along the adapter pipeline. If set to 0, there is no limit on the block building time. Default value is 1000 (milliseconds).
MaxBlockSize (Optional) AsapSource sends records in blocks for better performance. A block is built of individual records until the MaxBlockSize is reached or MaxBlockBuildTime elapses, whichever occurs first. Then the block is sent along the adapter pipeline. Default value is 256.
RecordBufferCapacity (Optional) If set to 0, records are sent along the adapter pipeline one at a time.

If set to a positive number, AsapSource queues the records made available by the Event Stream Processor in an internal buffer.

Buffered records are added to ongoing blocks on a dedicated thread so that the Pub/Sub subscription thread can continue buffering the records. When the buffer capacity is exceeded, the queue blocks until the buffer capacity becomes available again. Default value is 4096.

PulseInterval (Optional) The number of seconds to wait until AsapSource gets the next record from Event Stream Processor. All updates to a record that are made on the Event Stream Processor during the pulse interval are coalesced and only the resulting record is sent.

By default, records are received by the adapter instantaneously, rather than being pulsed.

Related tasks
Example: Using the AsapSource Component