@SuppressWarnings("unchecked") @Test public void testGetValidEndPointCount() { ServicePool<Service> pool = mock(ServicePool.class); when(pool.getNumValidEndPoints()).thenReturn(3); Service service = ServicePoolProxy.create(Service.class, mock(RetryPolicy.class), pool, mock(PartitionContextSupplier.class), true); assertEquals(3, ServicePoolProxies.getNumValidEndPoints(service)); }
public static <S> int getNumValidEndPoints(S dynamicProxy) { return getPool(dynamicProxy).getNumValidEndPoints(); }
ServicePoolProxies { public static <S> int getNumValidEndPoints(S dynamicProxy) { return getPool(dynamicProxy).getNumValidEndPoints(); } }
ServicePoolProxies { public static <S> int getNumValidEndPoints(S dynamicProxy) { return getPool(dynamicProxy).getNumValidEndPoints(); } private  ServicePoolProxies(); }
ServicePoolProxies { public static <S> int getNumValidEndPoints(S dynamicProxy) { return getPool(dynamicProxy).getNumValidEndPoints(); } private  ServicePoolProxies(); static boolean isProxy(Object dynamicProxy); static void close(S dynamicProxy); static int getNumValidEndPoints(S dynamicProxy); static int getNumBadEndPoints(S dynamicProxy); static HealthCheckResults checkForHealthyEndPoint(S dynamicProxy); static com.bazaarvoice.ostrich.ServicePool<S> getPool(S dynamicProxy); }
ServicePoolProxies { public static <S> int getNumValidEndPoints(S dynamicProxy) { return getPool(dynamicProxy).getNumValidEndPoints(); } private  ServicePoolProxies(); static boolean isProxy(Object dynamicProxy); static void close(S dynamicProxy); static int getNumValidEndPoints(S dynamicProxy); static int getNumBadEndPoints(S dynamicProxy); static HealthCheckResults checkForHealthyEndPoint(S dynamicProxy); static com.bazaarvoice.ostrich.ServicePool<S> getPool(S dynamicProxy);  }