Package ch.rswk.meta.engine

Class AbstractEngineWorkQueueService<C,T,R>

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

ch.rswk.meta.engine.AbstractEngineIdleService<C>

ch.rswk.meta.engine.AbstractEngineWorkQueueService<C,T,R>

All Implemented Interfaces:

EngineServices.ConfigurableService<C>, EngineServices.InfoProvidingService, com.google.common.util.concurrent.Service

Direct Known Subclasses:

LuceneService

public abstract class AbstractEngineWorkQueueService<C,T,R>
extends AbstractEngineIdleService<C>

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
private com.codahale.metrics.Meter	processErrorMeter
private final Semaphore	semaphore
private static final Protocol.ErrorReplyFactory	WORK_QUEUE_ERROR
private static final Protocol.ErrorReplyFactory	WORK_UNIT_ERROR
private com.codahale.metrics.Timer	workUnitTimer

Fields inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

runtime

Constructor Summary

Constructors

Constructor	Description
AbstractEngineWorkQueueService(C config, EngineRuntime runtime)

Method Summary

Modifier and Type	Method	Description
protected void	afterProcessWorkUnit(T unit)
protected void	beforeProcessWorkUnit(T unit)
protected boolean	isWorkQueueEmpty()
protected com.google.common.util.concurrent.ListenableFuture<R>	offerWorkUnit(T unit)
protected abstract R	processWorkUnit(T unit)
protected void	startUp()

Methods inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

configClass, configReference, onConfigWatcherNotification, serviceId, serviceName, shutDown

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.rswk.meta.engine.EngineServices.ConfigurableService

config, handleConfigWatcherNotification, onConfigChanged

Methods inherited from interface ch.rswk.meta.engine.EngineServices.InfoProvidingService

getServiceInfo

Field Details

WORK_QUEUE_ERROR

private static final Protocol.ErrorReplyFactory WORK_QUEUE_ERROR

WORK_UNIT_ERROR

private static final Protocol.ErrorReplyFactory WORK_UNIT_ERROR

semaphore

private final Semaphore semaphore

processErrorMeter

private com.codahale.metrics.Meter processErrorMeter

workUnitTimer

private com.codahale.metrics.Timer workUnitTimer

Constructor Details

AbstractEngineWorkQueueService

public AbstractEngineWorkQueueService(C config,
 EngineRuntime runtime)

Method Details

isWorkQueueEmpty

protected boolean isWorkQueueEmpty()

offerWorkUnit

protected com.google.common.util.concurrent.ListenableFuture<R> offerWorkUnit(T unit)

beforeProcessWorkUnit

protected void beforeProcessWorkUnit(T unit)

processWorkUnit

protected abstract R processWorkUnit(T unit)
                              throws ErrorReplyException

Throws:

ErrorReplyException

afterProcessWorkUnit

protected void afterProcessWorkUnit(T unit)

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractEngineIdleService<C>

Throws:

Exception