|
39 | 39 | */ |
40 | 40 | package org.javaee7.platform.twitter.hashtag; |
41 | 41 |
|
42 | | -import javax.ejb.Schedule; |
| 42 | +import java.util.logging.Logger; |
| 43 | +import javax.annotation.PostConstruct; |
43 | 44 | 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; |
44 | 52 |
|
45 | 53 | /** |
46 | 54 | * @author Arun Gupta |
47 | 55 | */ |
48 | 56 | @Stateless |
49 | 57 | 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 | + } |
50 | 71 |
|
51 | | - @Schedule(hour = "*", minute = "*", second = "0") |
| 72 | +// @Schedule(hour = "*", minute = "1", second = "0", persistent = false) |
52 | 73 | public void pingTwitter() { |
53 | 74 | 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 | + |
54 | 96 | } |
55 | 97 |
|
56 | 98 | } |
0 commit comments