luca.frosini
/
infrastructure-tests
13
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fixed Tests 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/private/luca.frosini/infrastructure-tests@124194 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Luca Frosini 2016-02-15 14:32:01 +00:00
parent b2db1509ce
commit 0b38d02ec2
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/gcube/documentstore/persistence/AggregationSchedulerTest.java → src/test/java/org/gcube/documentstore/records/aggregation/AggregationSchedulerTest.java
View File

@ -1,22 +1,21 @@
/** /**
* *
*/ */
package org.gcube.documentstore.persistence; package org.gcube.documentstore.records.aggregation;
import java.io.File;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.gcube.accounting.datamodel.UsageRecord; import org.gcube.accounting.datamodel.UsageRecord;
import org.gcube.accounting.datamodel.usagerecords.ServiceUsageRecord; import org.gcube.accounting.datamodel.usagerecords.ServiceUsageRecord;
import org.gcube.documentstore.persistence.PersistenceExecutor;
import org.gcube.documentstore.records.AggregatedRecord; import org.gcube.documentstore.records.AggregatedRecord;
import org.gcube.documentstore.records.Record; import org.gcube.documentstore.records.Record;
import org.gcube.utils.ScopedTest; import org.gcube.utils.ScopedTest;
import org.gcube.utils.StressTestUtility; import org.gcube.utils.StressTestUtility;
import org.gcube.utils.TestOperation; import org.gcube.utils.TestOperation;
import org.gcube.utils.TestUsageRecord; import org.gcube.utils.TestUsageRecord;
import org.gcube.utils.TestUtility;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -31,8 +30,7 @@ public class AggregationSchedulerTest extends ScopedTest {
private static final Logger logger = LoggerFactory.getLogger(AggregationSchedulerTest.class); private static final Logger logger = LoggerFactory.getLogger(AggregationSchedulerTest.class);
public static AggregationScheduler getAggregationScheduler(){ public static AggregationScheduler getAggregationScheduler(){
File fallbackFile = PersistenceBackendFactory.getFallbackFile(TestUtility.getScope()); return new BufferAggregationScheduler(persistenceExecutor);
return new BufferAggregationScheduler(new FallbackPersistenceBackend(fallbackFile));
} }
public static PersistenceExecutor persistenceExecutor = new PersistenceExecutor(){ public static PersistenceExecutor persistenceExecutor = new PersistenceExecutor(){