@@ -272,9 +272,7 @@ public Object get(Object id, String keyspace) {
272272 public <T > T get (Object id , String keyspace , Class <T > type ) {
273273
274274 String stringId = asString (id );
275- String stringKeyspace = asString (keyspace );
276-
277- byte [] binId = createKey (stringKeyspace , stringId );
275+ byte [] binId = createKey (keyspace , stringId );
278276
279277 RedisCallback <Map <byte [], byte []>> command = connection -> connection .hGetAll (binId );
280278
@@ -287,7 +285,7 @@ public <T> T get(Object id, String keyspace, Class<T> type) {
287285 RedisData data = new RedisData (raw );
288286
289287 data .setId (stringId );
290- data .setKeyspace (stringKeyspace );
288+ data .setKeyspace (keyspace );
291289
292290 return readBackTimeToLiveIfSet (binId , converter .read (type , data ));
293291 }
@@ -307,13 +305,13 @@ public <T> T delete(Object id, String keyspace, Class<T> type) {
307305
308306 if (value != null ) {
309307
310- byte [] keyToDelete = createKey (asString ( keyspace ) , asString (id ));
308+ byte [] keyToDelete = createKey (keyspace , asString (id ));
311309
312310 redisOps .execute ((RedisCallback <Void >) connection -> {
313311
314312 connection .del (keyToDelete );
315313 connection .sRem (binKeyspace , binId );
316- new IndexWriter (connection , converter ).removeKeyFromIndexes (asString ( keyspace ) , binId );
314+ new IndexWriter (connection , converter ).removeKeyFromIndexes (keyspace , binId );
317315
318316 if (RedisKeyValueAdapter .this .keepShadowCopy ()) {
319317
@@ -384,7 +382,7 @@ public void deleteAllOf(String keyspace) {
384382 redisOps .execute ((RedisCallback <Void >) connection -> {
385383
386384 connection .del (toBytes (keyspace ));
387- new IndexWriter (connection , converter ).removeAllIndexes (asString ( keyspace ) );
385+ new IndexWriter (connection , converter ).removeAllIndexes (keyspace );
388386 return null ;
389387 });
390388 }
0 commit comments