Camel FileConsumer не обрабатывает Exchange, но распознает файл - PullRequest
Новая
       59

Camel FileConsumer не обрабатывает Exchange, но распознает файл

0 голосов
/ 05 августа 2020

У меня есть автономное приложение spring-boot-application, которое использует apache camel для использования одного файла, преобразования его и отправки содержимого в конечную точку отдыха.

Текущая рабочая настройка

pom. xml выглядит так: 

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.2.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.thehandofnod</groupId>
<artifactId>recommenderclient</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>recommenderclient</name>
<description>Client application which communicates with the different Recommender</description>

<properties>
    <java.version>1.8</java.version>
<camel-spring-boot-starter-version>2.25.2</camel-spring-boot-starter-version>
<camel-bindy-version>2.25.2</camel-bindy-version>
<camel-jackson-starter-version>2.25.2</camel-jackson-starter-version>
<camel-http-starter-version>2.25.2</camel-http-starter-version>
</properties>

<dependencies>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-validation</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-spring-boot-starter</artifactId>
        <version>${camel-spring-boot-starter-version}</version>
    </dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
 
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.camel/camel-bindy-starter -->
<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-bindy-starter</artifactId>
  <version>${camel-bindy-version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.camel/camel-jackson-starter -->
<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-jackson-starter</artifactId>
  <version>${camel-jackson-starter-version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.camel/camel-jetty-starter -->
<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-http-starter</artifactId>
  <version>${camel-http-starter-version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/ch.qos.logback/logback-classic -->
<dependency>  
  <groupId>ch.qos.logback</groupId>
  <artifactId>logback-classic</artifactId>
</dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
<!-- DB dependencies
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency> 
    <dependency>
        <groupId>com.h2database</groupId>
        <artifactId>h2</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>com.ibm.db2</groupId>
        <artifactId>jcc</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>com.oracle.database.jdbc</groupId>
        <artifactId>ojdbc8</artifactId>
        <scope>runtime</scope>
    </dependency>
 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
        <exclusions>
            <exclusion>
                <groupId>org.junit.vintage</groupId>
                <artifactId>junit-vintage-engine</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.springframework.restdocs</groupId>
        <artifactId>spring-restdocs-webtestclient</artifactId>
        <scope>test</scope>
    </dependency>

</dependencies>

<build>
    <plugins>
  <plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-enforcer-plugin</artifactId>
    <executions>
      <execution>
        <id>enforce</id>
        <configuration>
          <rules>
            <dependencyConvergence/>
          </rules>
        </configuration>
        <goals>
          <goal>enforce</goal>
        </goals>
      </execution>
    </executions>
  </plugin>
        <plugin>
            <groupId>org.asciidoctor</groupId>
            <artifactId>asciidoctor-maven-plugin</artifactId>
            <version>1.5.8</version>
            <executions>
                <execution>
                    <id>generate-docs</id>
                    <phase>prepare-package</phase>
                    <goals>
                        <goal>process-asciidoc</goal>
                    </goals>
                    <configuration>
                        <backend>html</backend>
                        <doctype>book</doctype>
                    </configuration>
                </execution>
            </executions>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.restdocs</groupId>
                    <artifactId>spring-restdocs-asciidoctor</artifactId>
                    <version>${spring-restdocs.version}</version>
                </dependency>
            </dependencies>
        </plugin>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

Как видите, в настоящее время я использую зависимость spring-boot-starter-web, чтобы приложение и, следовательно, маршруты верблюда работали. Я делаю это, потому что в противном случае FileConsumer просто распознает файл, создает обмен, но не направляет его в конечную точку для обработки. Вот где начинается мой вопрос.

Проблема

Если я не использую зависимость spring-boot-starter-web, но хочу, чтобы мое автономное приложение запускалось только один раз маршруты просто запускаются и завершаются без каких-либо действий (см. «Желаемая настройка»)

Проблема в том, что метод ScheduledBatchPollingConsumer#isBatchAllowed иногда возвращает false и иногда возвращает true . Я не могу понять, почему, но мне это кажется проблемой времени, потому что, если мне повезет, файл будет потреблен и обработан, а если мне не повезет, Exchange не будет обработан.

Желаемое setup

Поэтому я не хочу использовать зависимость spring-boot-starter-web и не хочу, чтобы приложение работало. Это должна быть моя желаемая конфигурация:

application.properties

camel.component.properties.encoding=UTF-8
# general spring-boot settings
#camel.springboot.main-run-controller=true
#camel.springboot.name=Recommender
# I don't want to keep it running! Shutdown after file was processed is what I wish for.
#camel.springboot.endpoint-bridge-error-handler=true
#camel.springboot.log-mask=true

# common attributes
projectID=2
# customer data route & properties
customerdata.from=file:D:\\projects\\TMP\\RecommenderClientTests\\source?fileName=CUSTOMER_DATA.csv&move=\..\processed&initialDelay=2000&delay=1000
customerdata.to=direct:TransmitCustomerData


# transmit customer data route & properties
transmitcustomerdata.from=direct:TransmitCustomerData
#transmitcustomerdata.to=file:D:\\projects\\TMP\\Camel\\to\\customer?    tempFileName=CustomerRequest_tmp.txt&fileName=Customer.json
transmitcustomerdata.to=http://u086:9002/prioritizer/project/customer/transmit?\
                        bridgeEndpoint=false&\
                        throwExceptionOnFailure=false&\
                        httpMethod=POST
transmitcustomerdata.append=false

# archive
archiv=file:D:\\projects\\TMP\\RecommenderClientTests\\archiv?    fileName=$simple{exchangeId}-$simple{date:now:yyyyMMddHHmm}&fileExist=Append

Вопрос

Как я могу настроить конечную точку файла, чтобы файл всегда использовался и обрабатывается , а маршруты отключаются после ?

1 Ответ

0 голосов
/ 05 августа 2020

Существуют параметры, которые вы можете настроить для выключения после обработки N сообщений, или после того, как они будут оставаться в идеале более N секунд, или после N времени et c.

Например, 

 camel.springboot.duration-max-messages = 1

См. Дополнительную информацию в документации: https://camel.apache.org/camel-spring-boot/latest/spring-boot.html

...