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

Unregister all Functions from Apache Geode's FunctionService after test class/suite execution.

Browse Source
This commit is contained in:
John Blum
2021-09-16 22:52:42 -07:00
parent 61316b8631
commit 84442946bd
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/integration/IntegrationTestsSupport.java
View File

@@ -34,6 +34,7 @@ import java.util.WeakHashMap;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.stream.Collectors;
@@ -43,6 +44,7 @@ import org.junit.Before;
import org.apache.geode.DataSerializer;
import org.apache.geode.cache.CacheClosedException;
import org.apache.geode.cache.GemFireCache;
import org.apache.geode.cache.execute.FunctionService;
import org.apache.geode.distributed.Locator;
import org.apache.geode.internal.InternalDataSerializer;
import org.apache.geode.internal.cache.CacheLifecycleListener;
@@ -365,6 +367,20 @@ public abstract class IntegrationTestsSupport {
.forEach(InternalDataSerializer::unregister);
}
/**
* Unregisters all Apache Geode {@link Function Functions} from Apache Geode's {@link FunctionService}
* after test (class/suite) execution.
*
* @see org.apache.geode.cache.execute.Function
* @see org.apache.geode.cache.execute.FunctionService
*/
@AfterClass
public static void unregisterFunctions() {
CollectionUtils.nullSafeMap(FunctionService.getRegisteredFunctions())
.forEach((functionId, function) -> FunctionService.unregisterFunction(functionId));
}
/**
* Configures (eanbles) Apache Geode {@literal OQL} query debugging before test (case/method) execution.
*/