overflow_cloud/central
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-07-01 02:30:16 +09:00
parent 09deab40db
commit e5e76f7e7a
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -50,7 +50,7 @@
<dependency>
<groupId>com.loafle.overflow</groupId>
<artifactId>commons-java</artifactId>
<version>1.0.114-SNAPSHOT</version>
<version>1.0.116-SNAPSHOT</version>
</dependency>
<dependency>

4
src/main/java/com/loafle/overflow/central/redis/service/RedisMessagePublisher.java
View File

@ -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<String> getMessageBody(final Object... params) {
protected List<String> getMessageBodyParam(final Object... params) {
List<String> results = new ArrayList<>(params.length);
for (Object param : params) {
if (param.getClass().equals(String.class)) {