You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/02/04 22:43:46 UTC
[incubator-streampipes] 03/05: [hotfix] Do not use random topics in pipeline generation
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch experimental-module-federation-494
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 0c46ccc66f5b186bc435d0dabb89b0ebdc957477
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Fri Feb 4 22:42:24 2022 +0100
[hotfix] Do not use random topics in pipeline generation
---
.../java/org/apache/streampipes/manager/matching/ProtocolSelector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ProtocolSelector.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ProtocolSelector.java
index ec3a891..4527e90 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ProtocolSelector.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ProtocolSelector.java
@@ -39,7 +39,7 @@ public class ProtocolSelector extends GroundingSelector {
public ProtocolSelector(NamedStreamPipesEntity source, Set<InvocableStreamPipesEntity> targets) {
super(source, targets);
- this.outputTopic = TopicGenerator.generateRandomTopic();
+ this.outputTopic = TopicGenerator.generateInternalPipelineElementTopic(source.getDOM());
this.prioritizedProtocols =
BackendConfig.INSTANCE.getMessagingSettings().getPrioritizedProtocols();
}