 |
Qorus Integration Engine® Enterprise Edition 7.0.7_prod
|
|
Qorus Integration Engine® Enterprise Edition 7.0.7_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 | |
| constructor (string stream, QorusSystemRestHelper remote, *hash< auto > options) | |
| constructor taking an OMQ::QorusSystemRestHelper object for the remote connection | |
| 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 | |
| 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 | |
| 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 | |
| bool | clear_persistent |
| clear the persistent flag on exit | |
configuration class for DB streams