Skip to content

G
gmsec_kafka
Commit 60d15b65 authored by Christopher Reis's avatar Christopher Reis
Browse files
Options

Added Request

parent 9cd9a2fe
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 1 deletion
include/KafkaConnection.h
View file @ 60d15b65
...@@ -47,7 +47,9 @@ private: ...@@ -47,7 +47,9 @@ private:
std::string mw_brokers; std::string mw_brokers;
std::string mw_errstr; std::string mw_errstr;
std::string mw_debug; std::string mw_debug;
int uniquecounter;
int requestCounter;
public: public:
KafkaConnection(const gmsec::api::Config& config); KafkaConnection(const gmsec::api::Config& config);
...@@ -61,6 +63,8 @@ public: ...@@ -61,6 +63,8 @@ public:
return "gmsec_kafka"; return "gmsec_kafka";
} }
std::string generateUniqueId(long id);
virtual const char* getMWInfo(); virtual const char* getMWInfo();
virtual void CALL_TYPE mwConnect(); virtual void CALL_TYPE mwConnect();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment