|
|
| GmMqttPublisher (int iBufferSize) |
| |
|
int | CheckInitialized (char *szServerName, char *szPortNumberAsString, char *szClientName, Bool bIsKnownIp) |
| |
|
int | ConnectToBroker (const char *brokerAddress) |
| |
|
int | Subscribe (const char *szTopicName) |
| |
|
int | Shutdown () |
| |
|
int | PrepTopic (char *szTopicName, UInt32 iDataSize, int iBufferCount) |
| |
|
int | Close (int iFileIndex) |
| |
|
int | WriteData (const char *pcData, unsigned int iDataSize, UInt32 uiTopic) |
| |
|
int | SetTopicString (UInt32 iTopicId, char *strTopic) |
| |
|
int | PushData (const char *pData, const int iDataSize) |
| |
|
int | StartPushData () |
| |
|
int | StopPushData () |
| |
|
int | PublishSelf (const char *szTopic, const char *pcData, int iDataSize) |
| |
|
virtual int | EnterTransaction () |
| |
|
virtual int | LeaveTransaction () |
| |
|
virtual int | RollAndSynchFile () |
| |
|
virtual int | SelectSurveyEx (const char *strSurveyId) |
| |
|
virtual int | IsDataStorage () |
| |
|
virtual int | GetLastError () |
| |
|
virtual bool | IsOpen () |
| |
|
void | SetDatasetId (const int iDataset) |
| |
|
int | GetDatasetId (bool increment) |
| |
|
|
static bool | sDaemonsHaveBeenSetUp = false |
| |
|
static int | s_recordsPerFile = BLOCKS_PER_ACQUISITION_DATA_FILE |
| |
|
|
static int | DecodeDownloadName (const char *szDownloadName, char *strSurveyId, char *strAcquisitionId, char *strFileName) |
| |
|
bool | m_bIsOpen |
| |
|
int | m_iCurrentDataSetId |
| |
|
bool | mIncrementDatasetId |
| |
The documentation for this class was generated from the following files:
- /home/kddev/dev/AppDev/GmCommon/include/GmMQTT.hpp
- /home/kddev/dev/AppDev/GmCommon/GmStorage/GmMQTT.cpp