使用處理器而不是端點

Question

駱駝很新。我需要竊聽一個處理管道，然後檢查裏面的事件，併發送統計的度量。該代碼 看起來像這樣的事情：

Processor statsdProcessor = new StatsDProcessor(); 
... 
from("disruptor:wiretap").process(statsdProcessor); 

的disruptor:wiretap已經連接到的主輸油管道。

我想知道什麼是使用prossor沒有 to()端點的含義？請問exchanges是否在內存中，因爲 沒有到達超時的地方，或者因爲緩衝區已滿而被覆蓋？

Answer 1

坦率地說，在最低的水平，那麼Apache的駱駝裏面，它的一切只是processor，例如to是specialzed processor等

因此，當一個消息被駱駝路由，它基本上只是

from X 
    process 
    process 
    process 
    ... 

因此，在沒有任何to的情況下，在駱駝中定義路線是沒有意義的。因爲這一切只是從 - >過程 - >過程等。

Answer 2

這是一個「匯」 - 它只有一個輸入和沒有輸出（或至少沒有輸出再次進入管道）。其他例子有文件接收器（將數據寫入文件），數據庫接收器等。

相反是一個「源」 - 其中沒有from()，只有to()。這些是由外部信號（即不是由駱駝框架）觸發的，它們將數據泵入管道（駱駝接管的地方）。常見的例子是cron作業（基於時間的觸發器），REST服務，連接到排隊系統的服務，如ActiveMQ或MQSeries。