Skip to content

Commit

Permalink
DATAGEODE-139 - Adapt to @eventlistener API behavior changes in Sprin…
Browse files Browse the repository at this point in the history
…g Framework 5.1.0.RC2.
  • Loading branch information
jxblum committed Aug 18, 2018
1 parent c76e001 commit b2f10c5
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 2 deletions.
Expand Up @@ -54,6 +54,7 @@ public class EnableCompressionConfigurationUnitTests {
@After
public void tearDown() {
Optional.ofNullable(this.applicationContext).ifPresent(ConfigurableApplicationContext::close);
//GemFireMockObjectsSupport.destroy();
}

private ConfigurableApplicationContext newApplicationContext(Class<?>... annotatedClasses) {
Expand All @@ -75,6 +76,7 @@ public void enableCompressionForAllRegions() {
this.applicationContext = newApplicationContext(EnableCompressionForAllRegionsConfiguration.class);

assertThat(this.applicationContext).isNotNull();
assertThat(this.applicationContext.containsBean("ExampleClientRegion")).isFalse();

Compressor compressor = this.applicationContext.getBean(Compressor.class);

Expand All @@ -98,6 +100,7 @@ public void enableCompressionForSelectRegions() {
Compressor compressor = this.applicationContext.getBean("MockCompressor", Compressor.class);

assertThat(compressor).isNotNull();
assertThat(compressor).isNotInstanceOf(SnappyCompressor.class);
assertThat(this.applicationContext.containsBean(SNAPPY_COMPRESSOR_BEAN_NAME)).isTrue();

Arrays.asList("People", "ExampleClientRegion").forEach(regionName -> {
Expand Down
Expand Up @@ -19,6 +19,7 @@
import java.lang.annotation.Annotation;

import org.springframework.beans.factory.config.BeanPostProcessor;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.ImportAware;
Expand Down Expand Up @@ -46,7 +47,7 @@
*/
@SuppressWarnings("unused")
@Configuration
public class GemFireMockObjectsConfiguration implements ImportAware {
public class GemFireMockObjectsConfiguration implements ApplicationListener<ContextClosedEvent>, ImportAware {

private boolean useSingletonCache = false;

Expand Down Expand Up @@ -91,7 +92,12 @@ public BeanPostProcessor mockGemFireObjectsBeanPostProcessor() {
}

@EventListener
public void releaseMockResources(ContextClosedEvent event) {
public void releaseMockObjectResources(ContextClosedEvent event) {
GemFireMockObjectsSupport.destroy();
}

@Override
public void onApplicationEvent(ContextClosedEvent event) {
releaseMockObjectResources(event);
}
}

0 comments on commit b2f10c5

Please sign in to comment.