Qorus Integration Engine® Enterprise Edition 6.0.25_prod
|
stream configuration class More...
Public Member Methods | |
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 | |
Private Member Methods | |
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 | |
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 | |
stream configuration class
default values:
m_timeout:
5m
m_loglevel:
LoggerLevel::INFO OMQ::StreamConfig::constructor | ( | string | stream, |
QorusSystemRestHelper | remote, | ||
*hash< auto > | options | ||
) |
constructor taking an OMQ::QorusSystemRestHelper object for the remote connection
stream | a string giving the name of the stream that will be used |
remote | a OMQ::QorusSystemRestHelper object |
options | optional Streaming API Constructor Options as follows:
|
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
stream | a string giving the name of the stream that will be used |
remote | a string giving the name of the remote connection for the remote server |
options | optional Streaming API Constructor Options as follows:
|
|
private |
no public members
the remote sqlutil service stream