gaetancollaud

import java.time.Clock;
import java.time.Duration;
import java.time.Instant;
import java.time.ZoneId;
import java.time.temporal.ChronoUnit;

/** Clock used so we can shift time in tests. */
public class MockClock extends Clock {

gaetancollaud

FROM quay.io/debezium/connect:2.5.3.Final

ENV KAFKA_CONNECT_PLUGINS_DIR=/kafka/connect/ \
    EXTERNAL_LIBS_DIR=/kafka/libs \
    CONNECT_PLUGIN_PATH=$KAFKA_CONNECT_PLUGINS_DIR \
    MAVEN_DEP_DESTINATION=$KAFKA_HOME/libs \
    CONFLUENT_VERSION=7.0.1 \
    AVRO_VERSION=1.10.1 \
    APICURIO_VERSION=2.2.5.Final \
    GUAVA_VERSION=31.0.1-jre \

gaetancollaud

 let CONFIG = {
  topic_prefix: "",
  output_count: 4
};
let value;

//Read mqtt topic prefix
Shelly.call("MQTT.GetConfig", null, function (config) {
  CONFIG.topic_prefix = config.topic_prefix;
  startSubscribing();

gaetancollaud

kafka:
  bootstrap:
    servers: localhost:9092
schema:
  registry:
    url: http://localhost:8081

mp:
  messaging:

gaetancollaud

#BEGIN TELCRED
SetEnvIf Origin "^http(s)?://(.+\.)?(telcred\.net|localhost)(:\d+)$" origin_is=$0 
Header always set Access-Control-Allow-Origin %{origin_is}e env=origin_is
Header always set Access-Control-Allow-Credentials %{origin_is}e env=origin_is
Header always set Access-Control-Allow-Headers "Authorization,Content-Type" env=origin_is
Header always set Access-Control-Request-Method "GET,POST,OPTIONS" env=origin_is
#END TELCRED

gaetancollaud

import {Directive, ElementRef, Input} from "angular2/core";
import {TranslateService} from "ng2-translate";

@Directive({
	selector: '[translate]'
})
export class Translate {
	constructor(private translateService:TranslateService, private element:ElementRef) {
	}