This commit is contained in:
+25
@@ -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");
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user