honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use twitter4j 2.5 snapshot version as its the only version that works with the change of the endpoint

This commit is contained in:
Shay Banon 2011-10-14 17:46:35 +02:00
parent 7fb32a0287
commit 8c776bee97
3 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
.idea/modules/plugin-river-twitter.iml
View File

@ -15,12 +15,11 @@
<orderEntry type="module-library"> <orderEntry type="module-library">
<library name="twitter4j"> <library name="twitter4j">
<CLASSES> <CLASSES>
<root url="jar://$GRADLE_REPOSITORY$/org.twitter4j/twitter4j-core/jars/twitter4j-core-2.1.10.jar!/" /> <root url="jar://$GRADLE_REPOSITORY$/org.twitter4j/twitter4j-stream/jars/twitter4j-stream-2.2.5-SNAPSHOT.jar!/" />
<root url="jar://$GRADLE_REPOSITORY$/org.twitter4j/twitter4j-core/jars/twitter4j-core-2.2.5-SNAPSHOT.jar!/" />
</CLASSES> </CLASSES>
<JAVADOC /> <JAVADOC />
<SOURCES> <SOURCES />
<root url="jar://$USER_HOME$/opt/twitter4j/2.1.10/twitter4j-core/twitter4j-core-2.1.10-sources.jar!/" />
</SOURCES>
</library> </library>
</orderEntry> </orderEntry>
<orderEntry type="module" module-name="test-testng" scope="TEST" /> <orderEntry type="module" module-name="test-testng" scope="TEST" />

12
plugins/river/twitter/build.gradle
View File

@ -30,13 +30,17 @@ configurations {
} }
} }
repositories {
mavenRepo urls: 'http://twitter4j.org/maven2'
}
dependencies { dependencies {
compile project(':elasticsearch') compile project(':elasticsearch')
compile('org.twitter4j:twitter4j-core:2.2.4') { transitive = false } compile('org.twitter4j:twitter4j-core:2.2.5-SNAPSHOT') { transitive = false }
compile('org.twitter4j:twitter4j-stream:2.2.4') { transitive = false } compile('org.twitter4j:twitter4j-stream:2.2.5-SNAPSHOT') { transitive = false }
compile('org.twitter4j:twitter4j-core:2.2.4') { transitive = false } compile('org.twitter4j:twitter4j-core:2.2.5-SNAPSHOT') { transitive = false }
compile('org.twitter4j:twitter4j-stream:2.2.4') { transitive = false } compile('org.twitter4j:twitter4j-stream:2.2.5-SNAPSHOT') { transitive = false }
} }
task explodedDist(dependsOn: [jar], description: 'Builds the plugin zip file') << { task explodedDist(dependsOn: [jar], description: 'Builds the plugin zip file') << {

8
plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java
View File

@ -265,8 +265,8 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
} }
currentRequest = client.prepareBulk(); currentRequest = client.prepareBulk();
if (streamType.equals("filter") || filterQuery != null) { if (streamType.equals("filter") || filterQuery != null) {
stream.filter(filterQuery); stream.filter(filterQuery);
} else if (streamType.equals("firehose")) { } else if (streamType.equals("firehose")) {
stream.firehose(0); stream.firehose(0);
@ -416,7 +416,9 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
for (URLEntity url : status.getURLEntities()) { for (URLEntity url : status.getURLEntities()) {
if (url != null) { if (url != null) {
builder.startObject(); builder.startObject();
builder.field("url", url.getURL().toExternalForm()); if (url.getURL() != null) {
builder.field("url", url.getURL().toExternalForm());
}
if (url.getDisplayURL() != null) { if (url.getDisplayURL() != null) {
builder.field("display_url", url.getDisplayURL()); builder.field("display_url", url.getDisplayURL());
} }