cleanup code

Activiti · Dec 5, 2022 · a8a7bc1 · a8a7bc1
1 parent 5216907
commit a8a7bc1
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 14 deletions.
diff --git a/...t/java/org/activiti/cloud/connectors/starter/test/it/ActivitiCloudConnectorServiceIT.java b/...t/java/org/activiti/cloud/connectors/starter/test/it/ActivitiCloudConnectorServiceIT.java
@@ -15,15 +15,19 @@
  */
 package org.activiti.cloud.connectors.starter.test.it;
 
-import java.time.Duration;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
 import org.activiti.api.runtime.model.impl.IntegrationContextImpl;
 import org.activiti.cloud.api.process.model.CloudBpmnError;
 import org.activiti.cloud.api.process.model.IntegrationError;
 import org.activiti.cloud.api.process.model.IntegrationRequest;
 import org.activiti.cloud.api.process.model.impl.IntegrationRequestImpl;
 import org.activiti.cloud.connectors.starter.ActivitiCloudConnectorApp;
 import org.activiti.cloud.services.test.containers.RabbitMQContainerApplicationInitializer;
-import org.awaitility.Awaitility;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -36,13 +40,6 @@
 import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.context.ContextConfiguration;
 
-import java.util.HashMap;
-import java.util.Map;
-import java.util.UUID;
-
-import static org.assertj.core.api.Assertions.assertThat;
-import static org.awaitility.Awaitility.await;
-
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = ActivitiCloudConnectorApp.class)
 @DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_CLASS)
 @ActiveProfiles(ConnectorsITStreamHandlers.CONNECTOR_IT)

diff --git a/...a/org/activiti/cloud/common/messaging/config/ConditionalFunctionBindingConfiguration.java b/...a/org/activiti/cloud/common/messaging/config/ConditionalFunctionBindingConfiguration.java
@@ -20,7 +20,6 @@
 import java.util.function.Function;
 import org.activiti.cloud.common.messaging.functional.ConditionalFunctionBinding;
 import org.activiti.cloud.common.messaging.functional.ConnectorGateway;
-import org.activiti.cloud.common.messaging.functional.ConsumerGateway;
 import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.config.BeanPostProcessor;
 import org.springframework.beans.factory.support.DefaultListableBeanFactory;

diff --git a/...nfig/src/main/java/org/activiti/cloud/common/messaging/config/ConnectorConfiguration.java b/...nfig/src/main/java/org/activiti/cloud/common/messaging/config/ConnectorConfiguration.java
@@ -64,7 +64,6 @@ public Object postProcessAfterInitialization(Object bean, String beanName) throw
                 if (Connector.class.isInstance(bean)) {
                     String connectorName = beanName;
                     String functionName = connectorName + "Connector";
-                    Connector connector = Connector.class.cast(bean);
 
                     final AtomicReference<String> responseDestination = new AtomicReference<>();
 
@@ -126,7 +125,7 @@ public Object postProcessAfterInitialization(Object bean, String beanName) throw
                         .gateway(connectorFlow, spec -> spec.replyTimeout(0L))
                         .get();
 
-                    integrationFlowContext.registration(connectorFlow)
+                    integrationFlowContext.registration(inputChannelFlow)
                         .register();
                 }
                 return bean;

diff --git a/...tiviti-cloud-services-test/src/main/java/org/activiti/cloud/starters/test/MyProducer.java b/...tiviti-cloud-services-test/src/main/java/org/activiti/cloud/starters/test/MyProducer.java
@@ -16,8 +16,6 @@
 package org.activiti.cloud.starters.test;
 
 import org.activiti.cloud.api.model.shared.events.CloudRuntimeEvent;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.messaging.MessageChannel;
 import org.springframework.messaging.support.MessageBuilder;