Qorus Integration Engine® Enterprise Edition 6.0.15_prod
Loading...
Searching...
No Matches
OMQ::DbRawSelectStreamConfig Class Reference

config class for raw DB select streams More...

Inheritance diagram for OMQ::DbRawSelectStreamConfig:
[legend]
Collaboration diagram for OMQ::DbRawSelectStreamConfig:
[legend]

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
 

Detailed Description

config class for raw DB select streams


The documentation for this class was generated from the following file: