From 0afc82049f5dcf181f8c075ef313c31564fea907 Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 4 Nov 2015 13:55:41 +0300 Subject: [PATCH] errors text fixed --- src/main/java/org/redisson/CommandBatchExecutorService.java | 2 +- src/main/java/org/redisson/CommandExecutorService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/redisson/CommandBatchExecutorService.java b/src/main/java/org/redisson/CommandBatchExecutorService.java index 280fb0e41..263d11aab 100644 --- a/src/main/java/org/redisson/CommandBatchExecutorService.java +++ b/src/main/java/org/redisson/CommandBatchExecutorService.java @@ -231,7 +231,7 @@ public class CommandBatchExecutorService extends CommandExecutorService { public void operationComplete(ChannelFuture future) throws Exception { if (!future.isSuccess()) { timeout.cancel(); - ex.set(new WriteRedisConnectionException("channel: " + future.channel() + " closed")); + ex.set(new WriteRedisConnectionException("channel: " + future.channel() + " has been closed")); connectionManager.getTimer().newTimeout(retryTimerTask, connectionManager.getConfig().getRetryInterval(), TimeUnit.MILLISECONDS); } } diff --git a/src/main/java/org/redisson/CommandExecutorService.java b/src/main/java/org/redisson/CommandExecutorService.java index 0fa7fdfe5..dbd783840 100644 --- a/src/main/java/org/redisson/CommandExecutorService.java +++ b/src/main/java/org/redisson/CommandExecutorService.java @@ -493,7 +493,7 @@ public class CommandExecutorService implements CommandExecutor { return; } ex.set(new WriteRedisConnectionException( - "Can't send command: " + command + ", params: " + params + ", channel: " + future.channel(), future.cause())); + "Can't write command: " + command + ", params: " + params + " to channel: " + future.channel(), future.cause())); connectionManager.getTimer().newTimeout(retryTimerTask, connectionManager.getConfig().getRetryInterval(), TimeUnit.MILLISECONDS); } }