launch_ems.py
No OneTemporary
Actions

Subscribers

None

File Metadata


	from Queue import Queue
	from rtevents_interface.rtevents_interf import RTEventInterface
	from emscore.ems_main import EnergyManagementSystem

	print("Starting EMS ")

	stream_rtevents = Queue()

	print("Launching threads for the interface frontend and the CMS")

	rtevents_interf = RTEventInterface(stream_rtevents) # RT Interface
	ems_core = EnergyManagementSystem(stream_rtevents) # The core of the EMS logic

	# Start the thread

	rtevents_interf.start()
	ems_core.start()

	# Do infinite loop here for EMS job


	rtevents_interf.join()
	cms.join()