mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-25 22:54:57 +02:00
Icinga DB: remove usernotification history stream
These will be added to the normal notification stream so there is no more need for this extra stream.
This commit is contained in:
parent
95cdc00ad4
commit
130b22e939
@ -1673,19 +1673,6 @@ void IcingaDB::SendSentNotification(
|
|||||||
}
|
}
|
||||||
|
|
||||||
m_Rcon->FireAndForgetQuery(std::move(xAdd), Prio::History);
|
m_Rcon->FireAndForgetQuery(std::move(xAdd), Prio::History);
|
||||||
|
|
||||||
for (const User::Ptr& user : users) {
|
|
||||||
auto userId = GetObjectIdentifier(user);
|
|
||||||
std::vector<String> xAddUser ({
|
|
||||||
"XADD", "icinga:history:stream:usernotification", "*",
|
|
||||||
"id", Utility::NewUniqueID(),
|
|
||||||
"environment_id", m_EnvironmentId,
|
|
||||||
"notification_history_id", notificationHistoryId,
|
|
||||||
"user_id", GetObjectIdentifier(user),
|
|
||||||
});
|
|
||||||
|
|
||||||
m_Rcon->FireAndForgetQuery(std::move(xAddUser), Prio::History);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void IcingaDB::SendStartedDowntime(const Downtime::Ptr& downtime)
|
void IcingaDB::SendStartedDowntime(const Downtime::Ptr& downtime)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user