AbstractRedisCommand extends AbstractNettyRequestResponseCommand<T> implements LoggableRedisCommand<T> { @Override protected boolean logRequest() { return logRequest; } AbstractRedisCommand(String host, int port, ScheduledExecutorService scheduled);  AbstractRedisCommand(SimpleObjectPool<NettyClient> clientPool, ScheduledExecutorService scheduled);  AbstractRedisCommand(String host, int port, ScheduledExecutorService scheduled, int commandTimeoutMilli);  AbstractRedisCommand(SimpleObjectPool<NettyClient> clientPool, ScheduledExecutorService scheduled, int commandTimeoutMilli); @Override String getName(); @Override int getCommandTimeoutMilli(); void setCommandTimeoutMilli(int commandTimeoutMilli); @Override void logResponse(boolean logResponse); @Override void logRequest(boolean logRequest); static int DEFAULT_REDIS_COMMAND_TIME_OUT_MILLI; static int PROXYED_REDIS_CONNECTION_COMMAND_TIME_OUT_MILLI; }
@Test public void testLogRequest() throws Exception { XpipeNettyClientKeyedObjectPool keyedObjectPool = getXpipeNettyClientKeyedObjectPool(); SimpleObjectPool<NettyClient> clientPool = keyedObjectPool .getKeyPool(new DefaultEndPoint("127.0.0.1", 6379)); ScheduledExecutorService scheduled = Executors.newScheduledThreadPool(1); InfoCommand infoCommand = new InfoCommand(clientPool, InfoCommand.INFO_TYPE.REPLICATION, scheduled); infoCommand.logResponse(false); infoCommand.execute().get(); }