Package eu.dnetlib.openaire.dsm.dao

Class MongoLoggerClientImpl

java.lang.Object

eu.dnetlib.openaire.dsm.dao.MongoLoggerClientImpl

All Implemented Interfaces:

MongoLoggerClient

@Component
@ConditionalOnProperty(value="openaire.exporter.enable.dsm",
                       havingValue="true")
public class MongoLoggerClientImpl
extends Object
implements MongoLoggerClient

Created by claudio on 20/10/2016.

Constructor Summary

Constructors

Constructor	Description
MongoLoggerClientImpl()

Method Summary

Modifier and Type	Method	Description
void	dropCache()
long	findTransformationDateBeforeForApi(String api, long timestamp)
List<AggregationInfoV1>	getAggregationHistoryV1(String dsId)	Deprecated.
List<AggregationInfo>	getAggregationHistoryV2(String dsId)

Methods inherited from class java.lang.Object

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

Constructor Details

MongoLoggerClientImpl

public MongoLoggerClientImpl()

Method Details

getAggregationHistoryV1

@Cacheable("dsm-aggregationhistory-cache-v1")
@Deprecated
public List<AggregationInfoV1> getAggregationHistoryV1(String dsId)
                                                throws DsmApiException

Deprecated.

Specified by:

getAggregationHistoryV1 in interface MongoLoggerClient

Throws:

DsmApiException

getAggregationHistoryV2

@Cacheable("dsm-aggregationhistory-cache-v2")
public List<AggregationInfo> getAggregationHistoryV2(String dsId)
                                              throws DsmApiException

Specified by:

getAggregationHistoryV2 in interface MongoLoggerClient

Throws:

DsmApiException

findTransformationDateBeforeForApi

@Cacheable("dsm-transformationdatebefore-cache")
public long findTransformationDateBeforeForApi(String api,
 long timestamp)

Specified by:

findTransformationDateBeforeForApi in interface MongoLoggerClient

dropCache

@CacheEvict(cacheNames={"dsm-aggregationhistory-cache-v1","dsm-aggregationhistory-cache-v2","dsm-firstharvestdate-cache","dsm-transformationdatebefore-cache"},
            allEntries=true)
@Scheduled(fixedDelayString="${openaire.exporter.cache.ttl}")
public void dropCache()

Specified by:

dropCache in interface MongoLoggerClient