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 Map<Integer,BucketInfo>	bucketInfoMap
protected Map<Integer,List<RecordFuture>>	deliveryFuturesMap
protected ExecutorContext	executorContext
protected LogStorage	storage

Constructor Summary

Constructors

Constructor and Description
AbstractLogCollector(LogTransport transport, ExecutorContext executorContext, KaaChannelManager channelManager, FailoverManager failoverManager)

Method Summary

Modifier and Type	Method and Description
protected void	addDeliveryFuture(BucketInfo info, RecordFuture future)
void	fillSyncRequest(org.kaaproject.kaa.common.endpoint.gen.LogSyncRequest request) Fills the given request with the latest Logging state.
protected void	notifyDeliveryFuturesOnSuccess(BucketInfo info)
void	onLogResponse(org.kaaproject.kaa.common.endpoint.gen.LogSyncResponse logSyncResponse) Updates the state using response from the server.
protected void	scheduleUploadCheck()
void	setLogDeliveryListener(LogDeliveryListener logDeliveryListener) Set a listener which receives a delivery status of each log bucket.
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

executorContext

protected final ExecutorContext executorContext

deliveryFuturesMap

protected final Map<Integer,List<RecordFuture>> deliveryFuturesMap

bucketInfoMap

protected final Map<Integer,BucketInfo> bucketInfoMap

storage

protected LogStorage storage

Constructor Detail

AbstractLogCollector

public AbstractLogCollector(LogTransport transport,
                            ExecutorContext executorContext,
                            KaaChannelManager channelManager,
                            FailoverManager failoverManager)

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 - the io exception

stop

public void stop()

Description copied from interface: GenericLogCollector

Stops and/or cleanup resources.

Specified by:

stop in interface GenericLogCollector

scheduleUploadCheck

protected void scheduleUploadCheck()

uploadIfNeeded

protected void uploadIfNeeded()

setLogDeliveryListener

public void setLogDeliveryListener(LogDeliveryListener logDeliveryListener)

Description copied from interface: GenericLogCollector

Set a listener which receives a delivery status of each log bucket.

Specified by:

setLogDeliveryListener in interface GenericLogCollector

Parameters:

logDeliveryListener - User-defined listener object.

addDeliveryFuture

protected void addDeliveryFuture(BucketInfo info,
                                 RecordFuture future)

notifyDeliveryFuturesOnSuccess

protected void notifyDeliveryFuturesOnSuccess(BucketInfo info)