|
|
| 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
|
| |
| | 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
|
| |
|
| 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
|
| |
|
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
|
| |
|
*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
Public Member Methods inherited from OMQ::StreamConfig