""" RabbitMQSync service to synchronize the internal RabbitMQ database. according to CS content. The whole work is done by the RabbitMQSynchronizer that is activated when the CS was changed. """ from __future__ import absolute_import from __future__ import division from __future__ import print_function __RCSID__ = "c0787e027 (2021-05-20 13:00:51 +0200) fstagni " from DIRAC.Core.DISET.RequestHandler import RequestHandler from DIRAC import S_OK from DIRAC import gConfig from DIRAC.FrameworkSystem.Utilities import RabbitMQSynchronizer class RabbitMQSyncHandler(RequestHandler): """Service to synchronize the content of internal RabbitMQ database with the CS content. The work is done by the RabbitMQSynchronizer that acts when the CS is changed. """ @classmethod def initializeHandler(cls, _serviceInfo): """ Handler initialization """ syncObject = RabbitMQSynchronizer.RabbitMQSynchronizer() gConfig.addListenerToNewVersionEvent(syncObject.sync) return S_OK()