Skip to content

Commit 8b88925

Browse files
committed
use twitter4j 2.5 snapshot version as its the only version that works with the change of the endpoint
1 parent 2184038 commit 8b88925

File tree

3 files changed

+16
-11
lines changed

3 files changed

+16
-11
lines changed

.idea/modules/plugin-river-twitter.iml

Lines changed: 3 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

plugins/river/twitter/build.gradle

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,13 +30,17 @@ configurations {
3030
}
3131
}
3232

33+
repositories {
34+
mavenRepo urls: 'http://twitter4j.org/maven2'
35+
}
36+
3337
dependencies {
3438
compile project(':elasticsearch')
3539

36-
compile('org.twitter4j:twitter4j-core:2.2.4') { transitive = false }
37-
compile('org.twitter4j:twitter4j-stream:2.2.4') { transitive = false }
38-
compile('org.twitter4j:twitter4j-core:2.2.4') { transitive = false }
39-
compile('org.twitter4j:twitter4j-stream:2.2.4') { transitive = false }
40+
compile('org.twitter4j:twitter4j-core:2.2.5-SNAPSHOT') { transitive = false }
41+
compile('org.twitter4j:twitter4j-stream:2.2.5-SNAPSHOT') { transitive = false }
42+
compile('org.twitter4j:twitter4j-core:2.2.5-SNAPSHOT') { transitive = false }
43+
compile('org.twitter4j:twitter4j-stream:2.2.5-SNAPSHOT') { transitive = false }
4044
}
4145

4246
task explodedDist(dependsOn: [jar], description: 'Builds the plugin zip file') << {

plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -265,8 +265,8 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
265265
}
266266
currentRequest = client.prepareBulk();
267267
if (streamType.equals("filter") || filterQuery != null) {
268-
269-
stream.filter(filterQuery);
268+
269+
stream.filter(filterQuery);
270270

271271
} else if (streamType.equals("firehose")) {
272272
stream.firehose(0);
@@ -416,7 +416,9 @@ private class StatusHandler extends StatusAdapter {
416416
for (URLEntity url : status.getURLEntities()) {
417417
if (url != null) {
418418
builder.startObject();
419-
builder.field("url", url.getURL().toExternalForm());
419+
if (url.getURL() != null) {
420+
builder.field("url", url.getURL().toExternalForm());
421+
}
420422
if (url.getDisplayURL() != null) {
421423
builder.field("display_url", url.getDisplayURL());
422424
}

0 commit comments

Comments
 (0)