Package org.thales.punch.libraries.storm.spout.impl

Interface Summary

Interface	Description
ISyslogReceiver<T>
ISyslogServer
LogFileTailerListener	Provides listener notification methods when a tailed log file is updated

Class Summary

Class	Description
FileSpout	The original implementation of the File Spout.
FileSpoutWatcher	The "Watcher" implementation of the File Spout.
HttpServer	This http server puts all the received event lines in a queue, ready to be consumed by a storm spout.
LogFileTailer	A log file tailer is designed to monitor a log file and send notifications when new lines are added to the log file.
LruCache<K,V>
LumberjackServer	This lumberjack server puts all the received log lines in a queue, ready to be consumed by a storm spout.
StringKafkaSpoutScheme	This is what is needed to get the message avalaible under the a given tuple field.
TcpSyslogServer<T>	This syslog server puts all the received log lines in a queue, ready to be consumed by a storm spout.
UdpSyslogServer<T>	This syslog server puts all the received log lines in a queue, ready to be consumed by a storm spout.

Enum Summary

Enum	Description
LumberjackInputRecordType	The possible type of lumberjack records we receive.