Skip to content

Commit

Permalink
Typo
Browse files Browse the repository at this point in the history
  • Loading branch information
cjmalloy committed Apr 10, 2024
1 parent 8ba2eb8 commit ec1139e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/main/java/jasper/config/RedisConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -410,11 +410,11 @@ public RedisMessageListenerContainer redisExtRxAdapter(RedisConnectionFactory re
container.setConnectionFactory(redisConnectionFactory);
container.addMessageListener((message, pattern) -> {
try {
var user = objectMapper.readValue(message.getBody(), ExtDto.class);
var ext = objectMapper.readValue(message.getBody(), ExtDto.class);
var parts = new String(message.getChannel(), StandardCharsets.UTF_8).split("/");
var origin = parts[1];
var tag = parts[2];
userRedisChannel().send(MessageBuilder.createMessage(user, tagHeaders(origin, tag)));
extRedisChannel().send(MessageBuilder.createMessage(ext, tagHeaders(origin, tag)));
} catch (IOException e) {
logger.error("Error parsing ExtDto from redis.");
}
Expand Down

0 comments on commit ec1139e

Please sign in to comment.