@Test(expectedExceptions = KSIClientException.class, expectedExceptionsMessageRegExp = "All subclients of HAService failed") public void testAllExtendersFail() throws Exception { ExtendingHAService haService = new ExtendingHAService.Builder().addServices(Arrays.asList( initFailingExtenderClient("Client failed. Client 1"), initFailingExtenderClient("Client failed. Client 2"), initFailingExtenderClient("Client failed. Client 3"))) .build(); haService.extend(new Date(), new Date()).getResult(); }
public Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime) throws KSIException { return extendingHAService.extend(aggregationTime, publicationTime); }
HAService implements KSISigningService, KSIExtendingService { public Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime) throws KSIException { return extendingHAService.extend(aggregationTime, publicationTime); } }
HAService implements KSISigningService, KSIExtendingService { public Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime) throws KSIException { return extendingHAService.extend(aggregationTime, publicationTime); } private  HAService(SigningHAService signingHAService, ExtendingHAService extendingHAService); }
HAService implements KSISigningService, KSIExtendingService { public Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime) throws KSIException { return extendingHAService.extend(aggregationTime, publicationTime); } private  HAService(SigningHAService signingHAService, ExtendingHAService extendingHAService); Future<AggregationResponse> sign(DataHash dataHash, Long level); Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime); void registerAggregatorConfigurationListener(ConfigurationListener<AggregatorConfiguration> listener); Future<AggregatorConfiguration> getAggregationConfiguration(); void registerExtenderConfigurationListener(ConfigurationListener<ExtenderConfiguration> listener); Future<ExtenderConfiguration> getExtendingConfiguration(); List<KSISigningService> getSubSigningServices(); List<KSIExtendingService> getSubExtendingServices(); void close(); @Override String toString(); }
HAService implements KSISigningService, KSIExtendingService { public Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime) throws KSIException { return extendingHAService.extend(aggregationTime, publicationTime); } private  HAService(SigningHAService signingHAService, ExtendingHAService extendingHAService); Future<AggregationResponse> sign(DataHash dataHash, Long level); Future<ExtensionResponse> extend(Date aggregationTime, Date publicationTime); void registerAggregatorConfigurationListener(ConfigurationListener<AggregatorConfiguration> listener); Future<AggregatorConfiguration> getAggregationConfiguration(); void registerExtenderConfigurationListener(ConfigurationListener<ExtenderConfiguration> listener); Future<ExtenderConfiguration> getExtendingConfiguration(); List<KSISigningService> getSubSigningServices(); List<KSIExtendingService> getSubExtendingServices(); void close(); @Override String toString();  }