Skip to content
Snippets Groups Projects
Commit e4473f27 authored by Sebastian Ebert's avatar Sebastian Ebert
Browse files

fixed bugs discovered in review

parent 5dd8f4f6
No related branches found
No related tags found
1 merge request!11Merge/dev to fork master merge
......@@ -14,7 +14,7 @@ aspect JavaHandler {
public static JavaHandler JAVA_HANDLER_INSTANCE = null;
private final org.apache.logging.log4j.Logger logger = org.apache.logging.log4j.LogManager.getLogger(avaHandler.class);
private final org.apache.logging.log4j.Logger logger = org.apache.logging.log4j.LogManager.getLogger(JavaHandler.class);
private Map<String, List<Consumer<byte[]>>> callbackList = new ConcurrentHashMap<>();
......
......@@ -15,7 +15,7 @@ public boolean {{parentTypeName}}.{{connectMethod}}(String {{connectParameterNam
case "mqtt": return {{javaHandlerAttribute}}().registerCallback(uri, consumer);
{{/usesJava}}
{{#usesRest}}
case "rest": return {{restHandlerAttribute}}().newPUTConnection(uri, input -> {
case "java": return {{restHandlerAttribute}}().newPUTConnection(uri, input -> {
consumer.accept(input.getBytes());
});
{{/usesRest}}
......
......@@ -21,8 +21,8 @@ public boolean {{parentTypeName}}.{{connectMethod}}(String {{connectParameterNam
break;
{{/usesMqtt}}
{{#usesJava}}
case "mqtt":
final MqttHandler handler = {{javaHandlerAttribute}}().resolveHandler(uri);
case "java":
final JavaHandler handler = {{javaHandlerAttribute}}().resolveHandler(uri);
final String topic = {{javaHandlerAttribute}}().extractTopic(uri);
{{sender}} = () -> {
{{#loggingEnabledForWrites}}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment