|
| constructor (string remote, string path, string streamType=AbstractFsRemoteReceive::TYPE_FILE, *hash< auto > options) |
| creates the configuration object from the arguments
|
|
| constructor (QorusSystemRestHelper remote, string path, string streamType=AbstractFsRemoteReceive::TYPE_FILE, *hash< auto > options) |
| creates the configuration object from the arguments
|
|
string | path () |
| returns the path
|
|
string | encoding () |
| returns the file's character encoding
|
|
| logStreamConfigImpl (string what, string url) |
| logs the stream configuration when created
|
|
| updatePath (string path) |
| updates the stored path
|
|
| 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
|
|
| 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
|
|
|
string | m_path |
| target path
|
|
string | m_encoding = get_default_encoding() |
| target file encoding
|
|
const | MinBlockSize = 4096 |
| minimum block size in bytes
|
|
string | m_streamType |
| One of supported stream types. See AbstractFsRemoteReceive public constants.
|
|
hash< auto > | m_csvUtilOpts |
| Potential options for csv when is the m_streamType = AbstractFsRemoteReceive::TYPE_CSV;.
|
|
string | m_xmlElement |
| Potential xml element for csv when is the m_streamType = AbstractFsRemoteReceive::TYPE_XML;.
|
|
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
|
|
*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
|
|
filesystem receive stream base config class