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

Refactor the ClientCacheFactoryBean class.

Browse Source 
Apply Spring @NonNull and @Nullable annotations appropriately.

Remove static import on java.util.stream.StreamSupport.
This commit is contained in:
John Blum
2021-07-14 12:03:57 -07:00
parent e23540822f
commit b2e38904bb
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-data-geode/src/main/java/org/springframework/data/gemfire/client/ClientCacheFactoryBean.java
View File

@@ -15,7 +15,6 @@
*/
package org.springframework.data.gemfire.client;
import static java.util.stream.StreamSupport.stream;
import static org.springframework.data.gemfire.util.CollectionUtils.nullSafeCollection;
import java.net.InetSocketAddress;
@@ -155,7 +154,8 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* @see #applyClientCacheConfigurers(Iterable)
*/
protected void applyClientCacheConfigurers(ClientCacheConfigurer... clientCacheConfigurers) {
applyClientCacheConfigurers(Arrays.asList(ArrayUtils.nullSafeArray(clientCacheConfigurers, ClientCacheConfigurer.class)));
applyClientCacheConfigurers(Arrays.asList(ArrayUtils.nullSafeArray(clientCacheConfigurers,
ClientCacheConfigurer.class)));
}
/**
@@ -320,7 +320,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
Iterable<InetSocketAddress> servers = pool.getServers(getServers().toInetSocketAddresses());
stream(servers.spliterator(), false).forEach(server -> {
StreamSupport.stream(servers.spliterator(), false).forEach(server -> {
clientCacheFactory.addPoolServer(server.getHostName(), server.getPort());
noServers.set(false);
});
@@ -330,7 +330,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
Iterable<InetSocketAddress> locators = pool.getLocators(getLocators().toInetSocketAddresses());
stream(locators.spliterator(), false).forEach(locator ->
StreamSupport.stream(locators.spliterator(), false).forEach(locator ->
clientCacheFactory.addPoolLocator(locator.getHostName(), locator.getPort()));
}
@@ -421,7 +421,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* @see #fetchCache()
*/
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
public void onApplicationEvent(@NonNull ContextRefreshedEvent event) {
if (isReadyForEvents()) {
try {
@@ -442,7 +442,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* @see #isKeepAlive()
*/
@Override
protected void close(GemFireCache cache) {
protected void close(@NonNull GemFireCache cache) {
((ClientCache) cache).close(isKeepAlive());
}