Wie ändert man Prozessoreigenschaften zur Laufzeit mit Camel?

Question

Ich habe eine Camel in Java DSL wie folgt geschrieben Strecke Definition:

from(myEndpoint) 
.throttle(200) 
.to(myOtherEndpoint); 

Dies verbindet meine beiden Endpunkte eine Throttler verwendet, die den Nachrichtenfluss zu 200 Nachrichten pro Sekunde begrenzt.

Ich suche nach einer Möglichkeit, die maximaleRequestCount/Sekunde während der Laufzeit zu ändern. Also muss ich irgendwie zu der aufgerufenen Throttler Instanz kommen und die Eigenschaft ändern.

Wie kann ich auf den Throttler zugreifen?

Answer 1

Ok, dachte ich, es selbst heraus ...

Sie benötigen Throttler Instanz selbst zu definieren.

Throttler throttler = new Throttler(null, 200); 

Dann können Sie es in Ihre Routen wie diese, weil Throttler der Prozessor-Schnittstelle implementiert:

from(myEndpoint) 
.process(throttler) 
.to(myOtherEndpoint); 

Jedes Mal, wenn Sie möchten, können Sie die Eigenschaften des throttler ändern.

Answer 2

Ja, das ist eine saubere Lösung.

In Camel 2.0 können Sie jetzt die Laufzeitprozessoren in der Route navigieren und so alle Throullers finden und dann dynamisch ändern.

Aber wir arbeiten auch an der Verbesserung der JMX in Camel 2.1, so dass Sie Throttler/Delayer und die Likes von JMX ändern können.

Und vielleicht auch die Navigate API verbessern, so dass Sie in einem einzigen Liner finden können, zB vielleicht nach ID suchen, wenn Sie eine ID in der Route angeben. Oder nach Typen, so können Sie filtern und erhalten nur die Throullers etc.