Skip to content
This repository has been archived by the owner on Jul 12, 2023. It is now read-only.

Commit

Permalink
AAE-11278 fix imports
Browse files Browse the repository at this point in the history
  • Loading branch information
@jsokolowskii
jsokolowskii committed Jan 3, 2023
1 parent 60f270c commit 9b257de
Show file tree
Hide file tree
Showing 7 changed files with 23 additions and 31 deletions.
17 changes: 8 additions & 9 deletions ...nector/starter/src/main/java/org/activiti/cloud/examples/connectors/ExampleConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,20 +15,11 @@
*/
package org.activiti.cloud.examples.connectors;

import static net.logstash.logback.marker.Markers.append;

import com.fasterxml.jackson.databind.ObjectMapper;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.function.Consumer;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.api.process.model.IntegrationResult;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.common.messaging.functional.FunctionBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
Expand All @@ -39,6 +30,14 @@
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

import static net.logstash.logback.marker.Markers.append;

@ConnectorBinding(input = ExampleConnectorChannels.EXAMPLE_CONNECTOR_CONSUMER, condition = "")
@Component(ExampleConnectorChannels.EXAMPLE_CONNECTOR_CONSUMER + "Connector")
public class ExampleConnector implements Connector<IntegrationRequest, Void> {
Expand Down
7 changes: 3 additions & 4 deletions ...nector/starter/src/main/java/org/activiti/cloud/examples/connectors/HeadersConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,8 @@
*/
package org.activiti.cloud.examples.connectors;

import java.util.HashMap;
import java.util.Map;
import java.util.function.Consumer;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.api.process.model.IntegrationResult;
import org.activiti.cloud.common.messaging.functional.ConditionalFunctionBinding;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
Expand All @@ -31,6 +27,9 @@
import org.springframework.messaging.MessageHeaders;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@ConnectorBinding(
input = HeadersConnectorChannels.HEADERS_CONNECTOR_CONSUMER,
condition = "headers['processDefinitionVersion']!=null"
Expand Down
5 changes: 2 additions & 3 deletions ...rter/src/main/java/org/activiti/cloud/examples/connectors/MoviesDescriptionConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,20 +15,19 @@
*/
package org.activiti.cloud.examples.connectors;

import java.util.Map;
import java.util.function.Consumer;
import org.activiti.api.process.model.IntegrationContext;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.common.messaging.functional.FunctionBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import java.util.Map;

@ConnectorBinding(input = MoviesDescriptionConnectorChannels.MOVIES_DESCRIPTION_CONSUMER, condition = "")
@Component(MoviesDescriptionConnectorChannels.MOVIES_DESCRIPTION_CONSUMER + "Connector")
public class MoviesDescriptionConnector implements Connector<IntegrationRequest, Void> {
Expand Down
9 changes: 4 additions & 5 deletions .../starter/src/main/java/org/activiti/cloud/examples/connectors/MultiInstanceConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,16 +15,11 @@
*/
package org.activiti.cloud.examples.connectors;

import java.util.Collections;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Consumer;
import org.activiti.api.process.model.IntegrationContext;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.api.process.model.IntegrationResult;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.common.messaging.functional.FunctionBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
Expand All @@ -34,6 +29,10 @@
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

import java.util.Collections;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

@ConnectorBinding(input = Channels.CHANNEL, condition = "")
@Component(Channels.CHANNEL + "Connector")
public class MultiInstanceConnector implements Connector<IntegrationRequest, Void> {
Expand Down
7 changes: 3 additions & 4 deletions ...connector/starter/src/main/java/org/activiti/cloud/examples/connectors/RestConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,21 +15,20 @@
*/
package org.activiti.cloud.examples.connectors;

import java.util.HashMap;
import java.util.Map;
import java.util.function.Consumer;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.api.process.model.IntegrationResult;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.common.messaging.functional.FunctionBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
import org.springframework.messaging.Message;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@ConnectorBinding(input = RestConnector.Channels.POST, condition = "")
@Component
public class RestConnector implements Connector<IntegrationRequest, Void> {
Expand Down
2 changes: 0 additions & 2 deletions .../starter/src/main/java/org/activiti/cloud/examples/connectors/TestBpmnErrorConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,10 @@

package org.activiti.cloud.examples.connectors;

import java.util.function.Consumer;
import org.activiti.cloud.api.process.model.CloudBpmnError;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.common.messaging.functional.FunctionBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationErrorSender;
import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
import org.activiti.cloud.connectors.starter.model.IntegrationErrorBuilder;
Expand Down
7 changes: 3 additions & 4 deletions ...ctor/starter/src/main/java/org/activiti/cloud/examples/connectors/TestErrorConnector.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,14 +15,10 @@
*/
package org.activiti.cloud.examples.connectors;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
import org.activiti.cloud.api.process.model.IntegrationRequest;
import org.activiti.cloud.api.process.model.IntegrationResult;
import org.activiti.cloud.common.messaging.functional.Connector;
import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
import org.activiti.cloud.common.messaging.functional.FunctionBinding;
import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
Expand All @@ -33,6 +29,9 @@
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

@ConnectorBinding(input = Channels.CHANNEL, condition = "")
@Component(Channels.CHANNEL + "Connector")
public class TestErrorConnector implements Connector<IntegrationRequest, Void> {
Expand Down

0 comments on commit 9b257de

Please sign in to comment.