breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Redis subscriber supports PING with a message.

Browse Source
This commit is contained in:
Xie Han
2024-08-21 16:11:20 +08:00
committed by xiehan
parent 98001bb67a
commit 487d013736
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/client/WFRedisSubscriber.h
View File

@@ -62,9 +62,9 @@ public:
return this->sync_send("UNSUBSCRIBE", channels);
}
int unsubscribe_all()
int unsubscribe()
{
return this->unsubscribe(std::vector<std::string>());
return this->sync_send("UNSUBSCRIBE", { });
}
int psubscribe(const std::vector<std::string>& patterns)
@@ -77,14 +77,19 @@ public:
return this->sync_send("PUNSUBSCRIBE", patterns);
}
int punsubscribe_all()
int punsubscribe()
{
return this->punsubscribe(std::vector<std::string>());
return this->sync_send("PUNSUBSCRIBE", { });
}
int ping(const std::string& message)
{
return this->sync_send("PING", { message });
}
int ping()
{
return this->sync_send("PING", std::vector<std::string>());
return this->sync_send("PING", { });
}
public: