@Test public void testBadBlobId() throws Exception { router = getNonBlockingRouter(); setOperationParams(CHUNK_SIZE, new GetBlobOptionsBuilder().build()); String[] badBlobIds = {"", "abc", "123", "invalid_id", "[],/-"}; for (String blobId : badBlobIds) { for (GetBlobOptions.OperationType opType : GetBlobOptions.OperationType.values()) { getBlobAndAssertFailure(blobId, new GetBlobOptionsBuilder().operationType(opType).build(), RouterErrorCode.InvalidBlobId); } } router.close(); }
void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } GetManager(ClusterMap clusterMap, ResponseHandler responseHandler, RouterConfig routerConfig,
      NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, KeyManagementService kms,
      CryptoService cryptoService, CryptoJobHandler cryptoJobHandler, Time time); }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } GetManager(ClusterMap clusterMap, ResponseHandler responseHandler, RouterConfig routerConfig,
      NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, KeyManagementService kms,
      CryptoService cryptoService, CryptoJobHandler cryptoJobHandler, Time time);  }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } GetManager(ClusterMap clusterMap, ResponseHandler responseHandler, RouterConfig routerConfig,
      NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, KeyManagementService kms,
      CryptoService cryptoService, CryptoJobHandler cryptoJobHandler, Time time);   }