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

Class LumberjackServer

java.lang.Object

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

All Implemented Interfaces:

Runnable, org.thales.punch.netty.api.INettyReaderCallback<Map<String,String>>

public class LumberjackServer
extends Object
implements org.thales.punch.netty.api.INettyReaderCallback<Map<String,String>>, Runnable

This lumberjack server puts all the received log lines in a queue, ready to be consumed by a storm spout.

This server can listen on several ports, relying on a single internal netty engine. To listen onto several ports, call the constructor once, then invoke addListeningAddress(ISettingsMap, LinkedBlockingQueue).

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
LumberjackServer(org.thales.punch.settings.api.ISettingsMap address, LinkedBlockingQueue<org.thales.punch.netty.api.INettyTuple<Map<String,String>>> queue, int queueSize, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Ctor.

Method Summary

Modifier and Type	Method and Description
LumberjackServer	addListeningAddress(org.thales.punch.settings.api.ISettingsMap address, LinkedBlockingQueue<org.thales.punch.netty.api.INettyTuple<Map<String,String>>> queue)
void	close()
Class<?>	getType()
void	onReceive(io.netty.channel.ChannelHandlerContext ctx, org.thales.punch.netty.api.INettyTuple<Map<String,String>> data)
void	registerNextTupleCallback(org.thales.punch.libraries.storm.api.INextTupleCallback cb)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.thales.punch.netty.api.INettyReaderCallback

onActive, onInactive, onThrowable

Constructor Detail

LumberjackServer

public LumberjackServer(org.thales.punch.settings.api.ISettingsMap address,
                        LinkedBlockingQueue<org.thales.punch.netty.api.INettyTuple<Map<String,String>>> queue,
                        int queueSize,
                        org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Ctor.

Parameters:

address - the listening address

queue - the receiving queue

queueSize - the size of the input queue, once reached the syslogserver will stop reading the incoming socket

metricsContext - the metrics context

Method Detail

onReceive

public void onReceive(io.netty.channel.ChannelHandlerContext ctx,
                      org.thales.punch.netty.api.INettyTuple<Map<String,String>> data)

Specified by:

onReceive in interface org.thales.punch.netty.api.INettyReaderCallback<Map<String,String>>

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

registerNextTupleCallback

public void registerNextTupleCallback(org.thales.punch.libraries.storm.api.INextTupleCallback cb)

addListeningAddress

public LumberjackServer addListeningAddress(org.thales.punch.settings.api.ISettingsMap address,
                                            LinkedBlockingQueue<org.thales.punch.netty.api.INettyTuple<Map<String,String>>> queue)

getType

public Class<?> getType()

Specified by:

getType in interface org.thales.punch.netty.api.INettyReaderCallback<Map<String,String>>