Aller au contenu principal

Apache Camel ⇄ Pulse

Intermédiaire ⏱ 10 min camel · java · endpoint http · ✅ exécuté E2E dans le repo

Camel possède le routage/l'orchestration EIP ; Pulse est le step de traitement de flux atteint via le composant http standard de Camel — pas de glue. Exemple du repo : examples/camel-pulse-bridge/ — exécuté de bout en bout avec un vrai CamelContext sur Camel 4.8 LTS.

from("direct:score")
   .marshal().json()
   .to("http://<pulse>/api/pulse/x/order-scoring/in")               // envoyer la commande
   .delay(1500)
   .to("http://<pulse>/api/pulse/events/order-scoring.score.out")   // lire le verdict
   .process(decide);                                                // escalate | auto-approve

Lancez-le​

pulse server start --dev
mkdir app && cp pulse.yaml app/ && (cd app && pulse deploy .)   # monte order-scoring
PULSE_URL=http://localhost:9090 mvn -q compile exec:java

Le token vient de PULSE_TOKEN ou de ~/.pulse/credentials.json (écrit par le login --dev).

Sortie validée​

amount= 2500  ->  decision=escalate
amount=  300  ->  decision=auto-approve

Camel garde le vocabulaire EIP (routes, processors, error handlers) ; Pulse garde l'état de flux fenêtré, par clé, capable d'IA, derrière une URL d'endpoint.

Ensuite​