diff --git a/src/main/java/com/loafle/overflow/module/noauthprobe/service/NoAuthProbeService.java b/src/main/java/com/loafle/overflow/module/noauthprobe/service/NoAuthProbeService.java index d130ac0..c4bc0dd 100644 --- a/src/main/java/com/loafle/overflow/module/noauthprobe/service/NoAuthProbeService.java +++ b/src/main/java/com/loafle/overflow/module/noauthprobe/service/NoAuthProbeService.java @@ -52,7 +52,7 @@ public class NoAuthProbeService { ApiKey apiKey = apiKeyService.readByApiKey(noAuthProbe.getApiKey()); 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); } diff --git a/src/main/java/com/loafle/overflow/redis/service/RedisMessagePublisher.java b/src/main/java/com/loafle/overflow/redis/service/RedisMessagePublisher.java index 5cb71bc..58f9ca3 100644 --- a/src/main/java/com/loafle/overflow/redis/service/RedisMessagePublisher.java +++ b/src/main/java/com/loafle/overflow/redis/service/RedisMessagePublisher.java @@ -78,7 +78,13 @@ public class RedisMessagePublisher implements MessagePublisher { ChannelTopic topic = this.topics.get(channel); 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 getMessageBody(final Object... params) {