From d9537b5a74d59a4da9df45a9f917a18ba1108dae Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 11 Dec 2017 17:32:26 +0300 Subject: [PATCH] NPE fixed --- .../src/main/java/org/redisson/command/CommandAsyncService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index 5ea9c4628..699290e2b 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -536,7 +536,7 @@ public class CommandAsyncService implements CommandAsyncExecutor { if (details.getConnectionFuture().isSuccess()) { if (details.getWriteFuture() == null || !details.getWriteFuture().isDone()) { if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) { - if (details.getWriteFuture().cancel(false)) { + if (details.getWriteFuture() != null && details.getWriteFuture().cancel(false)) { if (details.getException() == null) { details.setException(new RedisTimeoutException("Unable to send command: " + command + " with params: " + LogHelper.toString(details.getParams()) + " after " + connectionManager.getConfig().getRetryAttempts() + " retry attempts")); }