Es sieht nicht so aus, als ob Sie den Kontext erstellen und starten, was wahrscheinlich der Grund ist, warum die Nachricht Ihre Route nie erreicht. Hier ist ein Beispiel für den Einstieg:
https://examples.javacodegeeks.com/enterprise-java/apache-camel/apache-camel-hello-world-example/
import org.apache.activemq.camel.component.ActiveMQComponent;
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
public class CamelHelloWorldExample {
public static void main(String[] args) throws Exception {
CamelContext context = new DefaultCamelContext();
try {
context.addComponent("activemq", ActiveMQComponent.activeMQComponent("vm://localhost?broker.persistent=false"));
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("activemq:queue:test.queue")
.to("stream:out");
}
});
ProducerTemplate template = context.createProducerTemplate();
context.start();
template.sendBody("activemq:test.queue", "Hello World");
Thread.sleep(2000);
} finally {
context.stop();
}
}
}
Hinweis context.start() und context.stop();
Könnte sein, weil Sie versäumt haben, den Körper mit einer geschweiften Klammer zu schließen $ {in.body? Oder ist es nur ein Typ, wenn Sie es hier eingefügt haben? – gnanagurus
Nein, es ist nur ein Tippfehler, fürchte ich! – DJ180