bug fix
This commit is contained in:
parent
3ccea663d5
commit
2ad726523d
|
@ -97,8 +97,12 @@ public class RedisMessagePublisher implements MessagePublisher {
|
||||||
List<String> results = new ArrayList<>(params.length);
|
List<String> results = new ArrayList<>(params.length);
|
||||||
try {
|
try {
|
||||||
for (Object param : params) {
|
for (Object param : params) {
|
||||||
|
if (param.getClass().equals(String.class)) {
|
||||||
|
results.add((String)param);
|
||||||
|
} else {
|
||||||
results.add(objectMapper.writeValueAsString(param));
|
results.add(objectMapper.writeValueAsString(param));
|
||||||
}
|
}
|
||||||
|
}
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user