refactoring

pull/3487/head
Nikita Koksharov 4 years ago
parent 179c0c830a
commit 8bc4dc996f

@ -91,16 +91,6 @@ public class RedissonStream<K, V> extends RedissonExpirable implements RStream<K
return get(ackAsync(groupName, id));
}
@Override
public RFuture<PendingResult> listPendingAsync(String groupName) {
return getPendingInfoAsync(groupName);
}
@Override
public PendingResult listPending(String groupName) {
return getPendingInfo(groupName);
}
@Override
public RFuture<PendingResult> getPendingInfoAsync(String groupName) {
return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, RedisCommands.XPENDING, getName(), groupName);
@ -108,7 +98,7 @@ public class RedissonStream<K, V> extends RedissonExpirable implements RStream<K
@Override
public PendingResult getPendingInfo(String groupName) {
return get(listPendingAsync(groupName));
return get(getPendingInfoAsync(groupName));
}
@Override

@ -104,12 +104,6 @@ public interface RStream<K, V> extends RStreamAsync<K, V>, RExpirable {
*/
PendingResult getPendingInfo(String groupName);
/*
* Use #getPendingInfo method
*/
@Deprecated
PendingResult listPending(String groupName);
/**
* Returns list of common info about pending messages by group name.
* Limited by start Stream Message ID and end Stream Message ID and count.

@ -106,12 +106,6 @@ public interface RStreamAsync<K, V> extends RExpirableAsync {
*/
RFuture<PendingResult> getPendingInfoAsync(String groupName);
/*
* Use #getPendingInfoAsync method
*/
@Deprecated
RFuture<PendingResult> listPendingAsync(String groupName);
/**
* Returns list of common info about pending messages by group name.
* Limited by minimum idle time, messages count, start and end Stream Message IDs.

@ -97,7 +97,7 @@ public class RedissonStreamTest extends BaseTest {
public void testPendingEmpty() {
RStream<Object, Object> stream = redisson.getStream("test");
stream.createGroup("testGroup");
PendingResult result = stream.listPending("testGroup");
PendingResult result = stream.getPendingInfo("testGroup");
assertThat(result.getTotal()).isZero();
assertThat(result.getHighestId()).isNull();
assertThat(result.getLowestId()).isNull();
@ -298,7 +298,7 @@ public class RedissonStreamTest extends BaseTest {
Map<StreamMessageId, Map<String, String>> s2 = stream.readGroup("testGroup", "consumer2", StreamReadGroupArgs.neverDelivered());
assertThat(s2.size()).isEqualTo(2);
PendingResult pi = stream.listPending("testGroup");
PendingResult pi = stream.getPendingInfo("testGroup");
assertThat(pi.getLowestId()).isEqualTo(id1);
assertThat(pi.getHighestId()).isEqualTo(id4);
assertThat(pi.getTotal()).isEqualTo(4);

Loading…
Cancel
Save