forked from OpenAtomFoundation/pika
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathpika_pubsub.h
68 lines (60 loc) · 1.64 KB
/
pika_pubsub.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
// Copyright (c) 2015-present, Qihoo, Inc. All rights reserved.
// This source code is licensed under the BSD-style license found in the
// LICENSE file in the root directory of this source tree. An additional grant
// of patent rights can be found in the PATENTS file in the same directory.
#ifndef PIKA_PUBSUB_H_
#define PIKA_PUBSUB_H_
#include "pika_command.h"
/*
* pubsub
*/
class PublishCmd : public Cmd {
public:
PublishCmd() {}
virtual void Do();
private:
std::string channel_;
std::string msg_;
virtual void DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info);
};
class SubscribeCmd : public Cmd {
public:
SubscribeCmd() {}
virtual void Do();
private:
virtual void DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info);
};
class UnSubscribeCmd : public Cmd {
public:
UnSubscribeCmd() {}
virtual void Do();
private:
virtual void DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info);
};
class PUnSubscribeCmd : public Cmd {
public:
PUnSubscribeCmd() {}
virtual void Do();
private:
virtual void DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info);
};
class PSubscribeCmd : public Cmd {
public:
PSubscribeCmd() {}
virtual void Do();
private:
virtual void DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info);
};
class PubSubCmd : public Cmd {
public:
PubSubCmd() {}
virtual void Do();
private:
std::string subcommand_;
std::vector<std::string > arguments_;
virtual void DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info);
virtual void Clear() {
arguments_.clear();
}
};
#endif // INCLUDE_PIKA_PUBSUB_H_