/** * Clean up expired records. */ @Scheduled(initialDelayString = "${cas.authn.mfa.trusted.cleaner.startDelay:PT10S}", fixedDelayString = "${cas.authn.mfa.trusted.cleaner.repeatInterval:PT60S}") public void clean() { if (!trustedProperties.getCleaner().isEnabled()) { LOGGER.debug("[{}] is disabled. Expired trusted authentication records will not automatically be cleaned up by CAS", getClass().getName()); return; } try { LOGGER.debug("Proceeding to clean up expired trusted authentication records..."); SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); final LocalDate validDate = LocalDate.now().minus(trustedProperties.getExpiration(), DateTimeUtils.toChronoUnit(trustedProperties.getTimeUnit())); LOGGER.info("Expiring records that are on/before [{}]", validDate); this.storage.expire(validDate); } catch (final Exception e) { LOGGER.error(e.getMessage(), e); } }
@Override public void init(ServletConfig config) throws ServletException { super.init(config); try { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); configuration.load(); initializeProviders(); initializeActiviti(); addDeployTargets(); initExtras(); configuration.logFullConfig(); processEngine.getProcessEngineConfiguration().getJobExecutor().start(); LOGGER.info(Messages.ALM_SERVICE_ENV_INITIALIZED); } catch (Exception e) { LOGGER.error("Initialization error", e); throw new ServletException(e); } }
@Override public void init(final ServletConfig config) throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); // wait when condition is ready for initialization _timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { if (ComponentContext.getApplicationContext() != null) { _timer.cancel(); final TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.CLOUD_DB); try { ComponentContext.initComponentsLifeCycle(); } finally { txn.close(); } } } }, 0, 1000); }
@Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { if (backupService == null) { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); } String url = ((HttpServletRequest) request).getRequestURI(); if (isBackupFinishJsonUrl(url)) { ((HttpServletResponse) response).setHeader("Cache-Control", "private, max-age=0, no-cache"); ((HttpServletResponse) response).setDateHeader("Expires", 0); generateResponseForIsBackupFinishedAPI(response); return; } if (backupService.isBackingUp()) { ((HttpServletResponse) response).setHeader("Cache-Control", "private, max-age=0, no-cache"); ((HttpServletResponse) response).setDateHeader("Expires", 0); if (isAPIUrl(url) && !isMessagesJson(url)) { generateAPIResponse(request, response); } else { generateHTMLResponse(response); } } else { chain.doFilter(request, response); } }
@Override public void init(ServletConfig config) throws ServletException { LogUtils.initLog4j("log4j-cloud.xml"); SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); // wait when condition is ready for initialization _timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { if (ComponentContext.getApplicationContext() != null) { _timer.cancel(); TransactionLegacy txn = TransactionLegacy.open(TransactionLegacy.CLOUD_DB); try { ComponentContext.initComponentsLifeCycle(); } finally { txn.close(); } } } }, 0, 1000); }
@Override public void execute(final JobExecutionContext jobExecutionContext) throws JobExecutionException { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); try { logger.info("Beginning audit cleanup..."); decrementCounts(); } catch (final Exception e) { logger.error(e.getMessage(), e); } }
@Override public final void clean() { LOGGER.debug("Starting to clean expiring and previously used google authenticator tokens"); SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); cleanInternal(); LOGGER.info("Finished cleaning google authenticator tokens"); }
@Override public void execute(final JobExecutionContext jobExecutionContext) throws JobExecutionException { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); try { logger.info("Beginning ticket cleanup..."); final Collection<Ticket> ticketsToRemove = Collections2.filter(this.getTickets(), new Predicate<Ticket>() { @Override public boolean apply(@Nullable final Ticket ticket) { if (ticket.isExpired()) { if (ticket instanceof TicketGrantingTicket) { logger.debug("Cleaning up expired ticket-granting ticket [{}]", ticket.getId()); logoutManager.performLogout((TicketGrantingTicket) ticket); deleteTicket(ticket.getId()); } else if (ticket instanceof ServiceTicket) { logger.debug("Cleaning up expired service ticket [{}]", ticket.getId()); deleteTicket(ticket.getId()); } else { logger.warn("Unknown ticket type [{} found to clean", ticket.getClass().getSimpleName()); } return true; } return false; } }); logger.info("{} expired tickets found and removed.", ticketsToRemove.size()); } catch (final Exception e) { logger.error(e.getMessage(), e); } }
/** * Cette méthode init pourrait être déplacée dans une classe abstraite * * @see javax.servlet.GenericServlet#init() */ @Override public void init() throws ServletException { super.init(); // déclenchement de l'autowiring de la classe SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); // on ne peut pas faire d'autowire par constructeur dans ce cas là }
/** * Default Constructor that injects beans automatically. * * @param entityClass */ protected PersistentObjectIdResolver() { // As subclasses of this class are used in the resolver property of an // JsonIdentityInfo annotation, we cannot easily autowire components // (like the service for the current). For that reason, we use this // helper method to process the injection of the services SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
private void initAutowiredBeans() { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
public DistributionTargetDeserializer() { this(null); SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
/** * 解析微信类 * * @param clazz * @throws ServletException * @throws MultiWeixinEncodingAESKeyException * @throws IllegalAccessException * @throws InstantiationException */ private void parseWeixinClass(Class<?> clazz) throws ServletException { Weixin wx = clazz.getAnnotation(Weixin.class); String url = wx.value(); // 获取url对应的微信上下文,如果不存在,就新建一个 WeixinContext context = contextMapper.get(url); if (context == null) { context = new WeixinContext(); logger.debug("新建微信上下文(" + url + ")"); contextMapper.put(url, context); } // 获取微信上下文的url,如果为空,则赋值 if (StringUtil.isNull(context.getUrl())) { context.setUrl(url); } WeixinSetting setting = new WeixinSetting(); setting.setUrl(url); setting.setAppID(wx.appID()); setting.setAppSecret(wx.appSecret()); setting.setEncodingAESKey(wx.encodingAESKey()); setting.setToken(wx.token()); //配置微信参数 setContextParameter(context, setting); Object wxObj; try { // 生成微信对象实例 wxObj = clazz.newInstance(); } catch (InstantiationException | IllegalAccessException e) { throw new InitialWeixinConfigureException("实例化微信对象异常", e); } // 注入spring服务 SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(wxObj, getServletContext()); Method[] methods = clazz.getDeclaredMethods(); // 解析微信方法 for (Method method : methods) { if (WeixinMethod.hasWeixinAnnotationType(method)) { logger.debug("解析微信上下文(" + url + ")微信方法:" + method.getName()); parseWeixinMethod(context, method, wxObj); } } }
@Override public void execute(final JobExecutionContext jobExecutionContext) throws JobExecutionException { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); try { logger.info("Beginning ticket cleanup."); logger.debug("Attempting to acquire ticket cleanup lock."); if (!this.jpaLockingStrategy.acquire()) { logger.info("Could not obtain lock. Aborting cleanup."); return; } logger.debug("Acquired lock. Proceeding with cleanup."); logger.info("Beginning ticket cleanup..."); final Collection<Ticket> ticketsToRemove = Collections2.filter(this.getTickets(), new Predicate<Ticket>() { @Override public boolean apply(final Ticket ticket) { if (ticket.isExpired()) { if (ticket instanceof TicketGrantingTicket) { logger.debug("Cleaning up expired ticket-granting ticket [{}]", ticket.getId()); logoutManager.performLogout((TicketGrantingTicket) ticket); deleteTicket(ticket.getId()); } else if (ticket instanceof ServiceTicket) { logger.debug("Cleaning up expired service ticket [{}]", ticket.getId()); deleteTicket(ticket.getId()); } else { logger.warn("Unknown ticket type [{} found to clean", ticket.getClass().getSimpleName()); } return true; } return false; } }); logger.info("{} expired tickets found and removed.", ticketsToRemove.size()); } catch (final Exception e) { logger.error(e.getMessage(), e); } finally { logger.debug("Releasing ticket cleanup lock."); this.jpaLockingStrategy.release(); logger.info("Finished ticket cleanup."); } }
public ResendMessagesJob() { //First recover context of the job since it is created by Quartz, not Spring SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
@Override public void init() { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
@Override public void init() throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, this.getServletContext()); }
@Override public void init(final ServletConfig config) throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); s_keysMgr = _keysMgr; }
@Override public void init(final ServletConfig config) throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); }
public void init() { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
@Override public void init(ServletConfig config) throws ServletException { super.init(config); SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); }
@Override public final void init(ServletConfig config) throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); doInit(config); }
public MomoLayerSerializer(Class<MomoLayer> t) { super(t); SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
public MomoUserSerializer(Class<MomoUser> t) { super(t); SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
@Override public void init() throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, getServletContext()); }
@PostConstruct protected void init() { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); }
@PostConstruct protected void init() { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); logger.info("Injected " + periodicTableService); }
@Override public void init(ServletConfig config) throws ServletException { super.init(config); SpringBeanAutowiringSupport .processInjectionBasedOnServletContext(this, config.getServletContext()); }