// Path: src/main/java/biz/paluch/spinach/api/CommandKeyword.java
// public enum CommandKeyword implements ProtocolKeyword {
// 
//     ALL, ASYNC, BCAST, BLOCKING, BUSYLOOP, COUNT, DELAY, FLUSHALL, FORGET, FROM, GET, HARD, ID, IMPORTRATE, IN, LEAVING,
// 
//     MAXLEN, MEET, MINLEN, NODES, NOHANG, NONE, OUT, QUEUE, REPLICATE, REPLY, RESET, RESETSTAT, RETRY,
// 
//     REWRITE, SAVECONFIG, SET, SOFT, STATE, TIMEOUT, TTL, WITHCOUNTERS;
// 
//     public final byte[] bytes;
// 
//     private CommandKeyword() {
//         bytes = name().getBytes(LettuceCharsets.ASCII);
//     }
// 
//     @Override
//     public byte[] getBytes() {
//         return bytes;
//     }
// }


import static org.assertj.core.api.Assertions.assertThat;
import java.nio.ByteBuffer;
import java.util.concurrent.ExecutionException;
import com.lambdaworks.redis.codec.Utf8StringCodec;
import com.lambdaworks.redis.protocol.AsyncCommand;
import org.junit.After;
import org.junit.Test;
import biz.paluch.spinach.api.CommandKeyword;
import com.lambdaworks.redis.output.StatusOutput;
/*
 * Copyright 2016 the original author or authors.
 *
 * 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 biz.paluch.spinach.impl;






/**
 * @author Mark Paluch
 */
public class DisqueCommandTest {

    private Utf8StringCodec codec = new Utf8StringCodec();
// Path: src/main/java/biz/paluch/spinach/api/CommandKeyword.java
// public enum CommandKeyword implements ProtocolKeyword {
// 
//     ALL, ASYNC, BCAST, BLOCKING, BUSYLOOP, COUNT, DELAY, FLUSHALL, FORGET, FROM, GET, HARD, ID, IMPORTRATE, IN, LEAVING,
// 
//     MAXLEN, MEET, MINLEN, NODES, NOHANG, NONE, OUT, QUEUE, REPLICATE, REPLY, RESET, RESETSTAT, RETRY,
// 
//     REWRITE, SAVECONFIG, SET, SOFT, STATE, TIMEOUT, TTL, WITHCOUNTERS;
// 
//     public final byte[] bytes;
// 
//     private CommandKeyword() {
//         bytes = name().getBytes(LettuceCharsets.ASCII);
//     }
// 
//     @Override
//     public byte[] getBytes() {
//         return bytes;
//     }
// }


// Path: src/test/java/biz/paluch/spinach/impl/DisqueCommandTest.java
import static org.assertj.core.api.Assertions.assertThat;
import java.nio.ByteBuffer;
import java.util.concurrent.ExecutionException;
import com.lambdaworks.redis.codec.Utf8StringCodec;
import com.lambdaworks.redis.protocol.AsyncCommand;
import org.junit.After;
import org.junit.Test;
import biz.paluch.spinach.api.CommandKeyword;
import com.lambdaworks.redis.output.StatusOutput;

/*
 * Copyright 2016 the original author or authors.
 *
 * 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 biz.paluch.spinach.impl;






/**
 * @author Mark Paluch
 */
public class DisqueCommandTest {

    private Utf8StringCodec codec = new Utf8StringCodec();
    private DisqueCommand<String, String, String> command = new DisqueCommand<String, String, String>(CommandKeyword.GET,