From 6abbe2e5855952d241e3fe269645419fd84b48ca Mon Sep 17 00:00:00 2001 From: Thomas Peetz Date: Tue, 4 Aug 2026 23:22:26 +0200 Subject: [PATCH] Add reading queue media.link.add --- .../integration/routes/QueueMediaLinkAdd.java | 25 +++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLinkAdd.java diff --git a/kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLinkAdd.java b/kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLinkAdd.java new file mode 100644 index 0000000..7ec886a --- /dev/null +++ b/kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLinkAdd.java @@ -0,0 +1,25 @@ +package de.thpeetz.kontor.integration.routes; +import de.thpeetz.kontor.media.services.MediaFileService; +import org.apache.camel.builder.RouteBuilder; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@Component +public class QueueMediaLinkAdd extends RouteBuilder { + + @Autowired + private final MediaFileService mediaFileService; + + @Autowired + public QueueMediaLinkAdd(MediaFileService mediaFileService) { + this.mediaFileService = mediaFileService; + } + + @Override + public void configure() throws Exception { + from("jms:queue:media.link.add") + .routeId("read-queue-media-link-add") + .log("${body}") + .to("jms:queue:media.link.add.processed"); + } +}