suroPing socketClose
lake connection suroPing fix
...
Merge pull request #89 from thinker0/hotfix/finally_close_npe

Hotfix/finally close npe
RemoteFileSink's pending messages should consider files

- cleanUp with fetchAll to describe unclosed files
- RemoteFileSink.getNumOfPendingMessages() is returning the number of files not uploaded yet when the number of pending messages in LocalFileSink is 0
Merge pull request #90 from metacret/ISSUE-82

RemoteFileSink's pending messages should consider files
[Gradle Release Plugin] - pre tag commit:  '0.2.7'.
[Gradle Release Plugin] - new version commit:  '0.2.8-SNAPSHOT'.
Create SuroInput

- input.json file on conf directory, by default only thrift server input
- addInputType on SuroPlugin
- DefaultObjectMapper additional class injection
- TrafficController registers/unregister input
- KafkaConsumer implements SuroInput
- ThriftServer implements SuroInput
upgrade joda-time dependency to 2.3
Merge pull request #96 from Netflix/ISSUE-95

upgrade joda-time dependency to 2.3
Merge pull request #94 from metacret/ISSUE-91

Create SuroInput
suro-elasticsearch
Merge remote-tracking branch 'upstream/master' into ISSUE-92
suro-elasticsearch is added with 0.90.10

will be updated to 1.x in the future

BlockingQueue4Sink is added to wait until Sink is draining messages

initialSet and initialStart are implemented for SinkManager and InputManager to control bootstrap sequence. Always SinkManager should be initialized first

At DefaultIndexInfoBuilder, DataConverter is applied first

KafkaConsumer's consumerProps is changed to protected to override consumer properties
ThriftServer stopTakingTraffic typo
Merge pull request #98 from metacret/ISSUE-92

ElasticSearchSink
unit test fixed
Merge pull request #99 from metacret/ISSUE-92

unit test fixed
ThreadPoolQueuedSink