From 7fb124c3daddaff7d5ccd75fa8625c8b7f3d1269 Mon Sep 17 00:00:00 2001 From: qiaowei Date: Fri, 17 Jul 2020 15:19:12 +0800 Subject: [PATCH] =?utf8?q?=E6=B6=88=E6=81=AF=E6=8E=A8=E9=80=81=EF=BC=9A?= =?utf8?q?=E5=A2=9E=E5=8A=A0=E8=BF=87=E6=9C=9F=E6=97=B6=E9=97=B4=E5=AD=97?= =?utf8?q?=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- .../supwisdom/dlpay/api/service/impl/kafka_service_impl.kt | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt index c913448f..fc5afd8b 100644 --- a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt +++ b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt @@ -79,10 +79,6 @@ class KafkaSendMsgServiceImpl : KafkaSendMsgService { if (it.lastloginplatform.isNullOrEmpty()) { message.platform = "all" kafkaTemplate.send(topic, msg.msgid, gson.toJson(message)) -// message.platform="ios" -// kafkaTemplate.send(topic, msg.msgid, gson.toJson(message)) -// message.platform="android" -// kafkaTemplate.send(topic, msg.msgid, gson.toJson(message)) } else { kafkaTemplate.send(topic, msg.msgid, gson.toJson(message)) } @@ -109,6 +105,7 @@ class KafkaSendMsgServiceImpl : KafkaSendMsgService { this.callback = true this.retries = 3 this.custom = gson.toJson(extras) + this.expiretime = DateUtil.getNewTime(DateUtil.getNow(), 300) } println(gson.toJson(message)) kafkaTemplate.send(topic, noticeMsg.msgid, gson.toJson(message)) -- 2.17.1