Commit afdd8646 authored by Sebastian Miller's avatar Sebastian Miller
Browse files

Added missing properties

parent 3c30524c
......@@ -41,14 +41,14 @@ def config_logging(log_settings):
def connect_to_influx(influx_conf) -> InfluxDBClient:
logging.info("Connecting to InfluxDB.")
influxdb_client = InfluxDBClient('influxdb', influx_conf['port'], influx_conf['username'], influx_conf['password'], retries=0)
influxdb_client = InfluxDBClient(influx_conf['hostname'], influx_conf['port'], influx_conf['username'], influx_conf['password'], retries=0)
logging.info("Successfully connected to InfluxDB.")
return influxdb_client
def connect_to_mq(stomp_conf, predictor):
logging.info("Connecting to ActiveMQ.")
conn = stomp.Connection(
[('activemq', stomp_conf['port'])],
[(stomp_conf['hostname'], stomp_conf['port'])],
reconnect_attempts_max=stomp_conf['reconnect_attempts_max'],
reconnect_sleep_initial=stomp_conf['reconnect_sleep_initial']
)
......
......@@ -10,10 +10,12 @@ api-endpoint: /predict
# Params for connecting to InfluxDB and ActiveMQ
components:
influxdb:
hostname: influxdb
port: 8086
username: admin
password: admin1234
stomp:
hostname: activemq
port: 61613
username: admin
password: admin
......
......@@ -10,10 +10,12 @@ api-endpoint: /predict
# Params for connecting to InfluxDB and ActiveMQ
components:
influxdb:
hostname: influxdb
port: 8086
username: admin
password: admin1234
stomp:
hostname: activemq
port: 61613
username: admin
password: admin
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment