[#1289] Remove legacy code in class AdapterDescription

apache · Feb 15, 2023 · ec907f1 · ec907f1
1 parent bd91944
commit ec907f1
Showing 1 changed file with 7 additions and 13 deletions.
diff --git a/...-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescription.java b/...-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) {