@Test public void storeAndQueryDataFilteringByClientAndServiceProviderOverflow() throws Exception { ClientId client = ClientId.create( "XTEE-CI-XM", "GOV", "00000001", "System1"); ClientId serviceProvider = ClientId.create( "XTEE-CI-XM", "GOV", "00000000", "Center"); storeFullOperationalDataRecord(1474968960L, client, serviceProvider); storeFullOperationalDataRecord(1474968961L, client, serviceProvider); storeFullOperationalDataRecord(1474968962L, client, serviceProvider); storeFullOperationalDataRecord(1474968963L, client, serviceProvider); storeFullOperationalDataRecord(1474968964L, client, serviceProvider); storeFullOperationalDataRecord(1474968960L, serviceProvider, client); storeFullOperationalDataRecord(1474968961L, serviceProvider, client); storeFullOperationalDataRecord(1474968962L, serviceProvider, client); storeFullOperationalDataRecord(1474968963L, serviceProvider, client); storeFullOperationalDataRecord(1474968964L, serviceProvider, client); OperationalDataRecordManager.setMaxRecordsInPayload(10); OperationalDataRecords result = queryRecords(1474968960L, 1474968980L); assertEquals(10, result.size()); assertNull(result.getNextRecordsFrom()); result = queryRecords(1474968960L, 1474968980L, client); assertEquals(10, result.size()); result = queryRecords(1474968960L, 1474968980L, client, serviceProvider, new HashSet<>()); assertEquals(5, result.size()); result = queryRecords(1474968960L, 1474968980L, serviceProvider, client, new HashSet<>()); assertEquals(5, result.size()); OperationalDataRecordManager.setMaxRecordsInPayload(4); result = queryRecords(1474968960L, 1474968980L, client, serviceProvider, new HashSet<>()); assertEquals(4, result.size()); assertNotNull(result.getNextRecordsFrom()); result = queryRecords(result.getNextRecordsFrom(), 1474968980L, client, serviceProvider, new HashSet<>()); assertEquals(1, result.size()); }
static OperationalDataRecords queryRecords(long recordsFrom, long recordsTo) throws Exception { return queryRecords(recordsFrom, recordsTo, null, null, new HashSet<>()); }
OperationalDataRecordManager { static OperationalDataRecords queryRecords(long recordsFrom, long recordsTo) throws Exception { return queryRecords(recordsFrom, recordsTo, null, null, new HashSet<>()); } }
OperationalDataRecordManager { static OperationalDataRecords queryRecords(long recordsFrom, long recordsTo) throws Exception { return queryRecords(recordsFrom, recordsTo, null, null, new HashSet<>()); } private  OperationalDataRecordManager(); }
OperationalDataRecordManager { static OperationalDataRecords queryRecords(long recordsFrom, long recordsTo) throws Exception { return queryRecords(recordsFrom, recordsTo, null, null, new HashSet<>()); } private  OperationalDataRecordManager();  }
OperationalDataRecordManager { static OperationalDataRecords queryRecords(long recordsFrom, long recordsTo) throws Exception { return queryRecords(recordsFrom, recordsTo, null, null, new HashSet<>()); } private  OperationalDataRecordManager();   }