mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-26 23:24:09 +02:00
parent
da83bae660
commit
5c77e6eafe
@ -510,7 +510,7 @@ void ApiListener::ApiTimerHandler(void)
|
|||||||
|
|
||||||
void ApiListener::RelayMessage(const MessageOrigin::Ptr& origin, const ConfigObject::Ptr& secobj, const Dictionary::Ptr& message, bool log)
|
void ApiListener::RelayMessage(const MessageOrigin::Ptr& origin, const ConfigObject::Ptr& secobj, const Dictionary::Ptr& message, bool log)
|
||||||
{
|
{
|
||||||
m_RelayQueue.Enqueue(boost::bind(&ApiListener::SyncRelayMessage, this, origin, secobj, message, log));
|
m_RelayQueue.Enqueue(boost::bind(&ApiListener::SyncRelayMessage, this, origin, secobj, message, log), true);
|
||||||
}
|
}
|
||||||
|
|
||||||
void ApiListener::PersistMessage(const Dictionary::Ptr& message, const ConfigObject::Ptr& secobj)
|
void ApiListener::PersistMessage(const Dictionary::Ptr& message, const ConfigObject::Ptr& secobj)
|
||||||
|
@ -90,7 +90,7 @@ ConnectionRole JsonRpcConnection::GetRole(void) const
|
|||||||
|
|
||||||
void JsonRpcConnection::SendMessage(const Dictionary::Ptr& message)
|
void JsonRpcConnection::SendMessage(const Dictionary::Ptr& message)
|
||||||
{
|
{
|
||||||
m_WriteQueue.Enqueue(boost::bind(&JsonRpcConnection::SendMessageSync, JsonRpcConnection::Ptr(this), message));
|
m_WriteQueue.Enqueue(boost::bind(&JsonRpcConnection::SendMessageSync, JsonRpcConnection::Ptr(this), message), true);
|
||||||
}
|
}
|
||||||
|
|
||||||
void JsonRpcConnection::SendMessageSync(const Dictionary::Ptr& message)
|
void JsonRpcConnection::SendMessageSync(const Dictionary::Ptr& message)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user