From 39d76ade6b49da9933978330df1a72c8459d861c Mon Sep 17 00:00:00 2001 From: lujian Date: Thu, 15 Nov 2018 18:41:34 +0800 Subject: [PATCH] [fix] --- .../riskbusiness/core/impl/RiskBusinessServiceImpl.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/java/au/com/royalpay/payment/manage/riskbusiness/core/impl/RiskBusinessServiceImpl.java b/src/main/java/au/com/royalpay/payment/manage/riskbusiness/core/impl/RiskBusinessServiceImpl.java index a727e396e..1b77e3f0d 100644 --- a/src/main/java/au/com/royalpay/payment/manage/riskbusiness/core/impl/RiskBusinessServiceImpl.java +++ b/src/main/java/au/com/royalpay/payment/manage/riskbusiness/core/impl/RiskBusinessServiceImpl.java @@ -108,6 +108,11 @@ public class RiskBusinessServiceImpl implements RiskBusinessService, ManagerTodo @Resource private APNSMessageHelper apnsMessageHelper; + @Resource + public void setAppMsgSenders(AppMsgSender[] senders) { + Arrays.stream(senders).forEach(appMsgSender -> senderMap.put(appMsgSender.devType(), appMsgSender)); + } + private ThreadPoolExecutor sendingAppleMsgPool = new ThreadPoolExecutor(10, 30, 5, TimeUnit.SECONDS, new LinkedBlockingQueue()); @Override