@@ -2080,28 +2080,30 @@ public static Map<String, String> defaultKeysWk() {
20802080 @ SuppressWarnings ({"SpellCheckingInspection" , "EnhancedSwitchMigration" })
20812081 public static WrapResponse <?> wget (String key ) {
20822082 if (String4j .isEmpty (key )) {
2083- return new HttpWrapBuilder <>().badRequest ("key is required" ).build ();
2083+ return new HttpWrapBuilder <>().badRequest ("key is required" ).requestId ( getCurrentSessionId ()). build ();
20842084 }
20852085 RedisCommands <String , String > command = syncCommands ();
20862086 if (command == null ) {
2087- return new HttpWrapBuilder <>().internalServerError ("Redis connection failure" ).build ();
2087+ return new HttpWrapBuilder <>().internalServerError ("Redis connection failure" ).requestId ( getCurrentSessionId ()). build ();
20882088 }
20892089 String type = command .type (key );
20902090 switch (type ) {
20912091 case "string" :
2092- return new HttpWrapBuilder <>().ok (command .get (key )).customFields ("redis_key_type_stored" , "string" ).build ();
2092+ return new HttpWrapBuilder <>().ok (command .get (key )).requestId ( getCurrentSessionId ()). customFields ("redis_key_type_stored" , "string" ).build ();
20932093 case "list" :
2094- return new HttpWrapBuilder <>().ok (command .lrange (key , 0 , -1 )).customFields ("redis_key_type_stored" , "list" ).build ();
2094+ return new HttpWrapBuilder <>().ok (command .lrange (key , 0 , -1 )).requestId ( getCurrentSessionId ()). customFields ("redis_key_type_stored" , "list" ).build ();
20952095 case "hash" :
2096- return new HttpWrapBuilder <>().ok (command .hgetall (key )).customFields ("redis_key_type_stored" , "hash" ).build ();
2096+ return new HttpWrapBuilder <>().ok (command .hgetall (key )).requestId ( getCurrentSessionId ()). customFields ("redis_key_type_stored" , "hash" ).build ();
20972097 case "set" :
2098- return new HttpWrapBuilder <>().ok (command .smembers (key )).customFields ("redis_key_type_stored" , "set" ).build ();
2098+ return new HttpWrapBuilder <>().ok (command .smembers (key )).requestId ( getCurrentSessionId ()). customFields ("redis_key_type_stored" , "set" ).build ();
20992099 case "zset" :
2100- return new HttpWrapBuilder <>().ok (command .zrange (key , 0 , -1 )).customFields ("redis_key_type_stored" , "zset" ).build ();
2100+ return new HttpWrapBuilder <>().ok (command .zrange (key , 0 , -1 )).requestId ( getCurrentSessionId ()). customFields ("redis_key_type_stored" , "zset" ).build ();
21012101 default :
21022102 return new HttpWrapBuilder <>().message (String .format ("unsupported type: %s" , type ))
21032103 .statusCode (HttpStatusBuilder .UN_PROCESSABLE_ENTITY )
2104- .customFields ("redis_key_type_stored_unsupported" , type ).build ();
2104+ .customFields ("redis_key_type_stored_unsupported" , type )
2105+ .requestId (getCurrentSessionId ())
2106+ .build ();
21052107 }
21062108 }
21072109}
0 commit comments