increase server connect timeout from 1s to 3s
[taxeditor.git] / eu.etaxonomy.taxeditor.cdmlib / src / main / java / eu / etaxonomy / cdm / api / application / CdmApplicationRemoteConfiguration.java
1 /**
2 * Copyright (C) 2014 EDIT
3 * European Distributed Institute of Taxonomy
4 * http://www.e-taxonomy.eu
5 *
6 * The contents of this file are subject to the Mozilla Public License Version 1.1
7 * See LICENSE.TXT at the top of this package for the full license terms.
8 */
9 package eu.etaxonomy.cdm.api.application;
10
11 import java.util.ArrayList;
12 import java.util.Arrays;
13 import java.util.HashMap;
14 import java.util.List;
15 import java.util.Map;
16
17 import org.apache.commons.lang3.StringUtils;
18 import org.apache.log4j.Logger;
19 import org.springframework.beans.BeansException;
20 import org.springframework.context.ApplicationContext;
21 import org.springframework.context.ApplicationContextAware;
22 import org.springframework.remoting.httpinvoker.CachingHttpInvokerProxyFactoryBean;
23 import org.springframework.remoting.httpinvoker.HttpComponentsHttpInvokerRequestExecutor;
24 import org.springframework.security.access.AccessDecisionVoter;
25 import org.springframework.security.authentication.AuthenticationProvider;
26 import org.springframework.security.authentication.ProviderManager;
27 import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
28 import org.springframework.security.authentication.dao.DaoAuthenticationProvider;
29 import org.springframework.security.authentication.dao.ReflectionSaltSource;
30 import org.springframework.security.authentication.encoding.Md5PasswordEncoder;
31 import org.springframework.security.core.Authentication;
32 import org.springframework.security.core.context.SecurityContext;
33 import org.springframework.security.core.context.SecurityContextHolder;
34 import org.springframework.stereotype.Component;
35 import org.springframework.transaction.PlatformTransactionManager;
36 import org.springframework.transaction.TransactionStatus;
37
38 import eu.etaxonomy.cdm.api.conversation.ConversationHolder;
39 import eu.etaxonomy.cdm.api.conversation.ConversationHolderMock;
40 import eu.etaxonomy.cdm.api.service.IAgentService;
41 import eu.etaxonomy.cdm.api.service.IAnnotationService;
42 import eu.etaxonomy.cdm.api.service.IClassificationService;
43 import eu.etaxonomy.cdm.api.service.ICollectionService;
44 import eu.etaxonomy.cdm.api.service.ICommonService;
45 import eu.etaxonomy.cdm.api.service.IDatabaseService;
46 import eu.etaxonomy.cdm.api.service.IDescriptionService;
47 import eu.etaxonomy.cdm.api.service.IDescriptiveDataSetService;
48 import eu.etaxonomy.cdm.api.service.IEntityConstraintViolationService;
49 import eu.etaxonomy.cdm.api.service.IEntityValidationService;
50 import eu.etaxonomy.cdm.api.service.IEventBaseService;
51 import eu.etaxonomy.cdm.api.service.IFeatureNodeService;
52 import eu.etaxonomy.cdm.api.service.IFeatureTreeService;
53 import eu.etaxonomy.cdm.api.service.IGrantedAuthorityService;
54 import eu.etaxonomy.cdm.api.service.IGroupService;
55 import eu.etaxonomy.cdm.api.service.IIdentificationKeyService;
56 import eu.etaxonomy.cdm.api.service.ILocationService;
57 import eu.etaxonomy.cdm.api.service.IMediaService;
58 import eu.etaxonomy.cdm.api.service.IMetadataService;
59 import eu.etaxonomy.cdm.api.service.INameService;
60 import eu.etaxonomy.cdm.api.service.IOccurrenceService;
61 import eu.etaxonomy.cdm.api.service.IPolytomousKeyNodeService;
62 import eu.etaxonomy.cdm.api.service.IPolytomousKeyService;
63 import eu.etaxonomy.cdm.api.service.IPreferenceService;
64 import eu.etaxonomy.cdm.api.service.IProgressMonitorService;
65 import eu.etaxonomy.cdm.api.service.IReferenceService;
66 import eu.etaxonomy.cdm.api.service.IRegistrationService;
67 import eu.etaxonomy.cdm.api.service.IRightsService;
68 import eu.etaxonomy.cdm.api.service.ITaxonNodeService;
69 import eu.etaxonomy.cdm.api.service.ITaxonService;
70 import eu.etaxonomy.cdm.api.service.ITermNodeService;
71 import eu.etaxonomy.cdm.api.service.ITermService;
72 import eu.etaxonomy.cdm.api.service.ITermTreeService;
73 import eu.etaxonomy.cdm.api.service.ITestService;
74 import eu.etaxonomy.cdm.api.service.IUserService;
75 import eu.etaxonomy.cdm.api.service.IVocabularyService;
76 import eu.etaxonomy.cdm.api.service.longrunningService.ILongRunningTasksService;
77 import eu.etaxonomy.cdm.api.service.media.MediaInfoFactory;
78 import eu.etaxonomy.cdm.api.service.molecular.IAmplificationService;
79 import eu.etaxonomy.cdm.api.service.molecular.IPrimerService;
80 import eu.etaxonomy.cdm.api.service.molecular.ISequenceService;
81 import eu.etaxonomy.cdm.ext.geo.IEditGeoService;
82 import eu.etaxonomy.cdm.io.service.IIOService;
83 import eu.etaxonomy.cdm.persistence.permission.CdmPermissionEvaluator;
84 import eu.etaxonomy.cdm.persistence.permission.ICdmPermissionEvaluator;
85 import eu.etaxonomy.cdm.persistence.permission.UnanimousBasedUnrevokable;
86 import eu.etaxonomy.cdm.persistence.permission.voter.DescriptionBaseVoter;
87 import eu.etaxonomy.cdm.persistence.permission.voter.DescriptionElementVoter;
88 import eu.etaxonomy.cdm.persistence.permission.voter.GrantAlwaysVoter;
89 import eu.etaxonomy.cdm.persistence.permission.voter.TaxonBaseVoter;
90 import eu.etaxonomy.cdm.persistence.permission.voter.TaxonNodeVoter;
91 import eu.etaxonomy.taxeditor.remoting.source.CdmRemoteSource;
92 import eu.etaxonomy.taxeditor.remoting.source.ICdmRemoteSource;
93 import eu.etaxonomy.taxeditor.service.AuthenticatingHttpInvokerRequestExecutor;
94 import eu.etaxonomy.taxeditor.service.CachedCommonServiceImpl;
95 import eu.etaxonomy.taxeditor.service.ICachedCommonService;
96 import eu.etaxonomy.taxeditor.service.RemoteInvocationTermCacher;
97 import eu.etaxonomy.taxeditor.session.CdmEntitySessionManager;
98 import eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager;
99
100 /**
101 * CDM Application Configuration class which manages the configuration for remoting
102 * clients
103 */
104 @Component
105 // TODO split into CdmRepository and proper @Configuration class
106 public class CdmApplicationRemoteConfiguration implements ICdmRepository, ApplicationContextAware {
107
108 @SuppressWarnings("unused")
109 private static final Logger logger = Logger.getLogger(CdmApplicationRemoteConfiguration.class);
110
111 /**
112 * Timeout for service lookup etc. This timeout (milliseconds) should be more
113 * strict than {@link #HTTP_READ_TIMEOUT} to avoid connecting to
114 * cdm servers when the network quality is too bad.
115 * Note AM: IMO we should not be to strict, sometimes services do not respond too fast
116 * during the first call (e.g. test server), therefore I put this up from 1 to 3 sec.
117 * Better we should inform the user that the connection might be of low quality
118 * instead of making the connection completely unavailable.
119 */
120 public static final int HTTP_READ_TIMEOUT_MIN = 3000; // 3 seconds
121
122 /**
123 * Timeout for normal operation (milliseconds)
124 *
125 * Infinite time out (value = 0) can cause the application to be stuck in
126 * SocketInputStream.read(), Therefore it makes sense to specify a definite
127 * timeout which is high enough to allow for longer operations
128 * <p>
129 * The application should be usable in networks with low connection quality,
130 * e.g.: from cuba where the throughput rate is low (<= ISDN speed, 64 kbit)
131 * and a packet delay of <200 ms.
132 *
133 */
134 public static final int HTTP_READ_TIMEOUT = 10 * 60 * 1000;
135
136 protected ApplicationContext applicationContext;
137
138 private ICdmRemoteSource remoteSource;
139
140 //TODO should be something like Map<Class<IService>, IService>, but we have no common service base interface yet
141 private Map<Class<?>, Object> serviceMap = new HashMap<>();
142
143 private ICdmEntitySessionManager cdmEntitySessionManager;
144
145 private CdmPermissionEvaluator cdmPermissionEvaluator;
146
147 private ProviderManager authenticationManager;
148
149 private ICachedCommonService cachedCommonService;
150
151 static {
152 // The Taxeditor is multithreaded, the same authentication should be used
153 // in all threads
154 SecurityContextHolder.setStrategyName(SecurityContextHolder.MODE_GLOBAL);
155 }
156
157 public CdmApplicationRemoteConfiguration() {}
158
159 public CdmApplicationRemoteConfiguration(ICdmRemoteSource remoteSource) {
160 this.remoteSource = remoteSource;
161 }
162
163 public void setRemoteSource(ICdmRemoteSource remoteSource) {
164 this.remoteSource = remoteSource;
165 }
166
167 private Object getService(Class<?/* extends IService*/> clazz, String serviceSuffix, HttpComponentsHttpInvokerRequestExecutor executor) {
168 if(serviceMap.containsKey(clazz)) {
169 return serviceMap.get(clazz);
170 }
171 Object service = getService(clazz, serviceSuffix, remoteSource, executor);
172 serviceMap.put(clazz, service);
173 return service;
174 }
175
176 public static Object getService(Class<?> clazz,
177 String serviceSuffix,
178 ICdmRemoteSource remoteSource,
179 HttpComponentsHttpInvokerRequestExecutor executor) {
180
181 String baseUrl;
182 String protocol = remoteSource.getPort() == 443 ? "https" : "http";
183
184 String contextPath = (remoteSource instanceof CdmRemoteSource)? ((CdmRemoteSource)remoteSource).getContextPath() : "";
185 if(StringUtils.isBlank(contextPath)) {
186 baseUrl = protocol + "://" + remoteSource.getServer() + ":" + String.valueOf(remoteSource.getPort());
187 } else {
188 baseUrl = protocol + "://" + remoteSource.getServer() + ":" + String.valueOf(remoteSource.getPort()) + "/" + contextPath;
189 }
190 CachingHttpInvokerProxyFactoryBean proxyFactory = new CachingHttpInvokerProxyFactoryBean();
191 proxyFactory.setServiceInterface(clazz);
192 proxyFactory.setServiceUrl(baseUrl + serviceSuffix);
193 if(executor != null) {
194 executor.setReadTimeout(HTTP_READ_TIMEOUT);
195 executor.setConnectionRequestTimeout(HTTP_READ_TIMEOUT);
196 proxyFactory.setHttpInvokerRequestExecutor(executor);
197 }
198 if(ITermService.class.isAssignableFrom(clazz)){
199 proxyFactory.setRemoteInvocationTermCacher(new RemoteInvocationTermCacher());
200 }
201 proxyFactory.afterPropertiesSet();
202 return proxyFactory.getObject();
203 }
204
205 // ****************************** APPLICATION CONTEXT *************************************************/
206
207 @Override
208 public void setApplicationContext(ApplicationContext applicationContext) throws BeansException{
209 this.applicationContext = applicationContext;
210 }
211
212 @Override
213 public PlatformTransactionManager getTransactionManager() throws UnsupportedOperationException {
214 throw new UnsupportedOperationException("getTransactionManager is not implemented for CdmApplicationRemoteConfiguration");
215 }
216
217 public IEditGeoService getEditGeoService() {
218 return (IEditGeoService) getService(IEditGeoService.class, "/remoting/editgeo.service", new AuthenticatingHttpInvokerRequestExecutor());
219 }
220
221 public ICachedCommonService getCachedCommonService(){
222 if(cachedCommonService == null) {
223 cachedCommonService = new CachedCommonServiceImpl();
224 }
225 return cachedCommonService;
226 }
227
228 public ICdmEntitySessionManager getCdmEntitySessionManager() {
229 if(cdmEntitySessionManager == null) {
230 cdmEntitySessionManager = new CdmEntitySessionManager();
231 }
232 return cdmEntitySessionManager;
233 }
234
235 // ****************************** GETTER *************************************************/
236
237 @Override
238 public final Object getBean(String name){
239 throw new UnsupportedOperationException("getBean is not implemented for CdmApplicationRemoteConfiguration");
240 }
241
242 @Override
243 public IAgentService getAgentService(){
244 return (IAgentService) getService(IAgentService.class, "/remoting/agent.service", new AuthenticatingHttpInvokerRequestExecutor());
245 }
246
247 @Override
248 public IAnnotationService getAnnotationService(){
249 return (IAnnotationService) getService(IAnnotationService.class, "/remoting/annotation.service", new AuthenticatingHttpInvokerRequestExecutor());
250 }
251
252 @Override
253 public IDatabaseService getDatabaseService(){
254 return (IDatabaseService) getService(IDatabaseService.class, "/remoting/database.service", new AuthenticatingHttpInvokerRequestExecutor());
255 }
256
257 @Override
258 public INameService getNameService(){
259 return (INameService) getService(INameService.class, "/remoting/name.service", new AuthenticatingHttpInvokerRequestExecutor());
260 }
261
262 @Override
263 public IReferenceService getReferenceService(){
264 return (IReferenceService) getService(IReferenceService.class, "/remoting/reference.service", new AuthenticatingHttpInvokerRequestExecutor());
265 }
266
267 @Override
268 public ITaxonService getTaxonService(){
269 return (ITaxonService) getService(ITaxonService.class, "/remoting/taxon.service", new AuthenticatingHttpInvokerRequestExecutor());
270 }
271
272 @Override
273 public IClassificationService getClassificationService(){
274 return (IClassificationService) getService(IClassificationService.class, "/remoting/classification.service", new AuthenticatingHttpInvokerRequestExecutor());
275 }
276
277 @Override
278 public ITaxonNodeService getTaxonNodeService(){
279 return (ITaxonNodeService) getService(ITaxonNodeService.class, "/remoting/taxonnode.service", new AuthenticatingHttpInvokerRequestExecutor());
280 }
281
282 @Override
283 public IDescriptionService getDescriptionService(){
284 return (IDescriptionService) getService(IDescriptionService.class, "/remoting/description.service", new AuthenticatingHttpInvokerRequestExecutor());
285 }
286
287 @Override
288 public IOccurrenceService getOccurrenceService(){
289 return (IOccurrenceService) getService(IOccurrenceService.class, "/remoting/occurrence.service", new AuthenticatingHttpInvokerRequestExecutor());
290 }
291
292 @Override
293 public IPrimerService getPrimerService(){
294 return (IPrimerService) getService(IPrimerService.class, "/remoting/primer.service", new AuthenticatingHttpInvokerRequestExecutor());
295 }
296
297 @Override
298 public IAmplificationService getAmplificationService(){
299 return (IAmplificationService) getService(IAmplificationService.class, "/remoting/amplification.service", new AuthenticatingHttpInvokerRequestExecutor());
300 }
301
302 @Override
303 public ISequenceService getSequenceService(){
304 return (ISequenceService) getService(ISequenceService.class, "/remoting/sequence.service", new AuthenticatingHttpInvokerRequestExecutor());
305 }
306
307 @Override
308 public IEventBaseService getEventBaseService() {
309 return (IEventBaseService) getService(IEventBaseService.class, "/remoting/eventbase.service", new AuthenticatingHttpInvokerRequestExecutor());
310 }
311
312 @Override
313 public IMediaService getMediaService(){
314 return (IMediaService) getService(IMediaService.class, "/remoting/media.service", new AuthenticatingHttpInvokerRequestExecutor());
315 }
316
317 @Override
318 public ITermService getTermService(){
319 return (ITermService) getService(ITermService.class, "/remoting/term.service", new AuthenticatingHttpInvokerRequestExecutor());
320 }
321
322 @Override
323 public IRightsService getRightsService(){
324 return (IRightsService) getService(IRightsService.class, "/remoting/rights.service", new AuthenticatingHttpInvokerRequestExecutor());
325 }
326
327 @Override
328 public ICommonService getCommonService(){
329 return (ICommonService) getService(ICommonService.class, "/remoting/common.service", new AuthenticatingHttpInvokerRequestExecutor());
330 }
331
332 @Override
333 public ILocationService getLocationService(){
334 return (ILocationService) getService(ILocationService.class, "/remoting/location.service", new AuthenticatingHttpInvokerRequestExecutor());
335 }
336
337 @Override
338 public IUserService getUserService(){
339 return (IUserService) getService(IUserService.class, "/remoting-public/user.service", new AuthenticatingHttpInvokerRequestExecutor());
340 }
341
342 public static IUserService getUserService(ICdmRemoteSource remoteSource) {
343 return (IUserService) getService(IUserService.class, "/remoting-public/user.service", remoteSource, new HttpComponentsHttpInvokerRequestExecutor());
344 }
345
346 @Override
347 public IMetadataService getMetadataService() {
348 return (IMetadataService) getService(IMetadataService.class, "/remoting-public/metadata.service", new HttpComponentsHttpInvokerRequestExecutor());
349 }
350
351 public static IMetadataService getMetadataService(ICdmRemoteSource remoteSource) {
352 return (IMetadataService) getService(IMetadataService.class, "/remoting-public/metadata.service", remoteSource, new HttpComponentsHttpInvokerRequestExecutor());
353 }
354
355 @Override
356 public IGrantedAuthorityService getGrantedAuthorityService(){
357 return (IGrantedAuthorityService) getService(IGrantedAuthorityService.class, "/remoting/grantedauthority.service", new AuthenticatingHttpInvokerRequestExecutor());
358 }
359
360 @Override
361 public ProviderManager getAuthenticationManager(){
362 if(authenticationManager == null) {
363 authenticationManager = getAuthenticationManager(getUserService());
364 }
365 return authenticationManager;
366 }
367
368 public static ProviderManager getAuthenticationManager(IUserService userService) {
369 Md5PasswordEncoder passwordEncoder = new Md5PasswordEncoder();
370 ReflectionSaltSource saltSource = new ReflectionSaltSource();
371 saltSource.setUserPropertyToUse("getUsername");
372
373 DaoAuthenticationProvider daoAuthenticationProvider = new DaoAuthenticationProvider();
374 daoAuthenticationProvider.setUserDetailsService(userService);
375 daoAuthenticationProvider.setSaltSource(saltSource);
376 daoAuthenticationProvider.setPasswordEncoder(passwordEncoder);
377
378 return new ProviderManager(Arrays.asList((AuthenticationProvider)daoAuthenticationProvider));
379 }
380
381
382 @Override
383 public ConversationHolder NewConversation() {
384 return new ConversationHolderMock();
385 }
386
387 @Override
388 public ICollectionService getCollectionService(){
389 return (ICollectionService) getService(ICollectionService.class, "/remoting/collection.service", new AuthenticatingHttpInvokerRequestExecutor());
390 }
391
392 @Override
393 public IFeatureTreeService getFeatureTreeService(){
394 return (IFeatureTreeService) getService(IFeatureTreeService.class, "/remoting/featuretree.service", new AuthenticatingHttpInvokerRequestExecutor());
395 }
396 @Override
397 public ITermTreeService getTermTreeService() {
398 return (ITermTreeService) getService(ITermTreeService.class, "/remoting/termtree.service", new AuthenticatingHttpInvokerRequestExecutor());
399 }
400
401 @Override
402 public IFeatureNodeService getFeatureNodeService(){
403 return (IFeatureNodeService) getService(IFeatureNodeService.class, "/remoting/featurenode.service", new AuthenticatingHttpInvokerRequestExecutor());
404 }
405
406 @Override
407 public ITermNodeService getTermNodeService() {
408 return (ITermNodeService) getService(ITermNodeService.class, "/remoting/termnode.service", new AuthenticatingHttpInvokerRequestExecutor());
409 }
410
411 @Override
412 public IVocabularyService getVocabularyService(){
413 return (IVocabularyService) getService(IVocabularyService.class, "/remoting/vocabulary.service", new AuthenticatingHttpInvokerRequestExecutor());
414 }
415
416 @Override
417 public IIdentificationKeyService getIdentificationKeyService(){
418 return (IIdentificationKeyService) getService(IIdentificationKeyService.class, "/remoting/identificationkey.service", new AuthenticatingHttpInvokerRequestExecutor());
419 }
420
421 @Override
422 public IPolytomousKeyService getPolytomousKeyService(){
423 return (IPolytomousKeyService) getService(IPolytomousKeyService.class, "/remoting/polytomouskey.service", new AuthenticatingHttpInvokerRequestExecutor());
424 }
425
426 @Override
427 public IPolytomousKeyNodeService getPolytomousKeyNodeService(){
428 return (IPolytomousKeyNodeService) getService(IPolytomousKeyNodeService.class, "/remoting/polytomouskeynode.service", new AuthenticatingHttpInvokerRequestExecutor());
429 }
430
431 @Override
432 public IProgressMonitorService getProgressMonitorService() {
433 return (IProgressMonitorService) getService(IProgressMonitorService.class, "/remoting/progressmonitor.service", new AuthenticatingHttpInvokerRequestExecutor());
434 }
435
436 @Override
437 public IDescriptiveDataSetService getDescriptiveDataSetService(){
438 return (IDescriptiveDataSetService) getService(IDescriptiveDataSetService.class, "/remoting/descriptivedataset.service", new AuthenticatingHttpInvokerRequestExecutor());
439 }
440
441 @Override
442 public IRegistrationService getRegistrationService() {
443 return (IRegistrationService) getService(IRegistrationService.class, "/remoting/registration.service", new AuthenticatingHttpInvokerRequestExecutor());
444 }
445
446 @Override
447 public IGroupService getGroupService(){
448 return (IGroupService) getService(IGroupService.class, "/remoting/group.service", new AuthenticatingHttpInvokerRequestExecutor());
449 }
450
451 @Override
452 public IPreferenceService getPreferenceService(){
453 return (IPreferenceService) getService(IPreferenceService.class, "/remoting/preference.service", new AuthenticatingHttpInvokerRequestExecutor());
454 }
455
456 @Override
457 public IEntityValidationService getEntityValidationService(){
458 return (IEntityValidationService) getService(IEntityValidationService.class, "/remoting/entityvalidation.service", new AuthenticatingHttpInvokerRequestExecutor());
459 }
460
461 @Override
462 public IEntityConstraintViolationService getEntityConstraintViolationService(){
463 return (IEntityConstraintViolationService) getService(IEntityConstraintViolationService.class, "/remoting/entityconstraintviolation.service", new AuthenticatingHttpInvokerRequestExecutor());
464 }
465
466 @Override
467 public MediaInfoFactory getMediaInfoFactory(){ // TODO use interface
468 return (MediaInfoFactory) getService(MediaInfoFactory.class, "/remoting/mediainfofactory.service", new AuthenticatingHttpInvokerRequestExecutor());
469 }
470
471 @Override
472 public ICdmPermissionEvaluator getPermissionEvaluator(){
473
474 if(cdmPermissionEvaluator != null) {
475 return cdmPermissionEvaluator;
476 }
477 List<AccessDecisionVoter<? extends Object>> decisionVoters = new ArrayList<>();
478 decisionVoters.add(new GrantAlwaysVoter());
479 decisionVoters.add(new TaxonNodeVoter());
480 decisionVoters.add(new TaxonBaseVoter());
481 decisionVoters.add(new DescriptionBaseVoter());
482 decisionVoters.add(new DescriptionElementVoter());
483 UnanimousBasedUnrevokable accessDecisionManager = new UnanimousBasedUnrevokable(decisionVoters);
484
485 cdmPermissionEvaluator = new CdmPermissionEvaluator();
486 cdmPermissionEvaluator.setAccessDecisionManager(accessDecisionManager);
487
488 return cdmPermissionEvaluator;
489 }
490
491 @Override
492 public TransactionStatus startTransaction() throws UnsupportedOperationException {
493 throw new UnsupportedOperationException("startTransaction is not implemented for CdmApplicationRemoteConfiguration");
494 }
495
496 @Override
497 public TransactionStatus startTransaction(Boolean readOnly) throws UnsupportedOperationException {
498 throw new UnsupportedOperationException("startTransaction is not implemented for CdmApplicationRemoteConfiguration");
499 }
500
501 @Override
502 public void commitTransaction(TransactionStatus txStatus) throws UnsupportedOperationException {
503 throw new UnsupportedOperationException("commitTransaction is not implemented for CdmApplicationRemoteConfiguration");
504 }
505
506 @Override
507 public void rollbackTransaction(TransactionStatus arg0) {
508 throw new UnsupportedOperationException("rollbackTransaction is not implemented for CdmApplicationRemoteConfiguration");
509 }
510
511 @Override
512 public void authenticate(String username, String password){
513 UsernamePasswordAuthenticationToken tokenForUser = new UsernamePasswordAuthenticationToken(username, password);
514 Authentication authentication = this.getAuthenticationManager().authenticate(tokenForUser);
515 SecurityContext context = SecurityContextHolder.getContext();
516 context.setAuthentication(authentication);
517 }
518
519 public IIOService getIOService() {
520 return (IIOService) getService(IIOService.class, "/remoting/io.service", new AuthenticatingHttpInvokerRequestExecutor());
521 }
522
523 @Override
524 public ILongRunningTasksService getLongRunningTasksService() {
525 return (ILongRunningTasksService) getService(ILongRunningTasksService.class, "/remoting/longrunningtasks.service", new AuthenticatingHttpInvokerRequestExecutor());
526 }
527
528 public ITestService getTestService() {
529 return (ITestService) getService(ITestService.class, "/remoting/test.service", new AuthenticatingHttpInvokerRequestExecutor());
530 }
531 }