You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/12/03 23:26:43 UTC
[incubator-streampipes] 01/05: [STREAMPIPES-252] clean up comments
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 6e129a1d437677d8ccd3b3efe352d8f8792a3bbe
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Sat Nov 28 13:43:33 2020 +0100
[STREAMPIPES-252] clean up comments
---
.../model/connect/adapter/AdapterDescription.java | 3 ---
.../manager/matching/DataSetGroundingSelector.java | 12 ------------
2 files changed, 15 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 6be495e..37fa541 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
@@ -107,9 +107,6 @@ public abstract class AdapterDescription extends NamedStreamPipesEntity {
tpJms.setTopicDefinition(new SimpleTopicDefinition("cc"));
tpMqtt.setTopicDefinition(new SimpleTopicDefinition("dd"));
this.eventGrounding.setTransportProtocols(Arrays.asList(tpKafka,tpJms,tpMqtt));
-// this.eventGrounding.setTransportFormats(Arrays.asList(Formats.jsonFormat()));
-
-
}
public AdapterDescription(String uri, String name, String description) {
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/DataSetGroundingSelector.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/DataSetGroundingSelector.java
index a14bffc..cdbeee0 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/DataSetGroundingSelector.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/DataSetGroundingSelector.java
@@ -72,18 +72,6 @@ public class DataSetGroundingSelector {
outputGrounding.setTransportFormats(Collections
.singletonList(spDataSet.getSupportedGrounding().getTransportFormats().get(0)));
-// // TODO grounding negotiation
-// TransportProtocol protocol = new KafkaTransportProtocol(BackendConfig.INSTANCE.getKafkaHost(),
-// BackendConfig.INSTANCE.getKafkaPort(),
-// TopicGenerator.generateRandomTopic(),
-// BackendConfig.INSTANCE.getZookeeperHost(),
-// BackendConfig.INSTANCE.getZookeeperPort());
-// TransportFormat format = spDataSet.getSupportedGrounding().getTransportFormats().get(0);
-//
-// EventGrounding outputGrounding = new EventGrounding();
-// outputGrounding.setTransportProtocol(protocol);
-// outputGrounding.setTransportFormats(Arrays.asList(format));
-
return new DataSetModificationMessage(outputGrounding,RandomStringUtils.randomAlphanumeric(10));
}