@@ -40,6 +40,7 @@ public class ClientCommandsTest extends JedisCommandsTestBase {
4040
4141 private Jedis client ;
4242
43+
4344 public ClientCommandsTest (RedisProtocol protocol ) {
4445 super (protocol );
4546 }
@@ -123,18 +124,15 @@ public void clientIdReconnect() {
123124 public void clientUnblock () throws InterruptedException , TimeoutException {
124125 long clientId = client .clientId ();
125126 assertEquals (0 , jedis .clientUnblock (clientId , UnblockType .ERROR ));
126- Future <?> future = Executors .newSingleThreadExecutor ()
127- .submit (() -> client .brpop (100000 , "foo" ));
127+ Future <?> future = Executors .newSingleThreadExecutor ().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 (
136- "redis.clients.jedis.exceptions.JedisDataException: UNBLOCKED client unblocked via CLIENT UNBLOCK" ,
137- e .getMessage ());
135+ assertEquals ("redis.clients.jedis.exceptions.JedisDataException: UNBLOCKED client unblocked via CLIENT UNBLOCK" , e .getMessage ());
138136 }
139137 }
140138
@@ -180,8 +178,7 @@ public void killSkipmeNo() {
180178 public void killSkipmeYesNo () {
181179 jedis .clientKill (new ClientKillParams ().type (ClientType .NORMAL ).skipMe (SkipMe .YES ));
182180 assertDisconnected (client );
183- assertEquals (1 ,
184- jedis .clientKill (new ClientKillParams ().type (ClientType .NORMAL ).skipMe (SkipMe .NO )));
181+ assertEquals (1 , jedis .clientKill (new ClientKillParams ().type (ClientType .NORMAL ).skipMe (SkipMe .NO )));
185182 assertDisconnected (jedis );
186183 }
187184
@@ -229,7 +226,7 @@ public void killAddrIpPort() {
229226 matcher .find ();
230227 String addr = matcher .group (1 );
231228 int lastColon = addr .lastIndexOf (":" );
232- String [] hp = new String [] { addr .substring (0 , lastColon ), addr .substring (lastColon + 1 ) };
229+ String [] hp = new String []{ addr .substring (0 , lastColon ), addr .substring (lastColon + 1 )};
233230
234231 assertEquals (1 , jedis .clientKill (new ClientKillParams ().addr (hp [0 ], Integer .parseInt (hp [1 ]))));
235232
@@ -307,8 +304,8 @@ public void trackingInfo() {
307304
308305 @ Test
309306 public void trackingInfoResp3 () {
310- Jedis clientResp3 = new Jedis (endpoint .getHostAndPort (),
311- endpoint . getClientConfigBuilder () .protocol (RedisProtocol .RESP3 ).build ());
307+ Jedis clientResp3 = new Jedis (endpoint .getHostAndPort (), endpoint . getClientConfigBuilder ()
308+ .protocol (RedisProtocol .RESP3 ).build ());
312309 TrackingInfo trackingInfo = clientResp3 .clientTrackingInfo ();
313310
314311 assertEquals (1 , trackingInfo .getFlags ().size ());
0 commit comments