Ich habe Schwierigkeiten, mich auf das Konzept einzulassen.

Ich versuche, einen Endpunkt zu implementieren, der auf einem TCP-Port auf eingehende Nachrichten in einem proprietären Format wartet, die dann die Nachricht transformieren und Camel die Weiterleitung und das Routing übernehmen lässt.

Habe ich richtig verstanden, dass der Produzent für das Versenden von Nachrichten in das verantwortlich istEndpoint und dasConsumer empfängt sie von diesem Endpunkt?

Beim Studium der Schnittstellen konnte ich den Nachrichtenfluss zwischen diesen Objekten nicht herausfinden, insbesondere auf der Verbraucherseite.Consumer definiert nurstart() undstop() Methoden ...

Wenn Sie einen Test für eine Skeleton-Implementierung einrichten,Camel aufgerufencreateProducer() auf dem Endpunkt undprocess() auf dem Erzeugerobjekt. Danach kehrte es zurück, ohne irgendetwas mit dem Verbraucher oder dem mit ihm verbundenen Prozessor zu tun.

Könnte mich jemand in die richtige Richtung weisen?