mirror of
https://github.com/didi/KnowStreaming.git
synced 2025-12-24 03:42:07 +08:00
@@ -27,19 +27,19 @@ import java.util.concurrent.TimeUnit;
|
||||
public class N9eService extends AbstractMonitorService {
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(N9eService.class);
|
||||
|
||||
@Value("${monitor.n9e.nid}")
|
||||
@Value("${monitor.n9e.nid:}")
|
||||
private Integer monitorN9eNid;
|
||||
|
||||
@Value("${monitor.n9e.user-token}")
|
||||
@Value("${monitor.n9e.user-token:}")
|
||||
private String monitorN9eUserToken;
|
||||
|
||||
@Value("${monitor.n9e.mon.base-url}")
|
||||
@Value("${monitor.n9e.mon.base-url:}")
|
||||
private String monitorN9eMonBaseUrl;
|
||||
|
||||
@Value("${monitor.n9e.sink.base-url}")
|
||||
@Value("${monitor.n9e.sink.base-url:}")
|
||||
private String monitorN9eSinkBaseUrl;
|
||||
|
||||
@Value("${monitor.n9e.rdb.base-url}")
|
||||
@Value("${monitor.n9e.rdb.base-url:}")
|
||||
private String monitorN9eRdbBaseUrl;
|
||||
|
||||
private static final Cache<String, NotifyGroup> NOTIFY_GROUP_CACHE = Caffeine.newBuilder()
|
||||
|
||||
@@ -19,7 +19,7 @@ public class OrderPassedNotifyService implements ApplicationListener<OrderPassed
|
||||
@Autowired
|
||||
private AbstractNotifyService notifyService;
|
||||
|
||||
@Value("${notify.order.detail-url}")
|
||||
@Value("${notify.order.detail-url:}")
|
||||
private String orderDetailUrl;
|
||||
|
||||
@Async
|
||||
|
||||
@@ -19,7 +19,7 @@ public class OrderRefusedNotifyService implements ApplicationListener<OrderRefus
|
||||
@Autowired
|
||||
private AbstractNotifyService notifyService;
|
||||
|
||||
@Value("${notify.order.detail-url}")
|
||||
@Value("${notify.order.detail-url:}")
|
||||
private String orderDetailUrl;
|
||||
|
||||
@Async
|
||||
|
||||
Reference in New Issue
Block a user