This commit is contained in:
parent
abefe20617
commit
aa3ae5f936
1 changed files with 1 additions and 0 deletions
|
|
@ -492,6 +492,7 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini
|
||||||
sendTkrRequest.getTkrs().add(tkr.get());
|
sendTkrRequest.getTkrs().add(tkr.get());
|
||||||
kafkaSender.sendRequestToQueue(Consts.ACCOUNTS_TO_GATEWAY, sendTkrRequest);
|
kafkaSender.sendRequestToQueue(Consts.ACCOUNTS_TO_GATEWAY, sendTkrRequest);
|
||||||
}
|
}
|
||||||
|
sendNotificationToClearingSvc(tradingClearingRegistry);
|
||||||
log.debug("Update TCR.id={}.", tradingClearingRegistry.getId());
|
log.debug("Update TCR.id={}.", tradingClearingRegistry.getId());
|
||||||
} else {
|
} else {
|
||||||
log.debug("Nothing to update TCR.id={}.", tradingClearingRegistry.getId());
|
log.debug("Nothing to update TCR.id={}.", tradingClearingRegistry.getId());
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue