Removed redundant code from SuroModule.

…d in in last commit

…c and accurate

…"FastProperty"

Support an optional filter on each sink in the routing map.  The
routing map format is changed form

"where" : ["sink1", "sink2"]

to

"where" : [
   { "sink" : "sink1"},
   { "sink" : "sink2",
      "filter" : { "type" : "regex",
          "regex" : "abc" }
   }
]

This change breaks backwards compatibility with the exisintg route map
definition

Per sink filter

- Added support of JSON format for message filtering

Automatically creating file queue directories for Queue4client

suro-tranquility's ZkExternalResource file is copied and pased from suro-kafka, its test class dependency is not making idea project file correctly

Removed duplicated metrics. Added default tag for empty routing key

FileBlockingQueue's default gc period changed to 1 minute from 1hour
MessageSetReader's exception should truncate all messages
Updated thrift gen files
Added a few more test cases for FileBlockingQueue including multithreading
HealthCheck is not closing TTransport because it's making server throw the following error:
2014-08-21 06:55:11,276 ERROR Thread-15 AbstractNonblockingServer$FrameBuffer - Read an invalid frame size of 0. Are you using TFramedTransport on the client side?

Added configuration SuroClient.enableOutPool, by default false
SuroClient result status code is not OK, the server should be marked down
When OutPool is disabled, ConnectionOutPool should not be created
Unit tests fixed

Disable ConnectionOutPool

MessageSetReader will increase DROPPED_COUNT on the exception
MesageRouter will increase DROPPED_COUNT on emptyRoutingKey
QueuedSink with sinkId will increase DROPPED_COUNT with the tag, sinkId

ISSUES

AsyncSuroClient jobQueue is blocked on offer()

file queue size limit

we can safely ignore IndexOutOfBoundaryException

FileQueue with sizeLimit configuration

change get() to get(File file) , providing more useful info .

use suro File's lastModify/dateCreated time to generate upload path.