From ddb17783b554625ffa7050f91f004784263e0efe Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 26 Jun 2022 09:32:49 +0200 Subject: [PATCH] TOD --- TOD.txt | 13 +++++++++++++ .../de/juplo/kafka/IntegrationConfiguration.java | 11 +++++++++++ src/main/resources/integration.xml | 12 ------------ 3 files changed, 24 insertions(+), 12 deletions(-) create mode 100644 TOD.txt create mode 100644 src/main/java/de/juplo/kafka/IntegrationConfiguration.java delete mode 100644 src/main/resources/integration.xml diff --git a/TOD.txt b/TOD.txt new file mode 100644 index 0000000..70adc76 --- /dev/null +++ b/TOD.txt @@ -0,0 +1,13 @@ +Dieser Ansatz wurde erst mal verworfen! + +* Es geht hier nur darum, Daten einzulesen und in einen Channel zu schreiben +* Die Idee, dafür die Stream-Abstraktion von Integration zu verwenden, + passt aus mehreren Gründen schlecht zum gewählten Beispiel: + * Es könnten hier nur Datenblobs erzeugt werden und nicht, analog zu + den anderen Implementierungs-Beispielen, die unterschiedlichen + Nachrichten-Typen. + * Wenn überhaupt so möglich, wie angedacht, müsste mit der Stream- + Abstraktion ein Channel mit Daten-Blobs erzeugt werden, der dann + von einem Filter verarbeitet wird, der aus den Daten-Blobs die + erwarteten Nachrichten-Typen erzeugt. +* ... diff --git a/src/main/java/de/juplo/kafka/IntegrationConfiguration.java b/src/main/java/de/juplo/kafka/IntegrationConfiguration.java new file mode 100644 index 0000000..624e9ef --- /dev/null +++ b/src/main/java/de/juplo/kafka/IntegrationConfiguration.java @@ -0,0 +1,11 @@ +package de.juplo.kafka; + +import org.springframework.context.annotation.Configuration; +import org.springframework.integration.config.EnableIntegration; + + +@Configuration +@EnableIntegration +public class IntegrationConfiguration +{ +} diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml deleted file mode 100644 index 2b22bcd..0000000 --- a/src/main/resources/integration.xml +++ /dev/null @@ -1,12 +0,0 @@ - - - - - - -- 2.20.1