Fix checkstyle, activate pulsar test

apache · Oct 22, 2023 · 107a532 · 107a532
1 parent f7325bc
commit 107a532
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/...gration-tests/src/test/java/org/apache/streampipes/integration/adapters/AdaptersTest.java b/...gration-tests/src/test/java/org/apache/streampipes/integration/adapters/AdaptersTest.java
@@ -22,12 +22,12 @@
 public class AdaptersTest {
 
 
-//  @Test
-//  public void testPulsarAdapter() throws Exception {
-//    try (PulsarAdapterTester pulsarAdapterTester = new PulsarAdapterTester()) {
-//      pulsarAdapterTester.run();
-//    }
-//  }
+  @Test
+  public void testPulsarAdapter() throws Exception {
+    try (PulsarAdapterTester pulsarAdapterTester = new PulsarAdapterTester()) {
+      pulsarAdapterTester.run();
+    }
+  }
 
   @Test
   public void testMqttAdapter() throws Exception {

diff --git a/...n-tests/src/test/java/org/apache/streampipes/integration/adapters/KafkaAdapterTester.java b/...n-tests/src/test/java/org/apache/streampipes/integration/adapters/KafkaAdapterTester.java
@@ -19,9 +19,10 @@
 package org.apache.streampipes.integration.adapters;
 
 import org.apache.streampipes.commons.exceptions.connect.AdapterException;
-import org.apache.streampipes.extensions.connectors.kafka.adapter.KafkaProtocol;
 import org.apache.streampipes.extensions.api.connect.IAdapterConfiguration;
 import org.apache.streampipes.extensions.api.connect.StreamPipesAdapter;
+import org.apache.streampipes.extensions.connectors.kafka.adapter.KafkaProtocol;
+import org.apache.streampipes.extensions.connectors.kafka.shared.kafka.KafkaConnectUtils;
 import org.apache.streampipes.integration.containers.KafkaContainer;
 import org.apache.streampipes.integration.containers.KafkaDevContainer;
 import org.apache.streampipes.manager.template.AdapterTemplateHandler;
@@ -32,7 +33,6 @@
 import org.apache.streampipes.model.staticproperty.StaticPropertyAlternatives;
 import org.apache.streampipes.model.template.PipelineElementTemplate;
 import org.apache.streampipes.model.template.PipelineElementTemplateConfig;
-import org.apache.streampipes.extensions.connectors.kafka.shared.kafka.KafkaConnectUtils;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;

diff --git a/...-tests/src/test/java/org/apache/streampipes/integration/adapters/PulsarAdapterTester.java b/...-tests/src/test/java/org/apache/streampipes/integration/adapters/PulsarAdapterTester.java
@@ -18,9 +18,9 @@
 package org.apache.streampipes.integration.adapters;
 
 import org.apache.streampipes.commons.exceptions.connect.AdapterException;
-import org.apache.streampipes.extensions.connectors.pulsar.adapter.PulsarProtocol;
 import org.apache.streampipes.extensions.api.connect.IAdapterConfiguration;
 import org.apache.streampipes.extensions.api.connect.StreamPipesAdapter;
+import org.apache.streampipes.extensions.connectors.pulsar.adapter.PulsarProtocol;
 import org.apache.streampipes.integration.containers.PulsarContainer;
 import org.apache.streampipes.integration.containers.PulsarDevContainer;
 import org.apache.streampipes.integration.utils.Utils;