@@ -40,7 +40,6 @@ public class ClientCommandsTest extends JedisCommandsTestBase {
4040
4141 private Jedis client ;
4242
43-
4443 public ClientCommandsTest (RedisProtocol protocol ) {
4544 super (protocol );
4645 }
@@ -124,15 +123,18 @@ public void clientIdReconnect() {
124123 public void clientUnblock () throws InterruptedException , TimeoutException {
125124 long clientId = client .clientId ();
126125 assertEquals (0 , jedis .clientUnblock (clientId , UnblockType .ERROR ));
127- Future <?> future = Executors .newSingleThreadExecutor ().submit (() -> client .brpop (100000 , "foo" ));
126+ Future <?> future = Executors .newSingleThreadExecutor ()
127+ .submit (() -> client .brpop (100000 , "foo" ));
128128
129129 try {
130130 // to make true command already executed
131131 TimeUnit .MILLISECONDS .sleep (500 );
132132 assertEquals (1 , jedis .clientUnblock (clientId , UnblockType .ERROR ));
133133 future .get (1 , TimeUnit .SECONDS );
134134 } catch (ExecutionException e ) {
135- assertEquals ("redis.clients.jedis.exceptions.JedisDataException: UNBLOCKED client unblocked via CLIENT UNBLOCK" , e .getMessage ());
135+ assertEquals (
136+ "redis.clients.jedis.exceptions.JedisDataException: UNBLOCKED client unblocked via CLIENT UNBLOCK" ,
137+ e .getMessage ());
136138 }
137139 }
138140
@@ -178,7 +180,8 @@ public void killSkipmeNo() {
178180 public void killSkipmeYesNo () {
179181 jedis .clientKill (new ClientKillParams ().type (ClientType .NORMAL ).skipMe (SkipMe .YES ));
180182 assertDisconnected (client );
181- assertEquals (1 , jedis .clientKill (new ClientKillParams ().type (ClientType .NORMAL ).skipMe (SkipMe .NO )));
183+ assertEquals (1 ,
184+ jedis .clientKill (new ClientKillParams ().type (ClientType .NORMAL ).skipMe (SkipMe .NO )));
182185 assertDisconnected (jedis );
183186 }
184187
@@ -226,7 +229,7 @@ public void killAddrIpPort() {
226229 matcher .find ();
227230 String addr = matcher .group (1 );
228231 int lastColon = addr .lastIndexOf (":" );
229- String [] hp = new String []{ addr .substring (0 , lastColon ), addr .substring (lastColon + 1 )};
232+ String [] hp = new String [] { addr .substring (0 , lastColon ), addr .substring (lastColon + 1 ) };
230233
231234 assertEquals (1 , jedis .clientKill (new ClientKillParams ().addr (hp [0 ], Integer .parseInt (hp [1 ]))));
232235
@@ -304,8 +307,8 @@ public void trackingInfo() {
304307
305308 @ Test
306309 public void trackingInfoResp3 () {
307- Jedis clientResp3 = new Jedis (endpoint .getHostAndPort (), endpoint . getClientConfigBuilder ()
308- .protocol (RedisProtocol .RESP3 ).build ());
310+ Jedis clientResp3 = new Jedis (endpoint .getHostAndPort (),
311+ endpoint . getClientConfigBuilder () .protocol (RedisProtocol .RESP3 ).build ());
309312 TrackingInfo trackingInfo = clientResp3 .clientTrackingInfo ();
310313
311314 assertEquals (1 , trackingInfo .getFlags ().size ());
0 commit comments