errors text fixed

pull/282/head
Nikita 9 years ago
parent 46138c7f14
commit 0afc82049f

@ -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);
}
}

@ -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);
}
}

Loading…
Cancel
Save