OMQ::DbSelectStreamConfig Class Reference

config class for DB select streams More...

Inheritance diagram for OMQ::DbSelectStreamConfig:

Collaboration diagram for OMQ::DbSelectStreamConfig:

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	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

Private Member Methods
	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
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

Detailed Description

config class for DB select streams

---

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

• Streams.qc