Package pl.tkowalcz.tjahzi

Class LogShipperAgent

java.lang.Object

pl.tkowalcz.tjahzi.LogShipperAgent

All Implemented Interfaces:

org.agrona.concurrent.Agent

public class LogShipperAgent
extends Object
implements org.agrona.concurrent.Agent

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_MESSAGES_TO_RETRIEVE

Constructor Summary

Constructors

Constructor	Description
LogShipperAgent(TimeCappedBatchingStrategy batchStrategy, org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer logBuffer, OutputBuffer outputBuffer, NettyHttpClient httpClient, LogBufferMessageHandler messageHandler)

Method Summary

Modifier and Type	Method	Description
int	doWork()
void	onClose()
String	roleName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.agrona.concurrent.Agent

onStart

Field Details

MAX_MESSAGES_TO_RETRIEVE

public static final int MAX_MESSAGES_TO_RETRIEVE

See Also:

• Constant Field Values

Constructor Details

LogShipperAgent

public LogShipperAgent(TimeCappedBatchingStrategy batchStrategy,
 org.agrona.concurrent.ringbuffer.ManyToOneRingBuffer logBuffer,
 OutputBuffer outputBuffer,
 NettyHttpClient httpClient,
 LogBufferMessageHandler messageHandler)

Method Details

doWork

public int doWork()
           throws IOException

Specified by:

doWork in interface org.agrona.concurrent.Agent

Throws:

IOException

onClose

public void onClose()

Specified by:

onClose in interface org.agrona.concurrent.Agent

roleName

public String roleName()

Specified by:

roleName in interface org.agrona.concurrent.Agent