Bug fixes (log messages).
Change-Id: I0674ff703a16764d3e837a0851ea1e5794a624d2
This commit is contained in:
parent
085c7646eb
commit
5fab1557ef
|
@ -38,7 +38,7 @@ cfg.CONF.register_opts(forwarder_opts)
|
|||
def forwarder():
|
||||
"""Listens probes_endpoints and forwards messages to the plugins."""
|
||||
LOG = log.getLogger('kwapi')
|
||||
LOG.info('Collector listenig to %s' % cfg.CONF.probes_endpoint)
|
||||
LOG.info('Forwarder listening to %s' % cfg.CONF.probes_endpoint)
|
||||
context = zmq.Context.instance()
|
||||
frontend = context.socket(zmq.XPUB)
|
||||
frontend.bind(cfg.CONF.forwarder_endpoint)
|
||||
|
|
|
@ -131,7 +131,7 @@ class Collector:
|
|||
database. Messages are dictionaries dumped in JSON format.
|
||||
|
||||
"""
|
||||
LOG.info('Collector listenig to %s' % cfg.CONF.probes_endpoint)
|
||||
LOG.info('API listening to %s' % cfg.CONF.probes_endpoint)
|
||||
|
||||
context = zmq.Context.instance()
|
||||
subscriber = context.socket(zmq.SUB)
|
||||
|
|
|
@ -260,7 +260,7 @@ def listen():
|
|||
database. Messages are dictionaries dumped in JSON format.
|
||||
|
||||
"""
|
||||
LOG.info('RRD listenig to %s' % cfg.CONF.probes_endpoint)
|
||||
LOG.info('RRD listening to %s' % cfg.CONF.probes_endpoint)
|
||||
|
||||
create_dirs()
|
||||
|
||||
|
|
Loading…
Reference in New Issue