#!/usr/bin/env python # # DM DAQ Web Service # from dm.common.service.dmRestWebServiceBase import DmRestWebServiceBase from dm.common.utility.dmModuleManager import DmModuleManager from dm.common.utility.configurationManager import ConfigurationManager from dm.daq_web_service.service.impl.fileSystemObserver import FileSystemObserver from dm.daq_web_service.service.impl.fileProcessingManager import FileProcessingManager from daqWebServiceRouteMapper import DaqWebServiceRouteMapper class DaqWebService(DmRestWebServiceBase): def __init__(self): DmRestWebServiceBase.__init__(self, DaqWebServiceRouteMapper) def initDmModules(self): self.logger.debug('Initializing dm modules') # Add modules that will be started. moduleManager = DmModuleManager.getInstance() moduleManager.addModule(FileSystemObserver.getInstance()) moduleManager.addModule(FileProcessingManager.getInstance()) self.logger.debug('Initialized dm modules') def getDefaultServerHost(self): return ConfigurationManager.getInstance().getServiceHost() def getDefaultServerPort(self): return ConfigurationManager.getInstance().getServicePort() #################################################################### # Run service if __name__ == '__main__': ConfigurationManager.getInstance().setServiceName('daq-web-service') service = DaqWebService(); service.run()