Skip to content
This repository was archived by the owner on Jan 30, 2019. It is now read-only.

Commit 88d1cd7

Browse files
author
Arun Gupta
committed
Making interim update
Former-commit-id: 5c5c9b0356ce4cfbbd672e57ddd8e766407b5adf
1 parent 3cb8972 commit 88d1cd7

2 files changed

Lines changed: 53 additions & 3 deletions

File tree

samples/platform/twitter-hashtag/pom.xml

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,14 @@
1313
<version>1.0-SNAPSHOT</version>
1414
<packaging>war</packaging>
1515

16-
<name>twitter-hashtag</name>
16+
<dependencies>
17+
<dependency>
18+
<groupId>org.glassfish.jersey.core</groupId>
19+
<artifactId>jersey-common</artifactId>
20+
<version>2.0</version>
21+
<type>jar</type>
22+
</dependency>
23+
</dependencies>
24+
1725

1826
</project>

samples/platform/twitter-hashtag/src/main/java/org/javaee7/platform/twitter/hashtag/TwitterPingBean.java

Lines changed: 44 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,18 +39,60 @@
3939
*/
4040
package org.javaee7.platform.twitter.hashtag;
4141

42-
import javax.ejb.Schedule;
42+
import java.util.logging.Logger;
43+
import javax.annotation.PostConstruct;
4344
import javax.ejb.Stateless;
45+
import javax.json.JsonArray;
46+
import javax.json.JsonObject;
47+
import javax.ws.rs.client.Client;
48+
import javax.ws.rs.client.ClientBuilder;
49+
import javax.ws.rs.client.WebTarget;
50+
import javax.ws.rs.core.MediaType;
51+
import org.glassfish.jersey.filter.LoggingFilter;
4452

4553
/**
4654
* @author Arun Gupta
4755
*/
4856
@Stateless
4957
public class TwitterPingBean {
58+
59+
WebTarget target;
60+
61+
@PostConstruct
62+
private void init() {
63+
Client client = ClientBuilder.newClient();
64+
// client.register(new LoggingFilter(Logger.getAnonymousLogger(), true));
65+
target = client
66+
.target("https://api.twitter.com/1.1/search/tweets.json")
67+
.queryParam("q", "%23javaee7")
68+
.queryParam("result_type", "mixed")
69+
.queryParam("count", "100");
70+
}
5071

51-
@Schedule(hour = "*", minute = "*", second = "0")
72+
// @Schedule(hour = "*", minute = "1", second = "0", persistent = false)
5273
public void pingTwitter() {
5374
System.out.println("pinging Twitter ...");
75+
target.queryParam("since_id", "335724844056449027");
76+
77+
String response = target
78+
.request(MediaType.TEXT_PLAIN)
79+
.header("Authorization", "OAuth oauth_consumer_key=\"myE71Pd0EDFGnisST8XQ\", oauth_nonce=\"f4f1506b69e50ff53b7416cff1137a32\", oauth_signature=\"6IeMHOlgyBy4W75vFZRZTrzuIs8%3D\", oauth_signature_method=\"HMAC-SHA1\", oauth_timestamp=\"1371254570\", oauth_token=\"12387972-28nXVXAmjdtfb83Y6s3Qf1hPIurv7YrGKhxmjEnrJ\", oauth_version=\"1.0\"")
80+
.get(String.class);
81+
System.out.println(response);
82+
}
83+
84+
public void pingFacebook() {
85+
Client client = ClientBuilder.newClient();
86+
WebTarget t = client.target("https://graph.facebook.com/search?q=java&type=post");
87+
88+
JsonObject object = t.request().get(JsonObject.class);
89+
JsonArray results = object.getJsonArray("data");
90+
for (JsonObject result : results.getValuesAs(JsonObject.class)) {
91+
System.out.println("Name ----> " + result.getJsonObject("from").getString("name") + "<br>");
92+
System.out.println("Message ----> " + result.getString("message", "") + "<br>");
93+
System.out.println("<p><p>");
94+
}
95+
5496
}
5597

5698
}

0 commit comments

Comments
 (0)