RethinkDBFactoryBean.java

import com.rethinkdb.RethinkDB;
import com.rethinkdb.net.Connection;
import org.springframework.beans.factory.config.AbstractFactoryBean;

import java.util.concurrent.TimeoutException;

public class RethinkDBFactoryBean extends AbstractFactoryBean<Connection> {


    private final Connection conn;

    private static final RethinkDB r = RethinkDB.r;

    public RethinkDBFactoryBean(String host, Integer port) throws TimeoutException {
        conn = r.connection().hostname(host).port(port).connect();
    }

    public RethinkDBFactoryBean(String host, String port) throws TimeoutException {
        this(host, Integer.valueOf(port));
    }


    @Override
    public Class<?> getObjectType() {
        return Connection.class;
    }

    @Override
    protected Connection createInstance() throws Exception {
        return conn;
    }
}