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

Class UdpSyslogServer<T>

java.lang.Object

org.thales.punch.libraries.storm.spout.impl.UdpSyslogServer<T>

All Implemented Interfaces:

AutoCloseable, Runnable, ISyslogServer, org.thales.punch.netty.api.INettyReaderCallback<T>

public class UdpSyslogServer<T>
extends Object
implements org.thales.punch.netty.api.INettyReaderCallback<T>, Runnable, ISyslogServer

This syslog server puts all the received log lines in a queue, ready to be consumed by a storm spout. In addition, it provides different codecs : XML, Json, Multiline .. prefix. All the caller has to do is to regularly call the ISyslogServer.tick() method so that a single log received with no subsequent line gets emitted after a timeout.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
UdpSyslogServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext, ISyslogReceiver<T> receiver)

Method Summary

Modifier and Type	Method and Description
void	close() Close the server
Class<?>	getType()
void	onReceive(io.netty.channel.ChannelHandlerContext channelHandlerContext, org.thales.punch.netty.api.INettyTuple<T> tuple)
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

Methods inherited from interface org.thales.punch.libraries.storm.spout.impl.ISyslogServer

tick

Constructor Detail

UdpSyslogServer

public UdpSyslogServer(org.thales.punch.settings.api.ISettingsMap settings,
                       org.thales.punch.libraries.metrics.api.IMetricContext metricsContext,
                       ISyslogReceiver<T> receiver)

Method Detail

onReceive

public void onReceive(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                      org.thales.punch.netty.api.INettyTuple<T> tuple)

Specified by:

onReceive in interface org.thales.punch.netty.api.INettyReaderCallback<T>

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Close the server

Specified by:

close in interface AutoCloseable

getType

public Class<?> getType()

Specified by:

getType in interface org.thales.punch.netty.api.INettyReaderCallback<T>