vichu

<!-- Exclude aws-java-sdk-core -->
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-aws</artifactId>
  <exclusions>
    <exclusion>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-java-sdk-core</artifactId>
    </exclusion>
  </exclusions>

vichu

package completablefutureexample;

import java.util.Random;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class App {
    public static void main(String[] args) throws ExecutionException, InterruptedException {

vichu

package completablefutureexample;

import java.util.Random;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class App {

vichu

<dependencies>
  <!-- Spring starter dependencies -->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
  </dependency>

vichu

@Configuration
public class IntegrationFlowConfiguration {

  @Autowired
  PersonRepository personRepository;

  @Bean
  public IntegrationFlow fileInputFlow() {
    return IntegrationFlows.from(
        //Setting up the inbound adapter for the flow

vichu

package com.indywiz.springorama.springintegration.model;

import javax.persistence.Entity;
import javax.persistence.Id;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

vichu

package com.indywiz.springorama.springintegration.model;

import javax.persistence.Entity;
import javax.persistence.Id;

@Entity
public class Person {
  @Id
  private Long personId;
  private String personName;

vichu

<dependencies>
	<dependency>
		<groupId>org.projectlombok</groupId>
		<artifactId>lombok</artifactId>
		<version>1.16.20</version>
		<scope>provided</scope>
	</dependency>
</dependencies>

vichu

lombok {
	version = 1.16.20 
	sha256 = ""
}

vichu

<!-- For exposing the /integration endpoint -->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- For @EnableIntegrationGraphController annotation -->
<dependency>
  <groupId>org.springframework.integration</groupId>
  <artifactId>spring-integration-http</artifactId>
</dependency>