// Path: redis-storage/src/main/java/com/offbynull/actors/redisclient/Connector.java
// public interface Connector extends Closeable {
//     /**
//      * Get a {@link Connection}.
//      * @return connection
//      * @throws IllegalStateException if closed
//      */
//     Connection getConnection();
// }
// 
// Path: redis-storage/src/main/java/com/offbynull/actors/redisclients/test/TestConnector.java
// public final class TestConnector implements Connector {
//     
//     private final Map<String, Item> keyspace = new HashMap<>();
//     private final AtomicBoolean closed = new AtomicBoolean();
//     
//     @Override
//     public Connection getConnection() {
//         Validate.validState(!closed.get(), "Closed");
//         return new TestConnection(keyspace, closed);
//     }
// 
//     @Override
//     public void close() throws IOException {
//         closed.set(true);
//     }
//     
// }


import com.offbynull.actors.redisclient.Connection;
import static com.offbynull.actors.address.Address.fromString;
import com.offbynull.actors.redisclient.Connector;
import com.offbynull.actors.redisclients.test.TestConnector;
import org.junit.After;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
import org.junit.Before;
import org.junit.Test;
package com.offbynull.actors.gateways.actor.stores.redis;


public final class TimestampQueueTest {
    
    private Connector connector;
    private Connection connection;

    
    @Before
    public void setUp() throws Exception {
//        connector = new JedisPoolConnector("192.168.56.101", 6379, 1);
//        clientFactory = new ConnectorClientFactory(connector);
// Path: redis-storage/src/main/java/com/offbynull/actors/redisclient/Connector.java
// public interface Connector extends Closeable {
//     /**
//      * Get a {@link Connection}.
//      * @return connection
//      * @throws IllegalStateException if closed
//      */
//     Connection getConnection();
// }
// 
// Path: redis-storage/src/main/java/com/offbynull/actors/redisclients/test/TestConnector.java
// public final class TestConnector implements Connector {
//     
//     private final Map<String, Item> keyspace = new HashMap<>();
//     private final AtomicBoolean closed = new AtomicBoolean();
//     
//     @Override
//     public Connection getConnection() {
//         Validate.validState(!closed.get(), "Closed");
//         return new TestConnection(keyspace, closed);
//     }
// 
//     @Override
//     public void close() throws IOException {
//         closed.set(true);
//     }
//     
// }


// Path: redis-storage/src/test/java/com/offbynull/actors/gateways/actor/stores/redis/TimestampQueueTest.java
import com.offbynull.actors.redisclient.Connection;
import static com.offbynull.actors.address.Address.fromString;
import com.offbynull.actors.redisclient.Connector;
import com.offbynull.actors.redisclients.test.TestConnector;
import org.junit.After;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
import org.junit.Before;
import org.junit.Test;

package com.offbynull.actors.gateways.actor.stores.redis;


public final class TimestampQueueTest {
    
    private Connector connector;
    private Connection connection;

    
    @Before
    public void setUp() throws Exception {
//        connector = new JedisPoolConnector("192.168.56.101", 6379, 1);
//        clientFactory = new ConnectorClientFactory(connector);
        connector = new TestConnector();