Skip to content

Commit 98b91a4

Browse files
committed
Revert "Add getCodec method to StatefulConnection (#3444)"
This reverts commit bcabe0f.
1 parent 9dd0bb8 commit 98b91a4

File tree

5 files changed

+0
-23
lines changed

5 files changed

+0
-23
lines changed

src/main/java/io/lettuce/core/StatefulRedisConnectionImpl.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,6 @@ public StatefulRedisConnectionImpl(RedisChannelWriter writer, PushHandler pushHa
109109
this.reactive = newRedisReactiveCommandsImpl();
110110
}
111111

112-
@Override
113112
public RedisCodec<K, V> getCodec() {
114113
return codec;
115114
}

src/main/java/io/lettuce/core/api/StatefulConnection.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66

77
import io.lettuce.core.ClientOptions;
88
import io.lettuce.core.RedisConnectionStateListener;
9-
import io.lettuce.core.codec.RedisCodec;
109
import io.lettuce.core.protocol.RedisCommand;
1110
import io.lettuce.core.resource.ClientResources;
1211

@@ -118,9 +117,4 @@ public interface StatefulConnection<K, V> extends AutoCloseable, AsyncCloseable
118117
*/
119118
void flushCommands();
120119

121-
/**
122-
* @return the {@link RedisCodec} used by this connection.
123-
*/
124-
RedisCodec<K, V> getCodec();
125-
126120
}

src/main/java/io/lettuce/core/cluster/StatefulRedisClusterConnectionImpl.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -126,11 +126,6 @@ public StatefulRedisClusterConnectionImpl(RedisChannelWriter writer, ClusterPush
126126
this.reactive = newRedisAdvancedClusterReactiveCommandsImpl();
127127
}
128128

129-
@Override
130-
public RedisCodec<K, V> getCodec() {
131-
return codec;
132-
}
133-
134129
protected RedisAdvancedClusterReactiveCommandsImpl<K, V> newRedisAdvancedClusterReactiveCommandsImpl() {
135130
return new RedisAdvancedClusterReactiveCommandsImpl<>((StatefulRedisClusterConnection<K, V>) this, codec, parser);
136131
}

src/main/java/io/lettuce/core/masterslave/MasterSlaveConnectionWrapper.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import io.lettuce.core.api.push.PushListener;
1212
import io.lettuce.core.api.reactive.RedisReactiveCommands;
1313
import io.lettuce.core.api.sync.RedisCommands;
14-
import io.lettuce.core.codec.RedisCodec;
1514
import io.lettuce.core.masterreplica.StatefulRedisMasterReplicaConnection;
1615
import io.lettuce.core.protocol.RedisCommand;
1716
import io.lettuce.core.resource.ClientResources;
@@ -135,9 +134,4 @@ public void flushCommands() {
135134
delegate.flushCommands();
136135
}
137136

138-
@Override
139-
public RedisCodec<K, V> getCodec() {
140-
return delegate.getCodec();
141-
}
142-
143137
}

src/main/java/io/lettuce/core/sentinel/StatefulRedisSentinelConnectionImpl.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -128,11 +128,6 @@ public ConnectionState getConnectionState() {
128128
return connectionState;
129129
}
130130

131-
@Override
132-
public RedisCodec<K, V> getCodec() {
133-
return codec;
134-
}
135-
136131
static class SentinelConnectionState extends ConnectionState {
137132

138133
@Override

0 commit comments

Comments
 (0)