| #include "rocketmq/RocketMQ.h" | |
| #include <string> | |
| #include <vector> | |
| ROCKETMQ_NAMESPACE_BEGIN | |
| enum class GroupType : int8_t { | |
| PUBLISHER = 0, | |
| SUBSCRIBER = 1, | |
| }; | |
| struct ClientResourceBundle { | |
| std::string client_id; | |
| std::vector<std::string> topics; | |
| std::string resource_namespace; | |
| std::string group; | |
| GroupType group_type{GroupType::PUBLISHER}; | |
| }; | |
| ROCKETMQ_NAMESPACE_END |