abortIntern(string meth, string fmt) | OMQ::AbstractParallelReceiveStream | |
abortInternMethod(string meth) | OMQ::AbstractParallelReceiveStream | |
checkComplete(string meth) | OMQ::DbRemoteReceive | |
cleanup() | OMQ::AbstractParallelReceiveStream | virtual |
commit() | OMQ::DbRemoteReceive | |
OMQ::AbstractParallelReceiveStream::commit(OMQ::DbStreamConfig m_config) | OMQ::AbstractParallelStream | |
complete | OMQ::DbRemoteReceive | private |
config() | OMQ::DbRemoteReceive | virtual |
constructor(DbRemote remote, string stream, string table_name, *hash options) | OMQ::DbRemoteReceive | |
constructor(string remote, string datasource, string stream, string table_name, *hash options) | OMQ::DbRemoteReceive | |
constructor(QorusSystemRestHelper remote, string datasource, string stream, string table_name, *hash options) | OMQ::DbRemoteReceive | |
OMQ::AbstractParallelReceiveStream::constructor() | Qore::Thread::AbstractThreadResource | |
destructor() | OMQ::AbstractParallelReceiveStream | |
disconnect() | OMQ::DbRemoteReceive | |
getAllData(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getAllDataRows(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getData(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getDataRows(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
m_config | OMQ::DbRemoteReceive | private |
openStream(string stream, string table_name, *hash options) | OMQ::DbRemoteReceive | |
recvData(any data) | DataStreamClient::DataStreamRecvMessage | |
recvDataDone(*string err) | DataStreamClient::DataStreamRecvMessage | |
recvDataDoneImpl(*string err) | OMQ::DbRemoteReceive | |
recvDataImpl(any rdata) | OMQ::DbRemoteReceive | virtual |
rollback(bool action=DO_DISCONNECT) | OMQ::DbRemoteReceive | |
OMQ::AbstractParallelReceiveStream::rollback(OMQ::DbStreamConfig m_config) | OMQ::AbstractParallelStream | |
socketThreadImpl() | OMQ::DbRemoteReceive | virtual |
startStreamImpl() | OMQ::DbRemoteReceive | virtual |
throwAbortedExceptionImpl(string meth) | OMQ::DbRemoteReceive | virtual |