treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

add history mapstores

Browse source
This commit is contained in:
etreschenkov 2023-10-11 21:44:02 +03:00
parent ba438187e5
commit 7b422acc4a
5 changed files with 26 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
clearing-parent/imdg-hist/pom.xml
View file

@ -3,14 +3,16 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>imdg-hist</artifactId>
<packaging>jar</packaging>
<version>SPCEX-1.0.0.0</version>
<parent>
<artifactId>clearing-parent</artifactId>
<groupId>ru.spcex.clearing</groupId>
<version>SPCEX-1.0.0.0</version>
</parent>
<artifactId>imdg-hist</artifactId>
<packaging>jar</packaging>
<properties>
<maven.compiler.source>17</maven.compiler.source>
@ -30,7 +32,6 @@
<dependency>
<groupId>ru.spcex.clearing</groupId>
<artifactId>imdg</artifactId>
<version>SPCEX-1.0.0.0</version>
</dependency>
<dependency>
<groupId>ru.spcex.clearing</groupId>

8
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/config/HistoryPoolMapConfigs.java
View file

@ -7,7 +7,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import ru.spcex.clearing.imdg.base.AutoconfiguredMap1;
import ru.spcex.clearing.imdg.base.AutoconfiguredMap;
import ru.spcex.clearing.imdg.base.DictionaryTMapStore;
import java.util.ArrayList;
@ -20,10 +20,10 @@ public class HistoryPoolMapConfigs {
private final Logger log = LoggerFactory.getLogger(getClass());
private final List<AutoconfiguredMap1<?>> autoconfiguredMaps;
private final List<AutoconfiguredMap<?>> autoconfiguredMaps;
@Autowired
public HistoryPoolMapConfigs(List<AutoconfiguredMap1<?>> autoconfiguredMaps) {
public HistoryPoolMapConfigs(List<AutoconfiguredMap<?>> autoconfiguredMaps) {
this.autoconfiguredMaps = autoconfiguredMaps;
}
@ -60,7 +60,7 @@ public class HistoryPoolMapConfigs {
public List<MapConfig> configureEachMapStore() {
List<MapConfig> out = new ArrayList<>();
HashSet<String> existMapStores = new HashSet<>();
for (AutoconfiguredMap1<?> mapStore : autoconfiguredMaps) {
for (AutoconfiguredMap<?> mapStore : autoconfiguredMaps) {
try {
log.debug("Link mapstore {} to map {}", mapStore.toString(), mapStore.getMapName());
if (StringUtils.isEmpty(mapStore.getMapName())) {

1
clearing-parent/imdg/pom.xml
View file

@ -143,6 +143,7 @@
</executions>
<configuration>
<addResources>true</addResources>
<classifier>exec</classifier>
<finalName>${project.artifactId}</finalName>
</configuration>
</plugin>

34
clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/AutoconfiguredMap.java
View file

@ -1,17 +1,17 @@
package ru.spcex.clearing.imdg.base;
import com.hazelcast.core.MapLoader;
public interface AutoconfiguredMap<T> extends MapLoader<Long, T> {
/**
*
* @return IMDGDistributedNames.*
*/
String getMapName();
/**
* Список индексируемых полей, для быстрого поиска
* @return
*/
String[] getIndexingField();
}
package ru.spcex.clearing.imdg.base;
import com.hazelcast.core.MapLoader;
public interface AutoconfiguredMap<T> extends MapLoader<Long, T> {
/**
*
* @return IMDGDistributedNames.*
*/
String getMapName();
/**
* Список индексируемых полей, для быстрого поиска
* @return
*/
String[] getIndexingField();
}

17
clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/AutoconfiguredMap1.java
View file

@ -1,17 +0,0 @@
package ru.spcex.clearing.imdg.base;
import com.hazelcast.core.MapLoader;
public interface AutoconfiguredMap1<T> extends MapLoader<Long, T> {
/**
*
* @return IMDGDistributedNames.*
*/
String getMapName();
/**
* Список индексируемых полей, для быстрого поиска
* @return
*/
String[] getIndexingField();
}