...
|
...
|
@@ -40,25 +40,26 @@ public class AwsSnsController { |
|
|
@RequestMapping(value = "/aws/sns")
|
|
|
public void awsSns(HttpServletRequest request, @RequestBody AwsSnsReq req) {
|
|
|
try {
|
|
|
logger.info(" - awsSns - request -");
|
|
|
logger.info(" - AwsSnsController - awsSns - request -");
|
|
|
String headMessageType = request.getHeader(AWS_SNS_HEAD_TYPE);
|
|
|
logger.info(" - AwsSnsController - awsSns - header:" + headMessageType);
|
|
|
if (!StringUtils.equals(NEED_TO_DEAL_WITH_TYPE, headMessageType)) {
|
|
|
return;
|
|
|
if (StringUtils.equals(NEED_TO_DEAL_WITH_TYPE, headMessageType)) {
|
|
|
if (req == null) {
|
|
|
logger.error(" - AwsSnsController - awsSns - json is emtry");
|
|
|
return;
|
|
|
}
|
|
|
String subscribeURL = req.getSubscribeURL();
|
|
|
if (StringUtils.isBlank(subscribeURL)) {
|
|
|
logger.error(" - AwsSnsController - awsSns - subscribeURL is emtry");
|
|
|
return;
|
|
|
}
|
|
|
logger.info(" - AwsSnsController - awsSns - subscribeURL is:" + subscribeURL);
|
|
|
//请求当前返回的Url
|
|
|
restTemplate.getForObject(subscribeURL, String.class);
|
|
|
logger.info(" - request - " + subscribeURL + " - success");
|
|
|
}else{
|
|
|
logger.info(" - AwsSnsController - awsSns - message is:" + req.toString());
|
|
|
}
|
|
|
if (req == null) {
|
|
|
logger.error(" - AwsSnsController - awsSns - json is emtry");
|
|
|
return;
|
|
|
}
|
|
|
String subscribeURL = req.getSubscribeURL();
|
|
|
if (StringUtils.isBlank(subscribeURL)) {
|
|
|
logger.error(" - AwsSnsController - awsSns - subscribeURL is emtry");
|
|
|
return;
|
|
|
}
|
|
|
logger.info(" - AwsSnsController - awsSns - subscribeURL is:" + subscribeURL);
|
|
|
//请求当前返回的Url
|
|
|
restTemplate.getForObject(subscribeURL, String.class);
|
|
|
logger.info(" - request - " + subscribeURL + " - success");
|
|
|
} catch (Exception e) {
|
|
|
logger.error(" - AwsSnsController - awsSns - error", e);
|
|
|
}
|
...
|
...
|
|