github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactoring

Browse Source
pull/2691/head
Nikita Koksharov 5 years ago
parent efba350f8b
commit bad582f96e
5 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File

8
redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

@ -237,11 +237,11 @@ public class RedissonConnection extends AbstractRedisConnection {
final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
final AtomicLong count = new AtomicLong();
final AtomicLong executed = new AtomicLong(range2key.size());
BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
@Override
public void accept(List<?> r, Throwable u) {
public void accept(BatchResult<?> r, Throwable u) {
if (u == null) {
List<Long> result = (List<Long>) r;
List<Long> result = (List<Long>) r.getResponses();
for (Long res : result) {
if (res != null) {
count.addAndGet(res);
@ -261,7 +261,7 @@ public class RedissonConnection extends AbstractRedisConnection {
es.writeAsync(entry.getKey(), null, command, key);
}
RFuture<List<?>> future = es.executeAsync();
RFuture<BatchResult<?>> future = es.executeAsync();
future.onComplete(listener);
}

8
redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

@ -273,11 +273,11 @@ public class RedissonConnection extends AbstractRedisConnection {
final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
final AtomicLong count = new AtomicLong();
final AtomicLong executed = new AtomicLong(range2key.size());
BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
@Override
public void accept(List<?> r, Throwable u) {
public void accept(BatchResult<?> r, Throwable u) {
if (u == null) {
List<Long> result = (List<Long>) r;
List<Long> result = (List<Long>) r.getResponses();
for (Long res : result) {
if (res != null) {
count.addAndGet(res);
@ -297,7 +297,7 @@ public class RedissonConnection extends AbstractRedisConnection {
es.writeAsync(entry.getKey(), null, command, key);
}
RFuture<List<?>> future = es.executeAsync();
RFuture<BatchResult<?>> future = es.executeAsync();
future.onComplete(listener);
}

8
redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

@ -240,11 +240,11 @@ public class RedissonConnection extends AbstractRedisConnection {
final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
final AtomicLong count = new AtomicLong();
final AtomicLong executed = new AtomicLong(range2key.size());
BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
@Override
public void accept(List<?> r, Throwable u) {
public void accept(BatchResult<?> r, Throwable u) {
if (u == null) {
List<Long> result = (List<Long>) r;
List<Long> result = (List<Long>) r.getResponses();
for (Long res : result) {
if (res != null) {
count.addAndGet(res);
@ -264,7 +264,7 @@ public class RedissonConnection extends AbstractRedisConnection {
es.writeAsync(entry.getKey(), null, command, key);
}
RFuture<List<?>> future = es.executeAsync();
RFuture<BatchResult<?>> future = es.executeAsync();
future.onComplete(listener);
}

8
redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

@ -270,11 +270,11 @@ public class RedissonConnection extends AbstractRedisConnection {
final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
final AtomicLong count = new AtomicLong();
final AtomicLong executed = new AtomicLong(range2key.size());
BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
@Override
public void accept(List<?> r, Throwable u) {
public void accept(BatchResult<?> r, Throwable u) {
if (u == null) {
List<Long> result = (List<Long>) r;
List<Long> result = (List<Long>) r.getResponses();
for (Long res : result) {
if (res != null) {
count.addAndGet(res);
@ -294,7 +294,7 @@ public class RedissonConnection extends AbstractRedisConnection {
es.writeAsync(entry.getKey(), null, command, key);
}
RFuture<List<?>> future = es.executeAsync();
RFuture<BatchResult<?>> future = es.executeAsync();
future.onComplete(listener);
}

8
redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

@ -262,11 +262,11 @@ public class RedissonConnection extends AbstractRedisConnection {
final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
final AtomicLong count = new AtomicLong();
final AtomicLong executed = new AtomicLong(range2key.size());
BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
@Override
public void accept(List<?> r, Throwable u) {
public void accept(BatchResult<?> r, Throwable u) {
if (u == null) {
List<Long> result = (List<Long>) r;
List<Long> result = (List<Long>) r.getResponses();
for (Long res : result) {
if (res != null) {
count.addAndGet(res);
@ -286,7 +286,7 @@ public class RedissonConnection extends AbstractRedisConnection {
es.writeAsync(entry.getKey(), null, command, key);
}
RFuture<List<?>> future = es.executeAsync();
RFuture<BatchResult<?>> future = es.executeAsync();
future.onComplete(listener);
}

Write Preview
Loading…
Cancel
Save