org.gcube.documentstore.persistence

Class PersistenceAccountingService

java.lang.Object

org.gcube.documentstore.persistence.PersistenceBackend

org.gcube.documentstore.persistence.PersistenceAccountingService

public class PersistenceAccountingService
extends org.gcube.documentstore.persistence.PersistenceBackend

Author:

Alessandro Pieve (ISTI - CNR) alessandro.pieve@isti.cnr.it, Luca Frosini (ISTI - CNR) luca.frosini@isti.cnr.it

Field Summary

Fields

Modifier and Type	Field and Description
static String	PATH_SERVICE_INSERT_ACCOUNTING
static String	SERVICE_CLASS
static String	SERVICE_ENTRY_NAME
static String	SERVICE_NAME
static String	URL_PROPERTY_KEY

Fields inherited from class org.gcube.documentstore.persistence.PersistenceBackend

aggregationScheduler, fallbackPersistence, fallbackUseCounter, fallbackUseStartTime, forceFallbackUse, MAX_FALLBACK_RETRY, MAX_TIME_TO_FALLBACK, persistenceBackendMonitor

Constructor Summary

Constructors

Constructor and Description
PersistenceAccountingService()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	accountWithFallback(org.gcube.documentstore.records.Record... records)
protected void	clean()
void	close()
protected void	closeConnection()
protected static void	forceURL(String url)
boolean	isConnectionActive()
protected void	openConnection()
protected void	prepareConnection(org.gcube.documentstore.persistence.PersistenceBackendConfiguration configuration)
protected void	reallyAccount(org.gcube.documentstore.records.Record record)
protected void	send(org.gcube.documentstore.records.Record... records)

Methods inherited from class org.gcube.documentstore.persistence.PersistenceBackend

account, accountValidateAggregate, flush, flush, getAggregationScheduler, getFallbackPersistence, setAggregationScheduler, setFallback

Methods inherited from class java.lang.Object

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

Field Detail

PATH_SERVICE_INSERT_ACCOUNTING

public static final String PATH_SERVICE_INSERT_ACCOUNTING

See Also:

Constant Field Values

URL_PROPERTY_KEY

public static final String URL_PROPERTY_KEY

See Also:

Constant Field Values

SERVICE_CLASS

public static final String SERVICE_CLASS

See Also:

Constant Field Values

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

SERVICE_ENTRY_NAME

public static final String SERVICE_ENTRY_NAME

See Also:

Constant Field Values

Constructor Detail

PersistenceAccountingService

public PersistenceAccountingService()

Method Detail

forceURL

protected static void forceURL(String url)

prepareConnection

protected void prepareConnection(org.gcube.documentstore.persistence.PersistenceBackendConfiguration configuration)
                          throws Exception

Specified by:

prepareConnection in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

send

protected void send(org.gcube.documentstore.records.Record... records)
             throws Exception

Throws:

Exception

reallyAccount

protected void reallyAccount(org.gcube.documentstore.records.Record record)
                      throws Exception

Specified by:

reallyAccount in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

accountWithFallback

protected void accountWithFallback(org.gcube.documentstore.records.Record... records)
                            throws Exception

Overrides:

accountWithFallback in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

close

public void close()
           throws Exception

Overrides:

close in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

openConnection

protected void openConnection()
                       throws Exception

Specified by:

openConnection in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

closeConnection

protected void closeConnection()
                        throws Exception

Specified by:

closeConnection in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

isConnectionActive

public boolean isConnectionActive()
                           throws Exception

Specified by:

isConnectionActive in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception

clean

protected void clean()
              throws Exception

Specified by:

clean in class org.gcube.documentstore.persistence.PersistenceBackend

Throws:

Exception