Added spout from socket
Replaced 'list' utility method from Parser and replaced for the use of ImmutableList and added messageId to StreamValues
Added messageId to emit of basic spouts
Removed messageId to emit of basic spouts, only useful if tuples can be replayed
Added ack for tuples and anchors
Removed log4j configuration as Storm uses its own configuration
Added codahale metrics library
Added spout and bolt metric hooks
Added utility for getting instance of metrics registry
Basic spouts are now acking received tuples
Basic spouts are now acking received tuples
Added constants for metrics configuration
Introduced the created_at field to calculate the latency
Added automatic timestamp append for FileSpout
Using getMeterHook method to enable custom meter hooks
Meter hook for bolts tracks emitted and received tuples, plus processing latency. Sink meter tracks received tuples and overall latency.
Created timestamp basic field
Removed sink meter
Removed created at field
Getting complete latency from spout ack info