summaryrefslogtreecommitdiff
path: root/src/io/StreamImpl.java
AgeCommit message (Collapse)AuthorFilesLines
2014-05-22Refactored JSON to GSON's implementation.Maurice Laveaux1-17/+23
* Changed JSONException to JsonParseException.
2014-05-07Display user for tweet, strip whitespace around keywordPeter Wu1-0/+1
2014-05-07Get rid of separate profilesPeter Wu1-9/+0
These are always available from the tweets themselves...
2014-05-07Allow commit to disconnect for empty keywords, detect dead connectionPeter Wu1-6/+6
2014-05-07Set read timeout for streamingPeter Wu1-0/+3
2014-05-07Fix deadlock in Poller if worker thread stops/diesPeter Wu1-0/+10
2014-05-07StreamImpl: make (un)watchKeywords support a listPeter Wu1-4/+20
2014-05-07Use IOUtils.closeQuietly for less verbosityPeter Wu1-13/+3
2014-05-02Reject commits without keywordsPeter Wu1-0/+4
2014-05-02Avoid hang during closePeter Wu1-4/+29
Apparently the socket operations are blocking in a way such that even interrupt() cannot stop it. Close the socket (which will generate an IOException masked as JSONException) to immediately close the socket. Also do not leak a socket if an error occurred in the Worker constructor (when a Stream connection is set up).
2014-05-01Add command to print active keywordsPeter Wu1-0/+15
2014-05-01New thread for notifying of new objectsPeter Wu1-13/+95
* Use volatile boolean instead of AtomicBoolean. There will only be one one writer. * Store received objects in a queue instead of printing them. * Rename thread to clarify its I/O purpose. * Create new Thread for notifying observers of new tweets and users.
2014-05-01Get rid of unused and broken poll functionPeter Wu1-9/+0
2014-05-01Merge branch 'master' of git.lekensteyn.nl:tue/2IOC0-DBL/TwitterDataAnalyticsMaurice Laveaux1-5/+11
2014-05-01Added the target command with options: file, shell.Maurice Laveaux1-0/+4
* Implemented target file, which uses DataWriter as RequestListener which writes the tweets and profiles. * Added profiles-filename, tweets-filename to the config.
2014-05-01Close stream when stopping worker, English tweets only please...Peter Wu1-5/+11
2014-05-01Allow result and exception handler to be changedPeter Wu1-7/+29
2014-05-01Fix signing for OAuth POST messages, fix search paramPeter Wu1-3/+3
2014-05-01[WIP] Initial hacky TweetShellPeter Wu1-2/+26
In TESTING! DefaultOAuthConsumer does not play nice with POST requests... need to fix that somehow.
2014-04-30Use wrapped gzipinputstream from twitterPeter Wu1-2/+2
2014-04-30StreamImpl: Read JSON objects and validatePeter Wu1-4/+25
2014-04-30StreamImp: support gzip compressionPeter Wu1-1/+17
May yield huge bandwidth savings and improve throughput for slow links.
2014-04-30[WIP] Stream processorPeter Wu1-0/+209