@Test public void testFailureOnAllConnects() throws Exception { requestAndResultsList.clear(); requestAndResultsList.add(new RequestAndResult(chunkSize * 5)); mockSelectorState.set(MockSelectorState.ThrowExceptionOnConnect); Exception expectedException = new RouterException("", RouterErrorCode.OperationTimedOut); submitPutsAndAssertFailure(expectedException, false, true, true); Assert.assertTrue("Router should not be closed", router.isOpen()); assertCloseCleanup(); }
boolean isOpen() { return isOpen.get(); }
PutManager { boolean isOpen() { return isOpen.get(); } }
PutManager { boolean isOpen() { return isOpen.get(); } PutManager(ClusterMap clusterMap, ResponseHandler responseHandler, NotificationSystem notificationSystem,
      RouterConfig routerConfig, NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, String suffix,
      KeyManagementService kms, CryptoService cryptoService, CryptoJobHandler cryptoJobHandler,
      AccountService accountService, Time time, String defaultPartitionClass); }
PutManager { boolean isOpen() { return isOpen.get(); } PutManager(ClusterMap clusterMap, ResponseHandler responseHandler, NotificationSystem notificationSystem,
      RouterConfig routerConfig, NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, String suffix,
      KeyManagementService kms, CryptoService cryptoService, CryptoJobHandler cryptoJobHandler,
      AccountService accountService, Time time, String defaultPartitionClass);  }
PutManager { boolean isOpen() { return isOpen.get(); } PutManager(ClusterMap clusterMap, ResponseHandler responseHandler, NotificationSystem notificationSystem,
      RouterConfig routerConfig, NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, String suffix,
      KeyManagementService kms, CryptoService cryptoService, CryptoJobHandler cryptoJobHandler,
      AccountService accountService, Time time, String defaultPartitionClass);   }