Spring/spring-data-gemfire
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SGF-682 - Beans proxied by the Spring container with declared CQs are not registered and triggered.

Browse Source
This commit is contained in:
John Blum
2017-10-23 11:05:11 -07:00
parent 77c1cf3e4d
commit 456a592ff1
2 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/springframework/data/gemfire/config/annotation/ContinuousQueryConfiguration.java
View File

@@ -124,8 +124,7 @@ public class ContinuousQueryConfiguration extends AbstractAnnotationConfigSuppor
}
else if (isApplicationBean(bean, beanName)) {
//Object resolvedBean = resolveTargetObject(bean);
Object resolvedBean = bean;
Object resolvedBean = resolveTargetObject(bean);
List<ContinuousQueryDefinition> definitions = stream(resolvedBean.getClass().getMethods())
.filter(method -> method.isAnnotationPresent(ContinuousQuery.class))
@@ -151,7 +150,7 @@ public class ContinuousQueryConfiguration extends AbstractAnnotationConfigSuppor
return Optional.ofNullable(bean)
//.filter(this::isNotProxy)
//.map(this::resolveTargetObject)
.map(this::resolveTargetObject)
.map(Object::getClass)
.map(Class::getPackage)
.map(Package::getName)