perf(StringRedisTemplate): avoid redundant logger creation in execute().

src/main/java/org/springframework/data/redis/connection/AbstractRedisConnection.java

@@ -35,7 +35,7 @@
  */
 public abstract class AbstractRedisConnection implements RedisConnection {
 
-	private final Log LOGGER = LogFactory.getLog(getClass());
+	private static final Log LOGGER = LogFactory.getLog(AbstractRedisConnection.class);
 
 	private @Nullable RedisSentinelConfiguration sentinelConfiguration;
 	private final Map<RedisNode, RedisSentinelConnection> connectionCache = new ConcurrentHashMap<>();

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

@@ -87,7 +87,7 @@ public class DefaultStringRedisConnection implements StringRedisConnection, Deco
 
 	private static final byte[][] EMPTY_2D_BYTE_ARRAY = new byte[0][];
 
-	private final Log log = LogFactory.getLog(DefaultStringRedisConnection.class);
+	private static final Log log = LogFactory.getLog(DefaultStringRedisConnection.class);
 	private final RedisConnection delegate;
 	private final RedisSerializer<String> serializer;
 	private Converter<byte[], String> bytesToString = new DeserializingConverter();

src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterConnection.java

@@ -80,7 +80,7 @@ public class JedisClusterConnection implements RedisClusterConnection {
 	private static final ExceptionTranslationStrategy EXCEPTION_TRANSLATION = new FallbackExceptionTranslationStrategy(
 			JedisExceptionConverter.INSTANCE);
 
-	private final Log log = LogFactory.getLog(getClass());
+	private static final Log log = LogFactory.getLog(JedisClusterConnection.class);
 
 	private final JedisCluster cluster;
 	private final JedisClusterGeoCommands geoCommands = new JedisClusterGeoCommands(this);

src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java

@@ -79,6 +79,8 @@
  */
 public class JedisConnection extends AbstractRedisConnection {
 
+	private static final Log LOGGER = LogFactory.getLog(JedisConnection.class);
+
 	private static final ExceptionTranslationStrategy EXCEPTION_TRANSLATION =
 			new FallbackExceptionTranslationStrategy(JedisExceptionConverter.INSTANCE);
 
@@ -108,8 +110,6 @@ public class JedisConnection extends AbstractRedisConnection {
 	private final JedisStringCommands stringCommands = new JedisStringCommands(this);
 	private final JedisZSetCommands zSetCommands = new JedisZSetCommands(this);
 
-	private final Log LOGGER = LogFactory.getLog(getClass());
-
 	@SuppressWarnings("rawtypes")
 	private List<JedisResult> pipelinedResults = new ArrayList<>();
 

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterConnection.java

@@ -70,6 +70,8 @@
 public class LettuceClusterConnection extends LettuceConnection
 		implements RedisClusterConnection, DefaultedRedisClusterConnection {
 
+	private static final Log log = LogFactory.getLog(LettuceClusterConnection.class);
+
 	static final ExceptionTranslationStrategy exceptionConverter = new PassThroughExceptionTranslationStrategy(
 			LettuceExceptionConverter.INSTANCE);
 
@@ -79,8 +81,6 @@ public class LettuceClusterConnection extends LettuceConnection
 
 	private ClusterTopologyProvider topologyProvider;
 
-	private final Log log = LogFactory.getLog(getClass());
-
 	private final LettuceClusterGeoCommands geoCommands = new LettuceClusterGeoCommands(this);
 	private final LettuceClusterHashCommands hashCommands = new LettuceClusterHashCommands(this);
 	private final LettuceClusterHyperLogLogCommands hllCommands = new LettuceClusterHyperLogLogCommands(this);

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java

@@ -104,6 +104,8 @@
  */
 public class LettuceConnection extends AbstractRedisConnection {
 
+	private static final Log LOGGER = LogFactory.getLog(LettuceConnection.class);
+
 	private static final ExceptionTranslationStrategy EXCEPTION_TRANSLATION = new FallbackExceptionTranslationStrategy(
 			LettuceExceptionConverter.INSTANCE);
 
@@ -154,8 +156,6 @@ public List<Object> convert(List<Object> execResults) {
 
 	private @Nullable List<LettuceResult<?, ?>> ppline;
 
-	private final Log LOGGER = LogFactory.getLog(getClass());
-
 	private PipeliningFlushPolicy pipeliningFlushPolicy = PipeliningFlushPolicy.flushEachCommand();
 
 	private @Nullable PipeliningFlushState pipeliningFlushState;

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java

@@ -120,6 +120,8 @@
 public class LettuceConnectionFactory implements RedisConnectionFactory, ReactiveRedisConnectionFactory,
 		InitializingBean, DisposableBean, SmartLifecycle {
 
+	private static final Log log = LogFactory.getLog(LettuceConnectionFactory.class);
+
 	private static final ExceptionTranslationStrategy EXCEPTION_TRANSLATION = new PassThroughExceptionTranslationStrategy(
 			LettuceExceptionConverter.INSTANCE);
 
@@ -144,8 +146,6 @@ public class LettuceConnectionFactory implements RedisConnectionFactory, Reactiv
 	private @Nullable LettuceConnectionProvider connectionProvider;
 	private @Nullable LettuceConnectionProvider reactiveConnectionProvider;
 
-	private final Log log = LogFactory.getLog(getClass());
-
 	private final Lock lock = new ReentrantLock();
 
 	private PipeliningFlushPolicy pipeliningFlushPolicy = PipeliningFlushPolicy.flushEachCommand();

src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java

@@ -113,7 +113,7 @@ public class RedisKeyValueAdapter extends AbstractKeyValueAdapter
 	 */
 	private static final int PHANTOM_KEY_TTL = 300;
 
-	private final Log logger = LogFactory.getLog(getClass());
+	private static final Log logger = LogFactory.getLog(RedisKeyValueAdapter.class);
 	private final AtomicReference<State> state = new AtomicReference<>(State.CREATED);
 
 	private RedisOperations<?, ?> redisOps;

src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java

@@ -107,6 +107,8 @@
  */
 public class RedisMessageListenerContainer implements InitializingBean, DisposableBean, BeanNameAware, SmartLifecycle {
 
+	protected static final Log logger = LogFactory.getLog(RedisMessageListenerContainer.class);
+
 	/**
 	 * The default recovery interval: 5000 ms = 5 seconds.
 	 */
@@ -123,9 +125,6 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab
 	public static final String DEFAULT_THREAD_NAME_PREFIX = ClassUtils.getShortName(RedisMessageListenerContainer.class)
 			+ "-";
 
-	/** Logger available to subclasses */
-	protected final Log logger = LogFactory.getLog(getClass());
-
 	// whether the container has been initialized via afterPropertiesSet
 	private boolean afterPropertiesSet = false;
 

src/main/java/org/springframework/data/redis/listener/adapter/MessageListenerAdapter.java

@@ -159,8 +159,7 @@ public String getMethodName() {
 	 */
 	public static final String ORIGINAL_DEFAULT_LISTENER_METHOD = "handleMessage";
 
-	/** Logger available to subclasses */
-	protected final Log logger = LogFactory.getLog(getClass());
+	protected static final Log logger = LogFactory.getLog(MessageListenerAdapter.class);
 
 	private volatile @Nullable Object delegate;
 

src/main/java/org/springframework/data/redis/repository/cdi/RedisRepositoryExtension.java

@@ -51,7 +51,7 @@
  */
 public class RedisRepositoryExtension extends CdiRepositoryExtensionSupport {
 
-	private final Log log = LogFactory.getLog(RedisRepositoryExtension.class);
+	private static final Log log = LogFactory.getLog(RedisRepositoryExtension.class);
 	private final Map<Set<Annotation>, Bean<RedisKeyValueAdapter>> redisKeyValueAdapters = new HashMap<>();
 	private final Map<Set<Annotation>, Bean<KeyValueOperations>> redisKeyValueTemplates = new HashMap<>();
 	private final Map<Set<Annotation>, Bean<RedisOperations<?, ?>>> redisOperations = new HashMap<>();

src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java

@@ -58,7 +58,7 @@
  */
 class DefaultStreamReceiver<K, V extends Record<K, ?>> implements StreamReceiver<K, V> {
 
-	private final Log logger = LogFactory.getLog(getClass());
+	private static final Log logger = LogFactory.getLog(DefaultStreamReceiver.class);
 	private final ReactiveRedisTemplate<K, ?> template;
 	private final ReactiveStreamOperations<K, Object, Object> streamOperations;
 	private final StreamReadOptions readOptions;