|
| ExporterQueue (Poco::SharedPtr< Exporter > exporter, int batchSize, int capacity, int treshold) |
|
void | enqueue (const SensorData &sensorData) |
|
unsigned int | exportBatch () |
|
unsigned int | sent () const |
|
unsigned int | dropped () const |
|
bool | canExport (const Poco::Timespan &deadTimeout) const |
|
bool | working () const |
|
|
static const int | UNLIMITED_BATCH_SIZE = 0 |
|
static const int | UNLIMITED_CAPACITY = 0 |
|
static const int | UNLIMITED_THRESHOLD = FailDetector::TRESHOLD_UNLIMITED |
|
|
void | setupLogger (Poco::Logger *logger=0) const |
|
Poco::Logger & | logger () const |
|
| Loggable (const ClassInfo &info) |
|
| Loggable (const std::type_info &info) |
|
static Poco::Logger & | forMethod (const char *name) |
|
static Poco::Logger & | forClass (const ClassInfo &info) |
|
static Poco::Logger & | forClass (const std::type_info &info) |
|
template<typename T > |
static Poco::Logger & | forInstance (const T *i) |
|
static void | configureSimple (Poco::Logger &logger, const std::string &level) |
|
static void | logException (Poco::Logger &logger, const Poco::Message::Priority priority, const Poco::Exception &e, const char *file, size_t line) |
|
ExporterQueue::ExporterQueue |
( |
Poco::SharedPtr< Exporter > |
exporter, |
|
|
int |
batchSize, |
|
|
int |
capacity, |
|
|
int |
treshold |
|
) |
| |
If batchSize <= 0 then size of batch is unlimited. If capacity <= 0 then data count is unlimited. If treshold <= 0 then treshold is unlimited.
bool ExporterQueue::canExport |
( |
const Poco::Timespan & |
deadTimeout | ) |
const |
The method canExport returns true if queue is not empty and at least one of following conditions is met:
- queue is working
- queue is dead too long
The documentation for this class was generated from the following files:
- /var/lib/jenkins/workspace/beeeon-gateway-master/src/core/ExporterQueue.h
- /var/lib/jenkins/workspace/beeeon-gateway-master/src/core/ExporterQueue.cpp