From a22deac08b92f84594aafec66ebc46c4986d153a Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 9 Oct 2017 10:56:03 +0300 Subject: [PATCH] Unnecessary codecs removed --- .../decoder/TTLMapValueReplayDecoder.java | 48 ------------- .../decoder/CacheGetAllDecoder.java | 69 ------------------- 2 files changed, 117 deletions(-) delete mode 100644 redisson/src/main/java/org/redisson/client/protocol/decoder/TTLMapValueReplayDecoder.java delete mode 100644 redisson/src/main/java/org/redisson/connection/decoder/CacheGetAllDecoder.java diff --git a/redisson/src/main/java/org/redisson/client/protocol/decoder/TTLMapValueReplayDecoder.java b/redisson/src/main/java/org/redisson/client/protocol/decoder/TTLMapValueReplayDecoder.java deleted file mode 100644 index 038b28bf3..000000000 --- a/redisson/src/main/java/org/redisson/client/protocol/decoder/TTLMapValueReplayDecoder.java +++ /dev/null @@ -1,48 +0,0 @@ -/** - * Copyright 2016 Nikita Koksharov - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.redisson.client.protocol.decoder; - -import java.util.List; - -import org.redisson.client.handler.State; - -import io.netty.buffer.ByteBuf; -import io.netty.util.CharsetUtil; - -/** - * - * @author Nikita Koksharov - * - * @param type - */ -public class TTLMapValueReplayDecoder implements MultiDecoder> { - - @Override - public Object decode(ByteBuf buf, State state) { - return Long.valueOf(buf.toString(CharsetUtil.UTF_8)); - } - - @Override - public List decode(List parts, State state) { - return (List) parts; - } - - @Override - public boolean isApplicable(int paramNum, State state) { - return paramNum == 0; - } - -} diff --git a/redisson/src/main/java/org/redisson/connection/decoder/CacheGetAllDecoder.java b/redisson/src/main/java/org/redisson/connection/decoder/CacheGetAllDecoder.java deleted file mode 100644 index 996dc1f52..000000000 --- a/redisson/src/main/java/org/redisson/connection/decoder/CacheGetAllDecoder.java +++ /dev/null @@ -1,69 +0,0 @@ -/** - * Copyright 2016 Nikita Koksharov - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.redisson.connection.decoder; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.redisson.client.codec.LongCodec; -import org.redisson.client.handler.State; -import org.redisson.client.protocol.decoder.MultiDecoder; - -import io.netty.buffer.ByteBuf; - -/** - * - * @author Nikita Koksharov - * - */ -public class CacheGetAllDecoder implements MultiDecoder> { - - private final List args; - - public CacheGetAllDecoder(List args) { - this.args = args; - } - - @Override - public Object decode(ByteBuf buf, State state) throws IOException { - return LongCodec.INSTANCE.getValueDecoder().decode(buf, state); - } - - @Override - public boolean isApplicable(int paramNum, State state) { - return paramNum == 0; - } - - @Override - public List decode(List parts, State state) { - List result = new ArrayList(); - Map map = new HashMap(parts.size()); - for (int index = 0; index < args.size()-1; index++) { - Object value = parts.get(index+1); - if (value == null) { - continue; - } - map.put(args.get(index+1), value); - } - result.add(parts.get(0)); - result.add(map); - return result; - } - -}