queuingTasksWredis-ChannelAdapter.java

public class ChannelAdapter {
    private static final Logger LOGGER = LoggerFactory.getLogger(ChannelAdapter.class);

    private final String waitQueue = "TestSample:waitQueue";
    private final String workQueue = "TestSample:workQueue";

    private final JedisPool jedisPool;

    /**
     * ChannelAdapter in charge of communication with messaging
     * service.
     * 
     * @param jedisPool
     *            - provider of jedis connections
     */
    public ChannelAdapter(JedisPool jedisPool) {

        this.jedisPool = jedisPool;
    }