com.inmobi.conduit.audit.services
Class AuditFeederService

java.lang.Object
  com.inmobi.conduit.audit.AuditDBService
      com.inmobi.conduit.audit.services.AuditFeederService

All Implemented Interfaces:

Runnable

public class AuditFeederService
extends AuditDBService

This class is responsible for reading audit packets,aggregating stats in memory for some time and than performing batch update of the DB

Field Summary

protected com.inmobi.messaging.consumer.MessageConsumer	consumer
protected boolean	isStop
protected boolean	stopIfMsgNull

Fields inherited from class com.inmobi.conduit.audit.AuditDBService

config, rollupChkPtDir, rollupChkPtKey, rollupProvider, thread, tillDays

Constructor Summary

AuditFeederService(String clusterName, String rootDir, com.inmobi.messaging.ClientConfig config)

Method Summary

void	execute()
String	getClusterName()
String	getRootDir()
String	getServiceName()
void	stop()

Methods inherited from class com.inmobi.conduit.audit.AuditDBService

checkTableExists, createDailyTableName, createHourTableName, createMinuteTableName, createRolledTableNameForService, getRollupTime, getRollupTimeFromChkPt, getTimeEnrtyDailyTable, join, run, start

Methods inherited from class java.lang.Object

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

Field Detail

consumer

protected volatile com.inmobi.messaging.consumer.MessageConsumer consumer

stopIfMsgNull

protected boolean stopIfMsgNull

isStop

protected volatile boolean isStop

Constructor Detail

AuditFeederService

public AuditFeederService(String clusterName,
                          String rootDir,
                          com.inmobi.messaging.ClientConfig config)
                   throws IOException

Parameters:

clusterName -

rootDir - path of _audit stream till /conduit

config -

Throws:

IOException

Method Detail

stop

public void stop()

Specified by:

stop in class AuditDBService

getServiceName

public String getServiceName()

Specified by:

getServiceName in class AuditDBService

execute

public void execute()

Specified by:

execute in class AuditDBService

getClusterName

public String getClusterName()

getRootDir

public String getRootDir()