 |
Qorus Integration Engine® Enterprise Edition 7.0.7_prod
|
|
Qorus Integration Engine® Enterprise Edition 7.0.7_prod
|
config class for raw DB select streams More...
Public Member Methods | |
| constructor (string remote, string datasource, string sql, *list< auto > args, *hash< auto > options) | |
| creates the object and assigns config info | |
| constructor (QorusSystemRestHelper remote, string datasource, string sql, *list< auto > args, *hash< auto > options) | |
| creates the object and assigns config info | |
 Public Member Methods inherited from OMQ::DbSelectStreamConfig | |
| 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 | getRawSql () |
| returns any raw SQL set | |
| *list< auto > | getRawSqlArgs () |
| returns any raw SQL bind args set | |
| *hash< auto > | selectOptions () |
| returns any select hash<auto> options | |
| bool | transaction () |
| returns the transaction flag | |
| update (string stream, string tablename, *hash< auto > options) | |
| updates the configuration for a new stream | |
| logStreamConfigImpl (string what, string url) | |
| logs the stream configuration when created | |
| Public Member Methods inherited from OMQ::DbStreamConfig | |
| 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 | |
| Public Member Methods inherited from OMQ::QueuedBlockConfigBase | |
| constructor (*hash< auto > options) | |
| creates the object and assigns config info | |
| *int | queueBlockSize () |
| returns the queue block size | |
| int | queueTimeout () |
| returns the queue timeout in milliseconds | |
| update (*hash< auto > options) | |
| updates options | |
Additional Inherited Members | |
| Private Member Methods inherited from OMQ::DbSelectStreamConfig | |
| constructor (*hash< auto > options, string stream, string remote, string datasource, string sql, *list< auto > args) | |
| private constructor | |
| constructor (*hash< auto > options, string stream, QorusSystemRestHelper remote, string datasource, string sql, *list< auto > args) | |
| private constructor | |
| setDbSelectOptions (*hash< auto > options) | |
| sets config options | |
| 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::DbSelectStreamConfig | |
| bool | m_transaction = False |
| flag to start a remote transaction | |
| *string | sql |
| raw select SQL for non-table-based selects | |
| *list< auto > | args |
| bind args for non-table-based selects | |
| 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 | |
| Private Attributes inherited from OMQ::QueuedBlockConfigBase | |
| *softint | m_queue_block_size = 2 |
data queue block size; the number of blocks to queue for sending before the main data thread will block; default: 2 | |
| timeout | m_queue_timeout = 5m |
queue timeout; maximum amount of time a message can wait for the queue to become free; default: 5m | |
| const | MinQueueBlockSize = 2 |
| minimum queue block size | |
config class for raw DB select streams