org.kaaproject.kaa.client.logging

Class AbstractLogCollector

java.lang.Object

org.kaaproject.kaa.client.logging.AbstractLogCollector

All Implemented Interfaces:

GenericLogCollector, LogCollector, LogProcessor

Direct Known Subclasses:

DefaultLogCollector

public abstract class AbstractLogCollector
extends Object
implements LogCollector, LogProcessor

Reference implementation of @see LogCollector

Author:

Andrew Shvayka

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorContext	executorContext
static long	MAX_BATCH_VOLUME
protected LogStorage	storage

Constructor Summary

Constructors

Constructor and Description
AbstractLogCollector(LogTransport transport, ExecutorContext executorContext, KaaChannelManager manager)

Method Summary

Methods

Modifier and Type	Method and Description
void	fillSyncRequest(org.kaaproject.kaa.common.endpoint.gen.LogSyncRequest request) Fills the given request with the latest Logging state.
protected boolean	isDeliveryTimeout()
void	onLogResponse(org.kaaproject.kaa.common.endpoint.gen.LogSyncResponse logSyncResponse) Updates the state using response from the server.
void	setStorage(LogStorage storage) Set user implementation of a log storage.
void	setStrategy(LogUploadStrategy strategy) Set user implementation of a log upload strategy.
void	stop() Stops and/or cleanup resources.
protected void	uploadIfNeeded()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.kaaproject.kaa.client.logging.LogCollector

addLogRecord

Field Detail

MAX_BATCH_VOLUME

public static final long MAX_BATCH_VOLUME

See Also:

Constant Field Values

executorContext

protected final ExecutorContext executorContext

storage

protected LogStorage storage

Constructor Detail

AbstractLogCollector

public AbstractLogCollector(LogTransport transport,
                    ExecutorContext executorContext,
                    KaaChannelManager manager)

Method Detail

setStrategy

public void setStrategy(LogUploadStrategy strategy)

Description copied from interface: GenericLogCollector

Set user implementation of a log upload strategy.

Specified by:

setStrategy in interface GenericLogCollector

Parameters:

strategy - User-defined log upload strategy object.

setStorage

public void setStorage(LogStorage storage)

Description copied from interface: GenericLogCollector

Set user implementation of a log storage.

Specified by:

setStorage in interface GenericLogCollector

Parameters:

storage - User-defined log storage object

fillSyncRequest

public void fillSyncRequest(org.kaaproject.kaa.common.endpoint.gen.LogSyncRequest request)

Description copied from interface: LogProcessor

Fills the given request with the latest Logging state.

Specified by:

fillSyncRequest in interface LogProcessor

Parameters:

request - the Log request which is going to be filled.

onLogResponse

public void onLogResponse(org.kaaproject.kaa.common.endpoint.gen.LogSyncResponse logSyncResponse)
                   throws IOException

Description copied from interface: LogProcessor

Updates the state using response from the server.

Specified by:

onLogResponse in interface LogProcessor

Parameters:

logSyncResponse - the response from the remote server.

Throws:

IOException

stop

public void stop()

Description copied from interface: GenericLogCollector

Stops and/or cleanup resources.

Specified by:

stop in interface GenericLogCollector

isDeliveryTimeout

protected boolean isDeliveryTimeout()

uploadIfNeeded

protected void uploadIfNeeded()