Qorus Integration Engine® Enterprise Edition 6.0.19_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 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 | |
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 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 | |
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