與阿卡駱駝訪問Twitter的返回JSON

Question

我使用一個HTTP POST方法使用URL 「https://stream.twitter.com/1.1/statuses/filter.json」，並在人體內我張貼的鍵/值我想從鳴叫 - 例如「軌道=倫敦」 。這工作正常。

現在我正在嘗試切換到AKKA-CAMEL，我正在使用他們的twitter消費者。我使用的端點URL：

def endpointUri: String = s"twitter:////search?type=direct&keywords=${Settings.queryList()}&consumerKey=${tweeterCredentials.consumerKey}&consumerSecret=${tweeterCredentials.consumerSecret}&accessToken=${tweeterCredentials.accessToken}&accessTokenSecret=${tweeterCredentials.accessTokenSecret}" 

我從Twitter的迴應，但它不是在JSON和它之前是不是鳴叫相同的信息。它只是返回tweet文本，但在獲取我需要分析的整個元數據之前。

有人知道如何配置Camel URI以返回JSON和整個元數據嗎？

感謝

Answer 1

我得到這個通過使用以下語法工作：

def endpointUri: String = s"twitter://streaming/filter?type=event&keywords=${Settings.queryList()}&consumerKey=${tweeterCredentials.consumerKey}&consumerSecret=${tweeterCredentials.consumerSecret}&accessToken=${tweeterCredentials.accessToken}&accessTokenSecret=${tweeterCredentials.accessTokenSecret}" 

其中：Settings.queryList返回一個逗號分隔keyworkds的列表。對象tweeterCredentials擁有Tweeter訪問網站的密鑰。

此外，有必要在駱駝設置AUTOACK這樣的：

倍率DEF AUTOACK =真

這防止超時異常。