diff options
author | Michael Jurkoic <mjjurkoic@gmail.com> | 2024-04-10 21:33:45 -0500 |
---|---|---|
committer | Michael Jurkoic <mjjurkoic@gmail.com> | 2024-04-10 21:33:45 -0500 |
commit | c8bb6c8f56e0c6d93c8623722ab932c04de882b5 (patch) | |
tree | b61f055748e8c8058f9d27c1441bf68d3bca030d /src/client/websocketpp_client.cpp | |
parent | 0a185a13aa4c202ad8d76ac3e62a878dc5f06619 (diff) |
Handle relay response messages
These changes do not yet have unit tests.
Diffstat (limited to 'src/client/websocketpp_client.cpp')
-rw-r--r-- | src/client/websocketpp_client.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/client/websocketpp_client.cpp b/src/client/websocketpp_client.cpp index 981d4ec..276c5dd 100644 --- a/src/client/websocketpp_client.cpp +++ b/src/client/websocketpp_client.cpp @@ -77,13 +77,19 @@ public: if (error.value() == -1) { - // PLOG_ERROR << "Error publishing event to relay " << relay << ": " << error.message(); return make_tuple(uri, false); } return make_tuple(uri, true); }; + tuple<string, bool> send(string message, string uri, function<void(const string&)> messageHandler) override + { + auto successes = this->send(message, uri); + this->receive(uri, messageHandler); + return successes; + }; + void receive(string uri, function<void(const string&)> messageHandler) override { lock_guard<mutex> lock(this->_propertyMutex); |