|
@@ -17,6 +17,7 @@
|
|
|
|
|
|
package com.pig4cloud.pigx.monitor.support;
|
|
|
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
import com.pig4cloud.pigx.common.core.constant.CommonConstants;
|
|
|
import de.codecentric.boot.admin.server.domain.events.InstanceEvent;
|
|
|
import de.codecentric.boot.admin.server.eventstore.InMemoryEventStore;
|
|
@@ -41,16 +42,16 @@ import java.util.List;
|
|
|
@Configuration
|
|
|
@AllArgsConstructor
|
|
|
public class RedisEventStore extends InMemoryEventStore {
|
|
|
- private final RedisTemplate pigxRedisTemplate;
|
|
|
+ private final RedisTemplate redisTemplate;
|
|
|
|
|
|
@Override
|
|
|
public Mono<Void> append(List<InstanceEvent> events) {
|
|
|
events.forEach(event -> {
|
|
|
- String key = event.getInstance().getValue() + "_" + event.getTimestamp().toString();
|
|
|
+ String key = event.getInstance().getValue() + StrUtil.UNDERLINE + event.getTimestamp().toString();
|
|
|
log.info("保存实例事件的KEY:{},EVENT: {}", key, event.getType());
|
|
|
- pigxRedisTemplate.setKeySerializer(new StringRedisSerializer());
|
|
|
- pigxRedisTemplate.setHashValueSerializer(new Jackson2JsonRedisSerializer<>(InstanceEvent.class));
|
|
|
- pigxRedisTemplate.opsForHash().put(CommonConstants.EVENT_KEY, key, event);
|
|
|
+ redisTemplate.setKeySerializer(new StringRedisSerializer());
|
|
|
+ redisTemplate.setHashValueSerializer(new Jackson2JsonRedisSerializer<>(InstanceEvent.class));
|
|
|
+ redisTemplate.opsForHash().put(CommonConstants.EVENT_KEY, key, event);
|
|
|
});
|
|
|
return super.append(events);
|
|
|
}
|