Skip to content

Commit 521c493

Browse files
committed
chore: remove deprecated isOpen, etc. from sentinel command APIs
Signed-off-by: The-East-Wind <[email protected]>
1 parent 972b887 commit 521c493

File tree

8 files changed

+0
-48
lines changed

8 files changed

+0
-48
lines changed

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

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -196,15 +196,6 @@ public <T> AsyncCommand<K, V, T> dispatch(RedisCommand<K, V, T> cmd) {
196196
return asyncCommand;
197197
}
198198

199-
public void close() {
200-
connection.close();
201-
}
202-
203-
@Override
204-
public boolean isOpen() {
205-
return connection.isOpen();
206-
}
207-
208199
@Override
209200
public StatefulRedisSentinelConnection<K, V> getStatefulConnection() {
210201
return (StatefulRedisSentinelConnection<K, V>) connection;

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

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -189,16 +189,6 @@ public <T> Flux<T> dispatch(ProtocolKeyword type, CommandOutput<K, V, ?> output,
189189
return (Flux) createFlux(() -> new Command<>(type, output, args));
190190
}
191191

192-
@Override
193-
public void close() {
194-
getStatefulConnection().close();
195-
}
196-
197-
@Override
198-
public boolean isOpen() {
199-
return getStatefulConnection().isOpen();
200-
}
201-
202192
@Override
203193
public StatefulRedisSentinelConnection<K, V> getStatefulConnection() {
204194
return (StatefulRedisSentinelConnection<K, V>) super.getConnection();

src/main/java/io/lettuce/core/sentinel/api/async/RedisSentinelAsyncCommands.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -249,11 +249,6 @@ public interface RedisSentinelAsyncCommands<K, V> {
249249
*/
250250
<T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K, V, T> output, CommandArgs<K, V> args);
251251

252-
/**
253-
* @return {@code true} if the connection is open (connected and not closed).
254-
*/
255-
boolean isOpen();
256-
257252
/**
258253
* @return the underlying connection.
259254
*/

src/main/java/io/lettuce/core/sentinel/api/reactive/RedisSentinelReactiveCommands.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -249,11 +249,6 @@ public interface RedisSentinelReactiveCommands<K, V> {
249249
*/
250250
<T> Flux<T> dispatch(ProtocolKeyword type, CommandOutput<K, V, ?> output, CommandArgs<K, V> args);
251251

252-
/**
253-
* @return {@code true} if the connection is open (connected and not closed).
254-
*/
255-
boolean isOpen();
256-
257252
/**
258253
* @return the underlying connection.
259254
*/

src/main/java/io/lettuce/core/sentinel/api/sync/RedisSentinelCommands.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -248,11 +248,6 @@ public interface RedisSentinelCommands<K, V> {
248248
*/
249249
<T> T dispatch(ProtocolKeyword type, CommandOutput<K, V, T> output, CommandArgs<K, V> args);
250250

251-
/**
252-
* @return {@code true} if the connection is open (connected and not closed).
253-
*/
254-
boolean isOpen();
255-
256251
/**
257252
* @return the underlying connection.
258253
*/

src/main/kotlin/io/lettuce/core/sentinel/api/coroutines/RedisSentinelCoroutinesCommands.kt

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -246,11 +246,5 @@ interface RedisSentinelCoroutinesCommands<K : Any, V : Any> {
246246
*/
247247
fun <T : Any> dispatch(type: ProtocolKeyword, output: CommandOutput<K, V, T>, args: CommandArgs<K, V>): Flow<T>
248248

249-
/**
250-
*
251-
* @return @code true} if the connection is open (connected and not closed).
252-
*/
253-
fun isOpen(): Boolean
254-
255249
}
256250

src/main/kotlin/io/lettuce/core/sentinel/api/coroutines/RedisSentinelCoroutinesCommandsImpl.kt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,5 @@ internal class RedisSentinelCoroutinesCommandsImpl<K : Any, V : Any>(internal va
9999

100100
override fun <T : Any> dispatch(type: ProtocolKeyword, output: CommandOutput<K, V, T>, args: CommandArgs<K, V>): Flow<T> = ops.dispatch<T>(type, output, args).asFlow()
101101

102-
override fun isOpen(): Boolean = ops.isOpen
103-
104102
}
105103

src/main/templates/io/lettuce/core/api/RedisSentinelCommands.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -247,12 +247,6 @@ public interface RedisSentinelCommands<K, V> {
247247
*/
248248
<T> T dispatch(ProtocolKeyword type, CommandOutput<K, V, T> output, CommandArgs<K, V> args);
249249

250-
/**
251-
*
252-
* @return {@code true} if the connection is open (connected and not closed).
253-
*/
254-
boolean isOpen();
255-
256250
/**
257251
*
258252
* @return the underlying connection.

0 commit comments

Comments
 (0)