diff --git a/pom.xml b/pom.xml index b39b14d..037aa28 100644 --- a/pom.xml +++ b/pom.xml @@ -50,7 +50,7 @@ com.loafle.overflow commons-java - 1.0.114-SNAPSHOT + 1.0.116-SNAPSHOT diff --git a/src/main/java/com/loafle/overflow/central/redis/service/RedisMessagePublisher.java b/src/main/java/com/loafle/overflow/central/redis/service/RedisMessagePublisher.java index adf719d..dd57c8d 100644 --- a/src/main/java/com/loafle/overflow/central/redis/service/RedisMessagePublisher.java +++ b/src/main/java/com/loafle/overflow/central/redis/service/RedisMessagePublisher.java @@ -111,7 +111,7 @@ public class RedisMessagePublisher implements MessagePublisher { protected void publish(final String channel, PublishMessage message, final String method, Object... params) { ChannelTopic topic = this.topics.get(channel); - message.setMessage(new PublishMessage.PublishMessageBody(method, this.getMessageBody(params))); + message.setMessage(new PublishMessage.PublishMessageBody(method, this.getMessageBodyParam(params))); try { String json = this.objectMapper.writeValueAsString(message); @@ -121,7 +121,7 @@ public class RedisMessagePublisher implements MessagePublisher { } } - protected List getMessageBody(final Object... params) { + protected List getMessageBodyParam(final Object... params) { List results = new ArrayList<>(params.length); for (Object param : params) { if (param.getClass().equals(String.class)) {