org.thales.punch.netty.impl

Class NettyLumberJackClientRunner

java.lang.Object

org.thales.punch.netty.impl.NettyLumberJackClientRunner

All Implemented Interfaces:

Runnable

public class NettyLumberJackClientRunner
extends Object
implements Runnable

This runner is in charge of running the main client lumberjack thread.

What it does is to continuously try to connect, and once connected, send the lumberjack frames to the peer.

In case of disconnection, all pending and queued frames are discarded. These frames are also promptly signalled as failed to the caller (through the so called acker). This allows the caller to immediately signal these failed frames to the spout or other equivalent input connector to do what they must do.

Note that such a client is supposed to stay alive forever. If you call stop() it will terminate all threads.

Constructor Summary

Constructors

Constructor and Description
NettyLumberJackClientRunner(NettyLumberJackClientImpl client, NettyDataAcker acker, org.thales.punch.settings.api.ISettingsMap settings, NettyLumberjackEncoder encoder, NettyLumberjackDecoder decoder, com.codahale.metrics.Counter appSentCounter, com.codahale.metrics.Histogram roundTripTime) Ctor

Method Summary

Modifier and Type	Method and Description
protected boolean	addItem(NettyLumberjackData item) Add an item to be written to the peer.
void	onReceive(io.netty.channel.Channel peer, io.netty.buffer.ByteBuf data)
void	run()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyLumberJackClientRunner

public NettyLumberJackClientRunner(NettyLumberJackClientImpl client,
                                   NettyDataAcker acker,
                                   org.thales.punch.settings.api.ISettingsMap settings,
                                   NettyLumberjackEncoder encoder,
                                   NettyLumberjackDecoder decoder,
                                   com.codahale.metrics.Counter appSentCounter,
                                   com.codahale.metrics.Histogram roundTripTime)

Ctor

Parameters:

client - the owning client

acker - the acker, possibly null if none.

settings - the caller settings

encoder - the lumberjack encoder for building new frame

decoder - the lumberjack decoder for decoding input (keepalive) frames

appSentCounter - the counter of outgoing bytes

roundTripTime - a histogram for monitoring the round trip time

Method Detail

run

public void run()

Specified by:

run in interface Runnable

onReceive

public void onReceive(io.netty.channel.Channel peer,
                      io.netty.buffer.ByteBuf data)

addItem

protected boolean addItem(NettyLumberjackData item)

Add an item to be written to the peer. This method will block if the input queue is full.

Parameters:

item - the item to write

Returns:

true if it was queued, false if not because we were just disconnected

stop

public void stop()