CODEWITHSUNDEEP
twitterapache-camelakkaakka-camel
Fabio
Fabio

Reputation: 615

Accessing Twitter with Akka Camel to return JSON

I was using an HTTP POST method using the URL "https://stream.twitter.com/1.1/statuses/filter.json" and in the body I was posting the key/value I wanted to get tweets from - for example "track=london". This was working fine.

Now I am trying to switch to AKKA-CAMEL and I am using their twitter consumer. I am using an endpoint URL of:

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

I get a response from twitter but it is not in JSON and it is not the same information about the tweet as before. It just return the tweet text but before I was getting the whole metadata which I need to analyze.

Does somebody knows how to configure Camel URI to return JSON and the whole metadata as before?

Thanks

Upvotes: 0

Views: 60

Answers (1)

Fabio
Fabio

Reputation: 615

I got this to work by using the following syntax:

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

Where: Settings.queryList return a comma separated list of keyworkds. The object tweeterCredentials holds the keys from Tweeter to access the site.

Also it is necessary to set autoAck like this in Camel:

override def autoAck = true

This prevents a timeout exception.

Upvotes: 0

Related Questions