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/01/06 20:20:33 UTC
[incubator-streampipes] 02/03: [hotfix] Modify internal topic name
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit f08166aee09080d6229c0d4078d505d78b93cf01
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Thu Jan 6 21:19:24 2022 +0100
[hotfix] Modify internal topic name
---
.../java/org/apache/streampipes/manager/util/TopicGenerator.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/TopicGenerator.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/TopicGenerator.java
index a8a8af7..0b0c0db 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/TopicGenerator.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/TopicGenerator.java
@@ -23,6 +23,10 @@ import org.apache.commons.lang3.RandomStringUtils;
public class TopicGenerator {
public static String generateRandomTopic() {
- return "org.apache.streampipes." + RandomStringUtils.randomAlphabetic(20);
+ return generateInternalPipelineElementTopic(RandomStringUtils.randomAlphabetic(15));
+ }
+
+ public static String generateInternalPipelineElementTopic(String appendix) {
+ return "org-apache-streampipes-internal-" + appendix;
}
}