为了账号安全,请及时绑定邮箱和手机立即绑定

Apache Geode CacheListenerAdapter无法正常工作

Apache Geode CacheListenerAdapter无法正常工作

POPMUISE 2021-04-28 21:17:30
我正在尝试为Apache Geode设置侦听器。我已经使用Web和JPA创建了一个Spring Boot项目。我创建了一个扩展CacheListenerAdapter的侦听器。在主类中,我在该区域上做了一个测试插入,并且监听器确实可以工作一次。应用程序启动后,将不处理事件。我确实尝试从“ gfsh”控制台以及另一个Java客户端插入。我包括我的侦听器,主类和日志。任何帮助将不胜感激。谢谢听众@Componentpublic class GeodeEventListener extends CacheListenerAdapter{public void afterCreate(EntryEvent event) {    System.out.println("Created: "+"Key: "+ event.getKey() +" New Value: "+ event.getNewValue());  }}主班@SpringBootApplicationpublic class GeodelistenerApplication {@Autowiredprivate AppConfig appConfig;@Autowiredprivate GeodeEventListener geodeEventListener;public static void main(String[] args) {    SpringApplication.run(GeodelistenerApplication.class, args);}@PostConstructpublic void init(){    ClientCache cache = new ClientCacheFactory()            .setPoolSubscriptionEnabled(true)            .addPoolLocator(appConfig.geodeHost , appConfig.geodePort)            .create();    ClientRegionFactory rf =     cache.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY);    rf.addCacheListener(geodeEventListener);    Region alert_status = rf.create(appConfig.region);      alert_status.put("test", "test"); }}由于您可能会错过来自侦听器的sysout,因此我将其添加到 Created:密钥:test新值:test。我收到此消息是由于从main函数插入的结果。但是侦听器无法捕获来自gfsh / java客户端的更多插入
查看完整描述

2 回答

  • 2 回答
  • 0 关注
  • 95 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信