From f928f38ce31fabe3d0bca2b3d74e80a5b05a4fb8 Mon Sep 17 00:00:00 2001 From: lbw Date: Tue, 29 Jun 2021 17:08:49 +0800 Subject: [PATCH] :fire: Removing code or files. RedisEventStore.java --- .../pigx/monitor/support/RedisEventStore.java | 59 ------------------- 1 file changed, 59 deletions(-) delete mode 100644 pigx-visual/pigx-monitor/src/main/java/com/pig4cloud/pigx/monitor/support/RedisEventStore.java diff --git a/pigx-visual/pigx-monitor/src/main/java/com/pig4cloud/pigx/monitor/support/RedisEventStore.java b/pigx-visual/pigx-monitor/src/main/java/com/pig4cloud/pigx/monitor/support/RedisEventStore.java deleted file mode 100644 index 7549b40c1..000000000 --- a/pigx-visual/pigx-monitor/src/main/java/com/pig4cloud/pigx/monitor/support/RedisEventStore.java +++ /dev/null @@ -1,59 +0,0 @@ -/* - * Copyright (c) 2018-2025, lengleng All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions are met: - * - * Redistributions of source code must retain the above copyright notice, - * this list of conditions and the following disclaimer. - * Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * Neither the name of the pig4cloud.com developer nor the names of its - * contributors may be used to endorse or promote products derived from - * this software without specific prior written permission. - * Author: lengleng (wangiegie@gmail.com) - */ - -package com.pig4cloud.pigx.monitor.support; - -import cn.hutool.core.util.StrUtil; -import com.pig4cloud.pigx.common.core.constant.CacheConstants; -import de.codecentric.boot.admin.server.domain.events.InstanceEvent; -import de.codecentric.boot.admin.server.eventstore.InMemoryEventStore; -import lombok.AllArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.context.annotation.Configuration; -import org.springframework.data.redis.core.RedisTemplate; -import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; -import org.springframework.data.redis.serializer.StringRedisSerializer; -import reactor.core.publisher.Mono; - -import java.util.List; - -/** - * @author lengleng - * @date 2018/11/12 - *

- * redis store event default 100 - */ -@Slf4j -@Configuration -@AllArgsConstructor -public class RedisEventStore extends InMemoryEventStore { - - private final RedisTemplate redisTemplate; - - @Override - public Mono append(List events) { - events.forEach(event -> { - String key = event.getInstance().getValue() + StrUtil.UNDERLINE + event.getTimestamp().toString(); - log.info("保存实例事件的KEY:{},EVENT: {}", key, event.getType()); - redisTemplate.setKeySerializer(new StringRedisSerializer()); - redisTemplate.setHashValueSerializer(new Jackson2JsonRedisSerializer<>(InstanceEvent.class)); - redisTemplate.opsForHash().put(CacheConstants.EVENT_KEY, key, event); - }); - return super.append(events); - } - -}