Redis bug fix
This commit is contained in:
parent
afcca18ba0
commit
905ebd6adf
|
@ -52,7 +52,7 @@ public class NoAuthProbeService {
|
||||||
ApiKey apiKey = apiKeyService.readByApiKey(noAuthProbe.getApiKey());
|
ApiKey apiKey = apiKeyService.readByApiKey(noAuthProbe.getApiKey());
|
||||||
noAuthProbe.setDomain(apiKey.getDomain());
|
noAuthProbe.setDomain(apiKey.getDomain());
|
||||||
|
|
||||||
messagePublisher.publishToDomain("/app", apiKey.getDomain(), "NoAuthProbeService.regist", noAuthProbe);
|
messagePublisher.publishToDomain("/web", apiKey.getDomain(), "NoAuthProbeService.regist", noAuthProbe);
|
||||||
|
|
||||||
return this.noAuthProbeDAO.save(noAuthProbe);
|
return this.noAuthProbeDAO.save(noAuthProbe);
|
||||||
}
|
}
|
||||||
|
|
|
@ -78,7 +78,13 @@ public class RedisMessagePublisher implements MessagePublisher {
|
||||||
ChannelTopic topic = this.topics.get(channel);
|
ChannelTopic topic = this.topics.get(channel);
|
||||||
message.setMessage(new PublishMessage.PublishMessageBody(method, this.getMessageBody(params)));
|
message.setMessage(new PublishMessage.PublishMessageBody(method, this.getMessageBody(params)));
|
||||||
|
|
||||||
redisTemplate.convertAndSend(topic.getTopic(), message);
|
try {
|
||||||
|
String json = this.objectMapper.writeValueAsString(message);
|
||||||
|
redisTemplate.convertAndSend(topic.getTopic(), json);
|
||||||
|
} catch (IOException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
protected List<String> getMessageBody(final Object... params) {
|
protected List<String> getMessageBody(final Object... params) {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user