Java Observer类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.jboss.seam.annotations.Observer类的典型用法代码示例。如果您正苦于以下问题：Java Observer类的具体用法？Java Observer怎么用？Java Observer使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Observer类属于org.jboss.seam.annotations包，在下文中一共展示了Observer类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: reloadConfigurationTimerEvent

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(EVENT_TYPE)
@Asynchronous
public void reloadConfigurationTimerEvent() {
    if (this.isActive.get()) {
        return;
    }

    if (!this.isActive.compareAndSet(false, true)) {
        return;
    }

    try {
        reloadConfiguration();
    } catch (Throwable ex) {
        log.error("Exception happened while reloading application configuration", ex);
    } finally {
        this.isActive.set(false);
    }
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:20，代码来源:OxTrustConfiguration.java

示例2: process

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(EVENT_TYPE)
@Asynchronous
public void process() {
    if (this.isActive.get()) {
        return;
    }

    if (!this.isActive.compareAndSet(false, true)) {
        return;
    }

    try {
        processInt();
    } finally {
        this.isActive.set(false);
    }
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:18，代码来源:LdapStatusTimer.java

示例3: reloadConfigurationTimerEvent

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(EVENT_TYPE)
@Asynchronous
public void reloadConfigurationTimerEvent() {
	if (this.isActive.get()) {
		return;
	}

	if (!this.isActive.compareAndSet(false, true)) {
		return;
	}

	try {
		reloadConfiguration();
	} catch (Throwable ex) {
		log.error("Exception happened while reloading application configuration", ex);
	} finally {
		this.isActive.set(false);
		this.lastFinishedTime = System.currentTimeMillis();
	}
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:21，代码来源:AppInitializer.java

示例4: recreateCentralLdapEntryManager

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(OxTrustConfiguration.LDAP_CENTRAL_CONFIGUARION_RELOAD_EVENT_TYPE)
  public void recreateCentralLdapEntryManager() {
  	// Backup current references to objects to allow shutdown properly
  	LdapEntryManager oldCentralLdapEntryManager = (LdapEntryManager) Component.getInstance(LDAP_CENTRAL_ENTRY_MANAGER_NAME);

  	// Recreate components
if ((oxTrustConfiguration.getLdapCentralConfiguration() != null) && oxTrustConfiguration.getApplicationConfiguration().isUpdateApplianceStatus()) {
	createConnectionProvider(oxTrustConfiguration.getLdapCentralConfiguration(), "centralLdapConfiguration", "centralConnectionProvider");
} else {
   	Contexts.getApplicationContext().remove("centralConnectionProvider");
}

      // Destroy old components
  	Contexts.getApplicationContext().remove(LDAP_CENTRAL_ENTRY_MANAGER_NAME);
  	
  	if (oldCentralLdapEntryManager != null) {
  		oldCentralLdapEntryManager.destroy();

      	log.debug("Destroyed {0}: {1}", LDAP_CENTRAL_ENTRY_MANAGER_NAME, oldCentralLdapEntryManager);
  	}
  }

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:22，代码来源:AppInitializer.java

示例5: init

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.postInitialization")
public void init() {
	log.info("Initializing CacheRefreshTimer...");
	this.isActive = new AtomicBoolean(false);
	this.lastFinishedTime = System.currentTimeMillis();
	
	// Clean up previous Inum cache
	CacheRefreshConfiguration cacheRefreshConfiguration = oxTrustConfiguration.getCacheRefreshConfiguration();
	if (cacheRefreshConfiguration != null) {
		String snapshotFolder = cacheRefreshConfiguration.getSnapshotFolder();
		if (StringHelper.isNotEmpty(snapshotFolder)) {
			String inumCachePath = getInumCachePath(cacheRefreshConfiguration);
			objectSerializationService.cleanup(inumCachePath);
		}
	}

	// Schedule to start cache refresh every 1 minute
	Events.instance().raiseTimedEvent(OxTrustConstants.EVENT_CACHE_REFRESH_TIMER, new TimerSchedule(1 * 60 * 1000L, 1 * 60 * 1000L));
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:20，代码来源:CacheRefreshTimer.java

示例6: schedulePayment

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.example.quartz.test.scheduleAndSave")
@Transactional
public QuartzTriggerHandle schedulePayment(Payment payment) 
{ 
    payment = entityManager.merge(payment);
    
    log.error("[#0] Processing cron payment #1", System.currentTimeMillis(), payment.getId());
    if (payment.getActive()) {
        BigDecimal balance = payment.getAccount().adjustBalance(payment.getAmount().negate());
        log.error(":: balance is now #0", balance);
        payment.setLastPaid(new Date());

    }

    return null;
}

开发者ID:windup，项目名称:windup-rulesets，代码行数:17，代码来源:TestPaymentProcessor.java

示例7: checkForMatchingCombinedTags

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(value = "checkForMatchingCombinedTags", create = false)
public boolean checkForMatchingCombinedTags() {
	for (final CombinedTag tag : combineOpponentBean.getOpponentTags()) {
		
		final Iterator<Combination> combinations = combinationsToTest.iterator();
		while (combinations.hasNext()) {
			final Combination combination = combinations.next();
			
			log.info("Comaring #0 and #1", combination.getCombinedTag(), tag);
			
			if (combination.getCombinedTag().equals(tag)) {
				score(combination, MatchType.DIRECT);
				
				combinations.remove();
				
				return true;
			}
		}
	}
	
	return false;
}

开发者ID:play4science，项目名称:gwap，代码行数:23，代码来源:CombinedTagBean.java

示例8: updateList

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("mit.betList.update")
public void updateList() {
	long start = System.currentTimeMillis();
	Query q = entityManager.createNamedQuery("bet.byPerson")
			.setParameter("person", person);
	betList = q.getResultList();
	paginationControl.setNumResults(betList.size());
	if (paginationControl.getNumPages() > 1) {
		q.setFirstResult(paginationControl.getFirstResult());
		q.setMaxResults(paginationControl.getResultsPerPage());
		betList = q.getResultList();
	}
	for (Bet bet : betList) {
		Resource resource = bet.getResource();
		if (resource instanceof Statement)
			((Statement) resource).getStatementTokens().size();
		if (bet.getCurrentMatch() == null || bet.getScore() == null)
			mitPokerScoring.updateScoreForBet(bet);
	}
	log.info("Created betList with #0 statements in #1ms",
			betList.size(), System.currentTimeMillis() - start);
	if (betList.size() > 0)
		selectedBet = betList.get(resultNumber);
}

开发者ID:play4science，项目名称:gwap，代码行数:25，代码来源:BetList.java

示例9: init

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.postInitialization")
public void init() {
    log.info("Initializing LdapStatusTimer");
    this.isActive = new AtomicBoolean(false);

    Events.instance().raiseTimedEvent(EVENT_TYPE, new TimerSchedule(DEFAULT_INTERVAL, DEFAULT_INTERVAL));
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:8，代码来源:LdapStatusTimer.java

示例10: init

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.postInitialization")
public void init() {
	// Schedule to run it every 120 seconds. First event will occur after 30
	// seconds
	Events.instance().raiseTimedEvent(OxTrustConstants.EVENT_METADATA_ENTITY_ID_UPDATE,
			new TimerSchedule(30 * 1000L, AppInitializer.CONNECTION_CHECKER_INTERVAL));
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:8，代码来源:EntityIDMonitoringService.java

示例11: initReloadTimer

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.postInitialization")
  public void initReloadTimer() {
this.isActive = new AtomicBoolean(false);
this.lastFinishedTime = System.currentTimeMillis();

Events.instance().raiseTimedEvent(EVENT_TYPE, new TimerSchedule(1 * 60 * 1000L, DEFAULT_INTERVAL * 1000L));
  }

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:8，代码来源:AppInitializer.java

示例12: recreateLdapEntryManager

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(OxTrustConfiguration.LDAP_CONFIGUARION_RELOAD_EVENT_TYPE)
  public void recreateLdapEntryManager() {
  	// Backup current references to objects to allow shutdown properly
  	LdapEntryManager oldLdapEntryManager = (LdapEntryManager) Component.getInstance(LDAP_ENTRY_MANAGER_NAME);

  	// Recreate components
createConnectionProvider(oxTrustConfiguration.getLdapConfiguration(), "localLdapConfiguration", "connectionProvider");

      // Destroy old components
  	Contexts.getApplicationContext().remove(LDAP_ENTRY_MANAGER_NAME);
  	oldLdapEntryManager.destroy();

  	log.debug("Destroyed {0}: {1}", LDAP_ENTRY_MANAGER_NAME, oldLdapEntryManager);
  }

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:15，代码来源:AppInitializer.java

示例13: process

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(OxTrustConstants.EVENT_CACHE_REFRESH_TIMER)
@Asynchronous
public void process() {
	if (this.isActive.get()) {
		log.debug("Another process is active");
		return;
	}

	CacheRefreshConfiguration cacheRefreshConfiguration = oxTrustConfiguration.getCacheRefreshConfiguration();

	if (!this.isActive.compareAndSet(false, true)) {
		log.debug("Failed to start process exclusively");
		return;
	}

	try {
		GluuAppliance currentAppliance = applianceService.getAppliance();
		if (!isStartCacheRefresh(cacheRefreshConfiguration, currentAppliance)) {
			log.debug("Starting conditions aren't reached");
			return;
		}

		processImpl(cacheRefreshConfiguration, currentAppliance);
		updateApplianceStatus(currentAppliance, System.currentTimeMillis());

		this.lastFinishedTime = System.currentTimeMillis();
	} catch (Throwable ex) {
		log.error("Exception happened while executing cache refresh synchronization", ex);
	} finally {
		log.debug("Allowing to run new process exclusively");
		this.isActive.set(false);
	}
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:34，代码来源:CacheRefreshTimer.java

示例14: observeTransactionSuccess

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.example.quartz.test.transactionSuccess")
@Transactional
public void observeTransactionSuccess(Payment payment)
{
    TransactionStatus.instance().setTransactionSucceded(true);
    TransactionStatus.instance().setId(payment.getId());
}

开发者ID:windup，项目名称:windup-rulesets，代码行数:8，代码来源:TestPaymentProcessor.java

示例15: observeTransactionCompletion

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.example.quartz.test.transactionCompletion")
@Transactional
public void observeTransactionCompletion(Payment payment)
{
    TransactionStatus.instance().setTransactionCompleted(true);
    TransactionStatus.instance().setId(payment.getId());
}

开发者ID:windup，项目名称:windup-rulesets，代码行数:8，代码来源:TestPaymentProcessor.java

示例16: checkAndAward

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer(Identity.EVENT_LOGIN_SUCCESSFUL)
public void checkAndAward() {
	resetCache();
	Badge b = getNextBestBadge();
	Badge lastBadge = null;
	while (b != lastBadge) {
		lastBadge = b;
		if (b.getWorth() <= 3) { // for location assignment
			if (getNrLocationAssignmentsForNextBadge() <= 0) {
				person = entityManager.find(Person.class, person.getId());
				person.getBadges().add(b);
				facesMessages.addFromResourceBundle("badge.reached");
				log.info("#0 reached next badge #1", person, b);
			}
		} else if (b.getWorth() == 4) {
			if (getNrBetsForNextBadge() <= 0) {
				person = entityManager.find(Person.class, person.getId());
				person.getBadges().add(b);
				facesMessages.addFromResourceBundle("badge.reached");
				log.info("#0 reached next badge #1", person, b);
			}
		} else if (b.getWorth() == 5) {
			HighscoreBean highscoreBean = (HighscoreBean) Component.getInstance("highscoreBean", true);
			List<HighscoreSet> highscores = highscoreBean.getHighscores();
			for (HighscoreSet highscoreSet : highscores) {
				if (highscoreSet.getGameType().getName().equals("mitRecognize")) {
					if (highscoreSet.getHighscoreAll().get(0).getPersonId().equals(person.getId())) {
						person.getBadges().add(b);
						facesMessages.addFromResourceBundle("badge.reached");
						log.info("#0 reached next badge #1", person, b);
					}
				}
			}
		}
		entityManager.flush();
		resetCache();
		b = getNextBestBadge();
	}
}

开发者ID:play4science，项目名称:gwap，代码行数:40，代码来源:BadgeBean.java

示例17: getBookings

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Factory
@Observer("bookingConfirmed")
public void getBookings()
{
   bookings = em.createQuery("select b from Booking b where b.user.username = :username order by b.checkinDate")
         .setParameter("username", user.getUsername())
         .getResultList();
}

开发者ID:windup，项目名称:windup，代码行数:9，代码来源:BookingListAction.java

示例18: initReloadTimer

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
@Observer("org.jboss.seam.postInitialization")
public void initReloadTimer() {
    final long delayBeforeFirstRun = 30 * 1000L;
    Events.instance().raiseTimedEvent(EVENT_TYPE, new TimerSchedule(delayBeforeFirstRun, DEFAULT_INTERVAL * 1000L));
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:6，代码来源:OxTrustConfiguration.java

示例19: clearOrganizationCache

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
/**
 * Remove organization from cache after receiving event that organization
 * were changed
 */
@Observer(OxTrustConstants.EVENT_CLEAR_ORGANIZATION)
public void clearOrganizationCache() throws Exception {
	log.debug("Removing organization from cache");
	cacheService.removeAll(OxTrustConstants.CACHE_APPLICATION_NAME);
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:10，代码来源:OrganizationService.java

示例20: clearAttributesCache

import org.jboss.seam.annotations.Observer; //导入依赖的package包/类
/**
 * Clear attributes cache after receiving event that attributes were changed
 */
@Observer(OxTrustConstants.EVENT_CLEAR_ATTRIBUTES)
public void clearAttributesCache() {
	log.debug("Removing attributes from cache");
	cacheService.removeAll(OxTrustConstants.CACHE_ATTRIBUTE_NAME);
}

开发者ID:AgarwalNeha1，项目名称:gluu，代码行数:9，代码来源:AttributeService.java

注：本文中的org.jboss.seam.annotations.Observer类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java IEditingSupportRegistry类代码示例发布时间：2022-05-22

Java OpVars类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18257|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9673|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8175|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8547|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8455|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9387|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8427|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7861|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8411|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Observer类代码示例

示例1: reloadConfigurationTimerEvent

示例2: process

示例3: reloadConfigurationTimerEvent

示例4: recreateCentralLdapEntryManager

示例5: init

示例6: schedulePayment

示例7: checkForMatchingCombinedTags

示例8: updateList

示例9: init

示例10: init

示例11: initReloadTimer

示例12: recreateLdapEntryManager

示例13: process

示例14: observeTransactionSuccess

示例15: observeTransactionCompletion

示例16: checkAndAward

示例17: getBookings

示例18: initReloadTimer

示例19: clearOrganizationCache

示例20: clearAttributesCache

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

CVE-2022-21509

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053