TFJ-545 now clear TheadLocal map is cleared with Site Streams

Twitter4J · Jan 28, 2011 · 923f602 · 923f602
1 parent 539ab5c
commit 923f602
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/twitter4j-core/src/main/java/twitter4j/AbstractStreamImplementation.java b/twitter4j-core/src/main/java/twitter4j/AbstractStreamImplementation.java
@@ -34,6 +34,7 @@
 import twitter4j.internal.org.json.JSONArray;
 import twitter4j.internal.org.json.JSONException;
 import twitter4j.internal.org.json.JSONObject;
+import twitter4j.json.DataObjectFactory;
 import twitter4j.json.JSONObjectType;
 
 import java.io.BufferedReader;
@@ -99,6 +100,7 @@ public void run() {
                     line = parseLine(line);
                     if (line.length() > 0) {
                         try {
+                            DataObjectFactoryUtil.clearThreadLocalMap();
                             JSONObject json = new JSONObject(line);
                             JSONObjectType jsonObjectType = JSONObjectType.determine(json);
                             if (logger.isDebugEnabled()) {

diff --git a/twitter4j-core/src/main/java/twitter4j/StatusStreamImpl.java b/twitter4j-core/src/main/java/twitter4j/StatusStreamImpl.java
@@ -79,7 +79,6 @@ public void next(StreamListener[] listeners) throws TwitterException {
     }
 
     protected String parseLine(String line) {
-        DataObjectFactoryUtil.clearThreadLocalMap();
         this.line = line;
         return line;
     }

diff --git a/twitter4j-core/src/main/java/twitter4j/UserStreamImpl.java b/twitter4j-core/src/main/java/twitter4j/UserStreamImpl.java
@@ -65,7 +65,6 @@ public void next(StreamListener[] listeners) throws TwitterException {
     }
 
     protected String parseLine(String line) {
-        DataObjectFactoryUtil.clearThreadLocalMap();
         this.line = line;
         return line;
     }