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

http://jira.mfd.msk:8088/browse/CLS-21

Browse source 
---
fix-up
This commit is contained in:
aalehin 2022-10-03 11:37:00 +03:00
parent b6e53e7dba
commit fefd935e45
3 changed files with 8 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
clearing-parent/company-service/src/main/java/ru/spcex/clearing/company/config/KafkaConfig.java
View file

@ -14,7 +14,7 @@ public class KafkaConfig {
@Autowired
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
@Bean
public Consumer<String, Object> createProducer(CompanyServiceSettings settings) {
public Consumer<String, Object> createConsumer(CompanyServiceSettings settings) {
return KafkaConsumerFactory.consumer(settings.getKafka());
}
}

2
clearing-parent/company-service/src/main/java/ru/spcex/clearing/company/service/CompanyService.java
View file

@ -24,7 +24,7 @@ public class CompanyService extends QueueConsumer implements InitializingBean {
public CompanyService(Consumer<String, Object> kafkaQueue,
ImdgProvider imdgProvider) {
super(kafkaQueue);
this.companyMap = imdgProvider.getImdg(IMDGDistributedNames.Map_Company, Company.class);
this.companyMap = imdgProvider.getImdg(IMDGDistributedNames.Map_CompanyInfo, Company.class);
}
@Override

17
platform-parent/platform-imdg-api/src/main/java/ru/spcex/clearing/imdg/IMDGDistributedNames.java
View file

@ -4,14 +4,11 @@ package ru.spcex.clearing.imdg;
* Список имён распределённых объектов
*/
public final class IMDGDistributedNames {
private IMDGDistributedNames() {
}
public static final String Map_Company = "Map_Company";
public static final String Map_CompanyHistory = "Map_CompanyHistory";
public static final String Map_CompanyRoleSet = "Map_CompanyRoleSet";
public static final String Map_CompanySymbols = "Map_CompanySymbols";
// public static final String Map_CompanyInfo = "Map_CompanyInfo"; интегрировано в Map_Company
public static final String Map_CompanyInfo = "Map_CompanyInfo";
public static final String Map_Contact = "Map_Contact";
public static final String Map_ProfileDocument = "Map_ProfileDocument";
public static final String Map_Account = "Map_Account";
@ -43,7 +40,6 @@ public final class IMDGDistributedNames {
public static final String Map_Timetable = "Map_Timetable";
public static final String Map_InDocumentJournal = "Map_InDocumentJournal";
public static final String Map_OutDocumentJournal = "Map_OutDocumentJournal";
public static final String Map_SDf01 = "Map_SDf01";
public static final String Map_SDf02 = "Map_SDf02";
public static final String Map_SDf03 = "Map_SDf03";
@ -58,10 +54,9 @@ public final class IMDGDistributedNames {
public static final String Map_SDf09 = "Map_SDf09";
public static final String Map_SDf12 = "Map_SDf12";
public static final String Map_SDf18 = "Map_SDf18";
// public static final String Map_InterestStatusDictionary = "Map_InterestStatusDictionary"; future
// public static final String Map_InterestStatusDictionary = "Map_InterestStatusDictionary"; future
public static final String Map_AllowedDictionary = "Map_AllowedDictionary";
// public static final String Map_ClearingMemberCategoryDictionary = "Map_ClearingMemberCategoryDictionary"; future
// public static final String Map_ClearingMemberCategoryDictionary = "Map_ClearingMemberCategoryDictionary"; future
public static final String Map_CompanyRoleDictionary = "Map_CompanyRoleDictionary";
public static final String Map_CompanySymbolDictionary = "Map_CompanySymbolDictionary";
public static final String Map_ContactTypeDictionary = "Map_ContactTypeDictionary";
@ -103,11 +98,11 @@ public final class IMDGDistributedNames {
public static final String Map_UserSettings = "Map_UserSettings";
public static final String Map_UserRoleSession = "Map_UserRoleSession";
public static final String Map_AccountStatusDictionary = "Map_AccountStatusDictionary";
public static final String Map_KeyRate = "Map_KeyRate";
public static final String Map_MoneyMarketSecurity = "Map_MoneyMarketSecurity";
public static final String Map_AccountBalance = "Map_AccountBalance";
public static final String MAP_SEQUENCE_NAME = "MAP_SEQUENCE_NAME"; // todo вынести idGenerator отдельно и завернуть в метод, чтобы не напрямую обращаться.
private IMDGDistributedNames() {
}
}