From ec907f187d3a483aa98ef27e8d68afa254afca92 Mon Sep 17 00:00:00 2001 From: Philipp Zehnder Date: Wed, 15 Feb 2023 16:03:07 +0100 Subject: [PATCH] [#1289] Remove legacy code in class `AdapterDescription` --- .../connect/adapter/AdapterDescription.java | 20 +++++++------------ 1 file changed, 7 insertions(+), 13 deletions(-) diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescription.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescription.java index 4663931f79..694c2fc9d3 100644 --- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescription.java +++ b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescription.java @@ -25,11 +25,6 @@ import org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription; import org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription; import org.apache.streampipes.model.grounding.EventGrounding; -import org.apache.streampipes.model.grounding.JmsTransportProtocol; -import org.apache.streampipes.model.grounding.KafkaTransportProtocol; -import org.apache.streampipes.model.grounding.MqttTransportProtocol; -import org.apache.streampipes.model.grounding.SimpleTopicDefinition; -import org.apache.streampipes.model.grounding.TransportProtocol; import org.apache.streampipes.model.schema.EventSchema; import org.apache.streampipes.model.shared.annotation.TsModel; import org.apache.streampipes.model.staticproperty.StaticProperty; @@ -38,7 +33,6 @@ import com.fasterxml.jackson.annotation.JsonSubTypes; import java.util.ArrayList; -import java.util.Arrays; import java.util.List; @JsonSubTypes({ @@ -81,13 +75,13 @@ public AdapterDescription() { this.category = new ArrayList<>(); // TODO move to another place - TransportProtocol tpKafka = new KafkaTransportProtocol(); - TransportProtocol tpJms = new JmsTransportProtocol(); - TransportProtocol tpMqtt = new MqttTransportProtocol(); - tpKafka.setTopicDefinition(new SimpleTopicDefinition("bb")); - tpJms.setTopicDefinition(new SimpleTopicDefinition("cc")); - tpMqtt.setTopicDefinition(new SimpleTopicDefinition("dd")); - this.eventGrounding.setTransportProtocols(Arrays.asList(tpKafka, tpJms, tpMqtt)); +// TransportProtocol tpKafka = new KafkaTransportProtocol(); +// TransportProtocol tpJms = new JmsTransportProtocol(); +// TransportProtocol tpMqtt = new MqttTransportProtocol(); +// tpKafka.setTopicDefinition(new SimpleTopicDefinition("bb")); +// tpJms.setTopicDefinition(new SimpleTopicDefinition("cc")); +// tpMqtt.setTopicDefinition(new SimpleTopicDefinition("dd")); +// this.eventGrounding.setTransportProtocols(Arrays.asList(tpKafka, tpJms, tpMqtt)); } public AdapterDescription(String elementId, String name, String description) {