parent
b0d3e4ac5a
commit
9f0f036356
2 changed files with 2 additions and 2 deletions
|
|
@ -24,7 +24,7 @@ public class CompanyInfoService extends QueueConsumer implements InitializingBea
|
|||
public CompanyInfoService(Consumer<String, Object> kafkaQueue,
|
||||
ImdgProvider imdgProvider) {
|
||||
super(kafkaQueue);
|
||||
this.companyInfoMap = imdgProvider.getImdg(IMDGDistributedNames.Map_Company, CompanyInfo.class);
|
||||
this.companyInfoMap = imdgProvider.getImdg(IMDGDistributedNames.Map_CompanyInfo, CompanyInfo.class);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
|
|||
|
|
@ -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_CompanyInfo, Company.class);
|
||||
this.companyMap = imdgProvider.getImdg(IMDGDistributedNames.Map_Company, Company.class);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue