suroPing socketClose
lake connection suroPing fix
...
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
[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
suro-elasticsearch
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
unit test fixed
ThreadPoolQueuedSink