diff --git a/lib/db_ido/dbevents.cpp b/lib/db_ido/dbevents.cpp index 08cf55cc6..57e680fbf 100644 --- a/lib/db_ido/dbevents.cpp +++ b/lib/db_ido/dbevents.cpp @@ -98,6 +98,7 @@ void DbEvents::NextCheckChangedHandler(const Checkable::Ptr& checkable, double n query1.Table = "hoststatus"; query1.Type = DbQueryUpdate; + query1.Category = DbCatState; Dictionary::Ptr fields1 = new Dictionary(); fields1->Set("next_check", DbValue::FromTimestamp(nextCheck)); @@ -128,6 +129,7 @@ void DbEvents::FlappingChangedHandler(const Checkable::Ptr& checkable, FlappingS query1.Table = "hoststatus"; query1.Type = DbQueryUpdate; + query1.Category = DbCatState; Dictionary::Ptr fields1 = new Dictionary(); fields1->Set("is_flapping", CompatUtility::GetCheckableIsFlapping(checkable)); @@ -163,6 +165,7 @@ void DbEvents::LastNotificationChangedHandler(const Notification::Ptr& notificat query1.Table = "hoststatus"; query1.Type = DbQueryUpdate; + query1.Category = DbCatState; Dictionary::Ptr fields1 = new Dictionary(); fields1->Set("last_notification", DbValue::FromTimestamp(now_bag.first)); @@ -221,6 +224,7 @@ void DbEvents::EnableChangedHandlerInternal(const Checkable::Ptr& checkable, boo query1.Table = "hoststatus"; query1.Type = DbQueryUpdate; + query1.Category = DbCatState; Dictionary::Ptr fields1 = new Dictionary(); diff --git a/lib/db_ido/endpointdbobject.cpp b/lib/db_ido/endpointdbobject.cpp index 98d7e73b8..7977489b3 100644 --- a/lib/db_ido/endpointdbobject.cpp +++ b/lib/db_ido/endpointdbobject.cpp @@ -82,6 +82,7 @@ void EndpointDbObject::UpdateConnectedStatus(const Endpoint::Ptr& endpoint) DbQuery query1; query1.Table = "endpointstatus"; query1.Type = DbQueryUpdate; + query1.Category = DbCatState; Dictionary::Ptr fields1 = new Dictionary(); fields1->Set("is_connected", (connected ? 1 : 0)); @@ -114,6 +115,7 @@ void EndpointDbObject::OnConfigUpdate(void) DbQuery query1; query1.Table = "endpointstatus"; query1.Type = DbQueryInsert; + query1.Category = DbCatConfig; Dictionary::Ptr fields1 = new Dictionary(); fields1->Set("identity", endpoint->GetName());