@Test public void testGetNumBadEndPoints() { int expected = new Random().nextInt(); AsyncServicePool<Service> pool = newAsyncPool(); when(_mockPool.getNumBadEndPoints()).thenReturn(expected); assertEquals(expected, pool.getNumBadEndPoints()); verify(_mockPool).getNumBadEndPoints(); }
@Override public int getNumBadEndPoints() { return _pool.getNumBadEndPoints(); }
AsyncServicePool implements com.bazaarvoice.ostrich.AsyncServicePool<S> { @Override public int getNumBadEndPoints() { return _pool.getNumBadEndPoints(); } }
AsyncServicePool implements com.bazaarvoice.ostrich.AsyncServicePool<S> { @Override public int getNumBadEndPoints() { return _pool.getNumBadEndPoints(); } AsyncServicePool(Ticker ticker, ServicePool<S> pool, boolean shutdownPoolOnClose,
                            ExecutorService executor, boolean shutdownExecutorOnClose, MetricRegistry metrics); }
AsyncServicePool implements com.bazaarvoice.ostrich.AsyncServicePool<S> { @Override public int getNumBadEndPoints() { return _pool.getNumBadEndPoints(); } AsyncServicePool(Ticker ticker, ServicePool<S> pool, boolean shutdownPoolOnClose,
                            ExecutorService executor, boolean shutdownExecutorOnClose, MetricRegistry metrics); @Override void close(); @Override Future<R> execute(final RetryPolicy retryPolicy, final ServiceCallback<S, R> callback); @Override Future<R> execute(final PartitionContext partitionContext, final RetryPolicy retryPolicy,
                                 final ServiceCallback<S, R> callback); @Override Collection<Future<R>> executeOnAll(RetryPolicy retry, ServiceCallback<S, R> callback); @Override Collection<Future<R>> executeOn(ServiceEndPointPredicate predicate, final RetryPolicy retry,
                                               final ServiceCallback<S, R> callback); @Override int getNumValidEndPoints(); @Override int getNumBadEndPoints(); }
AsyncServicePool implements com.bazaarvoice.ostrich.AsyncServicePool<S> { @Override public int getNumBadEndPoints() { return _pool.getNumBadEndPoints(); } AsyncServicePool(Ticker ticker, ServicePool<S> pool, boolean shutdownPoolOnClose,
                            ExecutorService executor, boolean shutdownExecutorOnClose, MetricRegistry metrics); @Override void close(); @Override Future<R> execute(final RetryPolicy retryPolicy, final ServiceCallback<S, R> callback); @Override Future<R> execute(final PartitionContext partitionContext, final RetryPolicy retryPolicy,
                                 final ServiceCallback<S, R> callback); @Override Collection<Future<R>> executeOnAll(RetryPolicy retry, ServiceCallback<S, R> callback); @Override Collection<Future<R>> executeOn(ServiceEndPointPredicate predicate, final RetryPolicy retry,
                                               final ServiceCallback<S, R> callback); @Override int getNumValidEndPoints(); @Override int getNumBadEndPoints();  }