@Test public void testServiceList_PooledConnection() throws Exception { int maxServices = 5; final int iterations = 5; int poolsize = maxServices - 1; createDatabase(); List<Service> serviceList = new ArrayList<Service>(); String name = Thread.currentThread().getName(); Thread.currentThread().setName(getName()); JdbcPooledConnection conn = PooledConnectionHelper.createPooledConnection(PROPERTIES.getProperty(CFG_JDBC_DRIVER), PROPERTIES.getProperty(CFG_JDBC_URL), poolsize); try { GuidGenerator guid = new GuidGenerator(); for (int i = 0; i < maxServices; i++) { JdbcServiceList service = createServiceCollection(createSequenceNumberService(conn, guid.safeUUID()), createSequenceNumberService(conn, guid.safeUUID())); service.setConnection(conn); serviceList.add(service); start(service); } PooledConnectionHelper.executeTest(serviceList, iterations, new PooledConnectionHelper.MessageCreator() { @Override public AdaptrisMessage createMsgForPooledConnectionTest() throws Exception { return AdaptrisMessageFactory.getDefaultInstance().newMessage(); } }); assertEquals(0, conn.currentBusyConnectionCount()); assertEquals(poolsize, conn.currentIdleConnectionCount()); assertEquals(poolsize, conn.currentConnectionCount()); } finally { stop(serviceList.toArray(new ComponentLifecycle[0])); Thread.currentThread().setName(name); } }
@Override public void setConnection(AdaptrisConnection c) { this.connection = c; }
JdbcServiceList extends ServiceList implements ConnectedService { @Override public void setConnection(AdaptrisConnection c) { this.connection = c; } }
JdbcServiceList extends ServiceList implements ConnectedService { @Override public void setConnection(AdaptrisConnection c) { this.connection = c; } JdbcServiceList();  JdbcServiceList(Collection<Service> serviceList);  JdbcServiceList(Service... services); }
JdbcServiceList extends ServiceList implements ConnectedService { @Override public void setConnection(AdaptrisConnection c) { this.connection = c; } JdbcServiceList();  JdbcServiceList(Collection<Service> serviceList);  JdbcServiceList(Service... services); @Override void prepare(); @Override AdaptrisConnection getConnection(); @Override void setConnection(AdaptrisConnection c); }
JdbcServiceList extends ServiceList implements ConnectedService { @Override public void setConnection(AdaptrisConnection c) { this.connection = c; } JdbcServiceList();  JdbcServiceList(Collection<Service> serviceList);  JdbcServiceList(Service... services); @Override void prepare(); @Override AdaptrisConnection getConnection(); @Override void setConnection(AdaptrisConnection c);  }