backend.component

Complexity

Total Complexity

3

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Importance

Changes

0

2 Functions

Rating	Name	Duplication	Size	Complexity
A	docomponent()	0	4	1
A	when_component()	0	7	2

'''a component that gathers stats and hearbeats from other components
evaluate if this is going to be used or not
'''

from helpers.queuehelper import QueueName
from backend.fcmapp import ApplicationService

APP = ApplicationService(component='component')

def when_component(channel, method, properties, body):
    '''when the event happens'''
    try:
        print("[{0}] Received component message".format(APP.now()))
        docomponent(body.decode())
    except Exception as ex:
        APP.logexception(ex)

def docomponent(msg):
    '''do this'''
    APP.telegram.sendmessage(msg)
    print("Sent telegram {0}".format(msg))

Q = APP.subscribe(QueueName.Q_COMPONENT, when_component)
APP.bus.listen(Q)