| 151 | } |
| 152 | |
| 153 | static void xreadgroup(acl::redis_stream& redis, const char* group, |
| 154 | const char* consumer) |
| 155 | { |
| 156 | acl::redis_stream_messages messages; |
| 157 | std::map<acl::string, acl::string> streams; |
| 158 | streams[__key] = ">"; |
| 159 | if (redis.xreadgroup(messages, group, consumer, streams) == false) { |
| 160 | printf("xreadgroup error=%s, key=%s, group=%s, consumer=%s\r\n", |
| 161 | redis.result_error(), __key.c_str(), group, consumer); |
| 162 | const acl::string* req = redis.request_buf(); |
| 163 | printf("request=[%s]\r\n", req ? req->c_str() : "NULL"); |
| 164 | return; |
| 165 | } |
| 166 | |
| 167 | printf("xreadgroup ok, key=%s, group=%s, consumer=%s\r\n", |
| 168 | __key.c_str(), group, consumer); |
| 169 | |
| 170 | if (messages.empty()) { |
| 171 | printf("no messages\r\n"); |
| 172 | } else { |
| 173 | show_messages(messages); |
| 174 | } |
| 175 | } |
| 176 | |
| 177 | static void xread(acl::redis_stream& redis, size_t count) |
| 178 | { |
no test coverage detected
searching dependent graphs…