Cammello nel contenitore OSGi: applica InterceptStrategy a tutti i contesti cammello

Question

Ho diversi pacchetti (A, B e C) distribuiti in un contenitore OSGi, ciascuno contenente uno CamelContext e alcuni percorsi. Ho un altro pacchetto (M) con un CamelContext con un percorso (per la raccolta dei dati di monitoraggio) e un bean InterceptStrategy. Vorrei che il bean InterceptStrategy di M si applicasse automaticamente a tutti gli altri CamelContext s nel contenitore (ad esempio quelli in A, B e C), senza dover modificare gli altri pacchetti.

In definitiva, l'obiettivo è intercettare i dati da ogni CamelContext nel percorso in M, senza dover apportare modifiche a A, B o C per instradare esplicitamente lo Exchange. Questo approccio o un approccio simile è fattibile?

Tutti i CamelContext s sono configurati utilizzando Spring XML.

---

Aggiornamento: contesto aggiuntivo

Bundles A, B, e C contengono il prodotto principale responsabile del trattamento dei dati. Bundle M contiene uno strumento di monitoraggio opzionale, progettato per misurare determinati parametri dei dati che fluiscono attraverso A, B e C. Attualmente, l'aggiunta dello strumento opzionale richiede la modifica dei percorsi in A, B e C per aggiungere ulteriori Processor s per arricchire Exchange con i dati di monitoraggio e leggere i dati di monitoraggio prima degli endpoint <to />.

L'obiettivo è essere in grado di inserire il pacchetto M in un sistema già verificato-come-lavoro con A, B e C; e farlo applicare automaticamente alle rotte esistenti senza dover modificare la configurazione per i bundle esistenti e funzionanti. È è accettabile per apportare modifiche a A, B e C per supportare questo, a condizione che le modifiche non causino A, B e C per fare affidamento su M per l'esecuzione (vale a dire, ABC deve ancora funzionare senza M).

Se c'è un mezzo migliore per farlo rispetto all'utilizzo di intercettori, sono aperto a questo. Gli obiettivi principali sono:

1. Tenere A, B, e C disaccoppiato da M (soprattutto durante lo sviluppo)
2. Garantire integrare M con A, B, e C è il più semplice possibile
3. Consentire M essere integrato senza dover modificare manualmente A, B o C

Answer 1

Non penso che questo sia possibile utilizzando InterceptorStrategy poiché si aspetta che sia in esecuzione nello stesso contesto di cammello. L'unico modo in cui sono consapevole di lavorare su più contesti è l'utilizzo dell'endpoint della VM (che è ovviamente limitato alla stessa JVM), tuttavia in questo caso probabilmente sarebbe meglio utilizzare JMS, JMX o qualcosa di simile.

JMS

Crea un InterceptorStrategy per ogni contesto cammello in A, B & C che pubblica i messaggi di M

intercept().bean(transformForMonitoring).to("jms:queue:monitoring"); 

from("whatever:endpoint") 
    .process(myProcessor) 
    .to("target:endpoint"); 

Si potrebbe anche utilizzare il componente vm sul intercept() se non volevi il sovraccarico di JMS, tuttavia limita il componente di monitoraggio a una singola JVM.

JMX

Questo è un po 'più complicato, ma l'idea di base è di informare il contesto cammello di pubblicare MBeans per A, B & C

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring"> 
    <jmxAgent id="agent" mbeanObjectDomainName="your.domain.name"/> 
    ... 
</camelContext> 

e poi M connettersi al server JVM MBean e utilizzare qualcosa come NotificationListener per reagire agli scambi.

Answer 2

Utilizzare Spring-DM, o meglio trasformare tutti i percorsi basati su xml primaverili in quelli del modello. Questo è il modo migliore di usare Route basate su XML in Karaf/Osgi.

Answer 3

Una delle possibilità è definire un custom Tracer in bundle 'M' ed esportarlo come servizio OSGi.

In fascio A, B, C definiscono osgi riferimento alle esportato Tracer fagiolo

Usa camel JMX abilitare traccia.

Ciò comporterà cambiamenti nel fascio A, B, C ma sarà minima e darà anche capacità di integrare e configurare l'analisi (intercettazione)

non hanno provato io stesso, ma hth