apache-camel-spring-boot-1.x (0.0.1)

# spring boot keep running if you not using spring-boot-web for example...
camel.springboot.main-run-controller=true
# actuator support:
spring.profiles.active=camel
management.context-path=/actuator/
management.security.enabled=false
# we wanna also post to camel endpoints (curl -XPOST ...):
endpoints.camelroutes.read-only=false

@Configuration
@RequiredArgsConstructor
public class MoveFilesCamelConfig {

  @Bean
  public RouteBuilder moveFilesRoute() {
    return new RouteBuilder() {
      @Override
      public void configure() throws Exception {
        from("file:///tmp/camel-in")
            .routeId("dir-to-dir")
            .to("file:///tmp/camel-out");
      }
    };
  }
}

@Slf4j
@Configuration
@RequiredArgsConstructor
public class MoveFilesViaJmsCamelConfig {

  @Bean
  public RouteBuilder moveFilesViaJmsRoute() {
    return new RouteBuilder() {
      @Override
      public void configure() throws Exception {

        from("file:///tmp/camel-jms-in")
            .routeId("in-dir-to-jms")
            .transform()
            .body(GenericFile.class, genericFile -> {
              final File file = File.class.cast(genericFile.getFile());
              try (final FileInputStream inputStream = new FileInputStream(file)) {
                final InputStreamReader streamReader = new InputStreamReader(inputStream);
                final BufferedReader in = new BufferedReader(streamReader);
                return in.lines().collect(joining());
              } catch (IOException e) {
                log.error(e.getLocalizedMessage());
                throw new RuntimeException(e);
              }
            })
            .to("jms:queue:files")
        ;

        from("jms:queue:files")
            .routeId("jms-to-out-dir")
            .to("file:///tmp/camel-jms-out")
        ;
      }
    };
  }
}

@Component
@RequiredArgsConstructor
class MoveFilesViaJmsComponentCustomizer implements ComponentCustomizer<JmsComponent> {

  final ConnectionFactory connectionFactory;

  @Override
  public void customize(JmsComponent component) {
    component.setConnectionFactory(connectionFactory);
  }
}

@Configuration
@RequiredArgsConstructor
public class ChangeFilenameHeaderCamelConfig {

  @Bean
  public RouteBuilder filenameHeaderRoute() {
    return new RouteBuilder() {
      @Override
      public void configure() throws Exception {
        from("file:///tmp/camel-filename-in")
            .routeId("change-filename-header")
            .setHeader("CamelFileName", () -> format("%s-changed.txt", UUID.randomUUID().toString()))
            .to("file:///tmp/camel-filename-out");
      }
    };
  }
}

@Configuration
@RequiredArgsConstructor
public class ExchangeProcessorCamelConfig {

  @Bean
  public RouteBuilder processExchangeRoute() {
    return new RouteBuilder() {
      @Override
      public void configure() throws Exception {
        from("file:///tmp/camel-exchange-in")
            .routeId("exchange-processor")
            .process().exchange(exchange -> {
              final Message inputMessage = exchange.getIn();
              final Object body = inputMessage.getBody(String.class);
              log.info("handling message body in exchange consumer: {}", body);
            })
            .to("file:///tmp/camel-exchange-out");
      }
    };
  }
}

@Configuration
@RequiredArgsConstructor
public class EasierExchangeProcessorCamelConfig {

  @Bean
  public RouteBuilder easierExchangeRoute() {
    return new RouteBuilder() {
      @Override
      public void configure() throws Exception {
        from("file:///tmp/camel-easier-exchange-in")
            .routeId("easier-exchange")
            .process()
            .message(message -> {
              final String body = message.getBody(String.class);
              final Map<String, Object> headers = message.getHeaders();
              log.info("easy body: {}", body);
              headers.entrySet().parallelStream()
                  .filter(e -> "CamelFileLength".contains(e.getKey()))
                  .forEach(e -> log.info("header({}): {}", e.getKey(), e.getValue()));
            })
            /* // absolutely same, even more easier!
            .body(String.class, (body, headers) -> {
              log.info("easiest: {}", body);
              headers.entrySet().parallelStream()
                  .filter(e -> "CamelFileLength".contains(e.getKey()))
                  .forEach(e -> log.info("header({}): {}", e.getKey(), e.getValue()));
            })
            */
            .to("file:///tmp/camel-easier-exchange-out");
      }
    };
  }
}

@Configuration
@RequiredArgsConstructor
public class ChoiceCamelConfig {

  @Bean
  public RouteBuilder choiceRoute() {
    return new RouteBuilder() {
      @Override
      public void configure() throws Exception {
        from("file:///tmp/camel-choice-in")
            .routeId("choice")
            //@formatter:off
            .choice()
              .when(exchange -> !exchange.getMessage().getBody(String.class).toLowerCase().contains("err"))
                .to("file:///tmp/camel-choice-out")
              .otherwise()
                .to("file:///tmp/camel-choice-error")
            .endChoice()
            //@formatter:on
        ;
      }
    };
  }
}