Qorus Integration Engine® Enterprise Edition 6.0.27_prod
|
configuration class for DB streams More...
Public Member Methods | |
constructor (string stream, string remote, string datasource, *string tablename, *hash< auto > options) | |
creates the object and assigns config info | |
constructor (string stream, QorusSystemRestHelper remote, string datasource, *string tablename, *hash< auto > options) | |
creates the object and assigns config info | |
string | streamDesc () |
returns a description of the stream for error reporting | |
logStreamConfigImpl (string what, string url) | |
logs the stream configuration when created | |
Public Member Methods inherited from OMQ::StreamConfig | |
constructor (string stream, string remote, *hash< auto > options) | |
constructor taking a string giving the name of the remote connection for the remote server More... | |
constructor (string stream, QorusSystemRestHelper remote, *hash< auto > options) | |
constructor taking an OMQ::QorusSystemRestHelper object for the remote connection More... | |
logStreamConfig (string what) | |
logs the stream configuration when created | |
logStreamConfigImpl (string what, string url) | |
logs the stream configuration when created | |
string | stream () |
returns the stream name | |
string | streamDesc () |
returns a description of the stream for error reporting | |
QorusSystemRestHelper | remote () |
returns the remote connection object (see OMQ::QorusSystemRestHelper) | |
timeout | timeout () |
returns the timeout value in milliseconds | |
int | block () |
returns the block size | |
bool | suppressRemoteTimeout () |
returns True if no "timeout" option should be sent to the remote | |
update (string stream, *hash< auto > options) | |
updates the configuration for a new stream | |
Public Member Methods inherited from OMQ::DbStreamConfigBase | |
constructor (string datasource, *string tablename) | |
creates the object and assigns config info More... | |
string | datasource () |
returns the the datasource connection name in the remote server | |
*string | tableName () |
returns the table name | |
update (string tablename) | |
updates the configuration for a new stream | |
Additional Inherited Members | |
Private Member Methods inherited from OMQ::StreamConfig | |
setOptions (*hash< auto > options) | |
sets configuration values from an optional option hash | |
int | getDefaultBlockSize () |
returns the default block size for this object (1000) | |
Private Attributes inherited from OMQ::StreamConfig | |
string | m_stream |
no public members More... | |
QorusSystemRestHelper | m_remote |
real remote rest helper | |
timeout | m_timeout = 5m |
timeout for rest connections | |
bool | m_no_remote_timeout = False |
flag to suppress sending the timeout option to the remote | |
int | m_logLevel = LoggerLevel::INFO |
default log level; default LoggerLevel::INFO | |
softint | m_block |
block size | |
configuration class for DB streams