tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-26 07:04:37 +02:00
Code Issues Packages Projects Releases Wiki Activity

Only send events to Redis when there is at least one subscriber

Browse Source 
refs #4991
This commit is contained in:
Gunnar Beutner 2017-03-13 10:56:16 +01:00 committed by Michael Friedrich
parent 10ddcbe4d3
commit 34c69d9556
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lib/redis/rediswriter.cpp
View File

@ -244,6 +244,21 @@ void RedisWriter::HandleEvent(const Dictionary::Ptr& event)
if (!m_Context) if (!m_Context)
return; return;
String type = event->Get("type");
bool atLeastOneSubscriber = false;
for (const std::pair<String, RedisSubscriptionInfo>& kv : m_Subscriptions) {
const auto& rsi = kv.second;
if (rsi.EventTypes.find(type) == rsi.EventTypes.end())
continue;
atLeastOneSubscriber = true;
}
if (!atLeastOneSubscriber)
return;
Log(LogInformation, "RedisWriter") Log(LogInformation, "RedisWriter")
<< "Pushing event to Redis: '" << Value(event) << "'."; << "Pushing event to Redis: '" << Value(event) << "'.";
@ -318,8 +333,6 @@ void RedisWriter::HandleEvent(const Dictionary::Ptr& event)
freeReplyObject(reply3); freeReplyObject(reply3);
String type = event->Get("type");
for (const std::pair<String, RedisSubscriptionInfo>& kv : m_Subscriptions) { for (const std::pair<String, RedisSubscriptionInfo>& kv : m_Subscriptions) {
const auto& name = kv.first; const auto& name = kv.first;
const auto& rsi = kv.second; const auto& rsi = kv.second;