summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPeter Wu <peter@lekensteyn.nl>2014-05-07 22:05:03 +0200
committerPeter Wu <peter@lekensteyn.nl>2014-05-07 22:05:03 +0200
commitb3f5eaaafe0fc17abe4252881f058215adafa0af (patch)
tree70cc8465a56596b9366a9cf8d37613bf58f9bc65
parent27d2376ce73158409e232ffbc4e156b4162281e3 (diff)
downloadTwitterDataAnalytics-b3f5eaaafe0fc17abe4252881f058215adafa0af.tar.gz
Fix null ptr when close/commit
commit closes everything via safeClose, so ensure that tweetGenerated re-opens it if necessary. Fixes: ƒ commit € Exception in thread "Thread-7" java.lang.NullPointerException at io.DataWriter.writeObject(DataWriter.java:137) at io.DataWriter.tweetGenerated(DataWriter.java:85) at provider.CompositeResultListener.tweetGenerated(CompositeResultListener.java:51) at io.StreamImpl$Poller.processObject(StreamImpl.java:255) at io.StreamImpl$Poller.run(StreamImpl.java:245) at java.lang.Thread.run(Thread.java:744)
-rw-r--r--src/io/DataWriter.java9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/io/DataWriter.java b/src/io/DataWriter.java
index 4f4c022..c1e1ce9 100644
--- a/src/io/DataWriter.java
+++ b/src/io/DataWriter.java
@@ -82,7 +82,14 @@ public class DataWriter implements ResultListener, Closeable, Flushable {
@Override
public void tweetGenerated(JSONObject obj) {
- writeObject(obj, m_tweet.getOutputStream(), m_tweetIdSet);
+ try {
+ // ensure that the file is open
+ m_tweet.open();
+
+ writeObject(obj, m_tweet.getOutputStream(), m_tweetIdSet);
+ } catch (IOException ex) {
+ getLogger().log(Level.SEVERE, "Cannot save tweet", ex);
+ }
}
/**