public abstract class AbstractQueueingDatasourceCacheUpdate<T extends AbstractThreadableDatasourceCacheUpdate> extends AbstractDatasourceCacheUpdate
Modifier and Type | Field and Description |
---|---|
private ConnectionProvider |
connectionProvider |
private static org.slf4j.Logger |
LOGGER |
private ThreadLocalSessionFactory |
sessionFactory |
private String |
threadGroupName |
private int |
threads |
Constructor and Description |
---|
AbstractQueueingDatasourceCacheUpdate(int threads,
String threadGroupName) |
Modifier and Type | Method and Description |
---|---|
void |
execute() |
protected abstract T[] |
getUpdatesToExecute() |
getSession, setSession
getCache, getErrors, getFeatureQueryHandler, setCache, setErrors, toString
run, setParentCountDownLatch
getStopwatchResult, startStopwatch
private static final org.slf4j.Logger LOGGER
private final int threads
private final String threadGroupName
private final ConnectionProvider connectionProvider
private final ThreadLocalSessionFactory sessionFactory
public AbstractQueueingDatasourceCacheUpdate(int threads, String threadGroupName)
protected abstract T[] getUpdatesToExecute() throws OwsExceptionReport
OwsExceptionReport
public void execute()
Copyright © 2012-2015 52north.org. All Rights Reserved.