 |
Qorus Integration Engine® Enterprise Edition 6.0.27_prod
|
|
Qorus Integration Engine® Enterprise Edition 6.0.27_prod
|
config class for DbRemoteSend 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 | |
| update (string stream, string tablename, *hash< auto > options) | |
| updates the configuration for a new stream | |
| *list< auto > | omitUpdate () |
| returns any "omit_update" remote upsert stream option | |
| *int | upsertStrategy () |
| returns any "upsert_strategy" remote upsert stream option | |
 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::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 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 DbRemoteSend