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

Class HttpServer

java.lang.Object

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

All Implemented Interfaces:

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

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

This http server puts all the received event lines in a queue, ready to be consumed by a storm spout. In addition, it provides the multiline function, aggregating all event lines into a single one if they match the multiline prefix. All the caller has to do is to regularly call the tick method so that a single log received with no subsequent line gets emitted after a timeout.

Constructor Summary

Constructors

Constructor and Description
HttpServer(org.thales.punch.settings.api.ISettingsMap address, int queueSize, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Method Summary

Modifier and Type	Method and Description
void	close()
LinkedBlockingQueue<org.thales.punch.netty.api.INettyTuple<Map<String,Object>>>	getQueue()
Class<?>	getType()
void	onReceive(io.netty.channel.ChannelHandlerContext ctx, org.thales.punch.netty.api.INettyTuple<Map<String,Object>> data)
void	registerNextTupleCallback(org.thales.punch.libraries.storm.api.INextTupleCallback cb) Register the callback to receive the data.
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

HttpServer

public HttpServer(org.thales.punch.settings.api.ISettingsMap address,
                  int queueSize,
                  org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Parameters:

address - the listening address

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,Object>> data)

Specified by:

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

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

getQueue

public LinkedBlockingQueue<org.thales.punch.netty.api.INettyTuple<Map<String,Object>>> getQueue()

Returns:

the backing queue

registerNextTupleCallback

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

Register the callback to receive the data.

Parameters:

cb - the callback

getType

public Class<?> getType()

Specified by:

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