org.springframework.geode.config.annotation

Class ClusterAwareConfiguration.ClusterAwareCondition

java.lang.Object

org.springframework.geode.config.annotation.ClusterAwareConfiguration.ClusterAwareCondition

All Implemented Interfaces:

org.springframework.context.annotation.Condition

Direct Known Subclasses:

ClusterAvailableConfiguration.AbstractCloudPlatformAvailableCondition, ClusterAvailableConfiguration.StandaloneClusterAvailableCondition, ClusterNotAvailableConfiguration.ClusterNotAvailableCondition

Enclosing class:

ClusterAwareConfiguration

public static class ClusterAwareConfiguration.ClusterAwareCondition
extends java.lang.Object
implements org.springframework.context.annotation.Condition

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	RUNTIME_ENVIRONMENT_NAME

Constructor Summary

Constructors

Constructor and Description
ClusterAwareCondition()

Method Summary

Modifier and Type	Method and Description
protected boolean	close(java.net.Socket socket)
protected void	configureTopology(org.springframework.core.env.Environment environment, org.springframework.data.gemfire.support.ConnectionEndpointList connectionEndpoints, int connectionCount)
protected java.net.Socket	connect(org.springframework.data.gemfire.support.ConnectionEndpoint connectionEndpoint)
protected int	countConnections(org.springframework.data.gemfire.support.ConnectionEndpointList connectionEndpoints)
protected boolean	doCachedMatch(org.springframework.context.annotation.ConditionContext conditionContext) Caches the result of the computed doMatch(ConditionContext) operation.
protected boolean	doMatch(org.springframework.context.annotation.ConditionContext conditionContext) Performs the actual conditional match to determine whether this Spring Boot for Apache Geode application can connect to an available Apache Geode cluster available in any environment (e.g.
protected void	failOnStrictMatchAndNoMatches(boolean strictMatch, boolean matches)
protected java.util.List<org.springframework.data.gemfire.support.ConnectionEndpoint>	getConfiguredConnectionEndpoints(org.springframework.core.env.Environment environment)
protected org.springframework.data.gemfire.support.ConnectionEndpointList	getConnectionEndpoints(org.springframework.core.env.Environment environment)
protected java.util.List<org.springframework.data.gemfire.support.ConnectionEndpoint>	getDefaultConnectionEndpoints(org.springframework.core.env.Environment environment)
protected org.slf4j.Logger	getLogger()
protected java.util.List<org.springframework.data.gemfire.support.ConnectionEndpoint>	getPooledConnectionEndpoints(org.springframework.core.env.Environment environment)
protected java.util.Collection<org.apache.geode.cache.client.Pool>	getPoolsFromApacheGeode()
protected java.lang.String	getRuntimeEnvironmentName() Returns a String containing a description of the runtime environment.
static boolean	isAvailable() Determines whether an Apache Geode-based Cluster is available in the runtime environment.
protected boolean	isConnected(int connectionCount)
protected boolean	isConnected(java.net.Socket socket)
protected boolean	isNotConnected(int connectionCount)
protected boolean	isStrictMatch(org.springframework.context.annotation.ConditionContext conditionContext, org.springframework.core.type.AnnotatedTypeMetadata typeMetadata)
protected boolean	isStrictMatchAndNoMatches(boolean strictMatch, boolean matches)
protected void	logConnectedRuntimeEnvironment(org.slf4j.Logger logger)
protected void	logConnectedRuntimeEnvironment(org.slf4j.Logger logger, int connectionCount)
protected void	logRuntimeEnvironment(org.slf4j.Logger logger, int connectionCount)
protected void	logUnconnectedRuntimeEnvironment(org.slf4j.Logger logger)
boolean	matches(org.springframework.context.annotation.ConditionContext conditionContext, org.springframework.core.type.AnnotatedTypeMetadata typeMetadata)
protected java.net.Socket	newSocket(ClusterAwareConfiguration.PoolConnectionEndpoint poolConnectionEndpoint)
protected java.net.Socket	newSocket(org.springframework.data.gemfire.support.ConnectionEndpoint connectionEndpoint)
protected org.springframework.context.annotation.ConditionContext	registerApplicationListener(org.springframework.context.annotation.ConditionContext conditionContext)
static void	reset() Resets the state of this Condition to reevaluate whether an Apache Geode-based Cluster is available in the runtime environment.
protected static void	set(java.lang.Boolean available) Sets the state of the clusterAvailable variable.
static boolean	wasClusterAvailabilityEvaluated() Determines whether the Condition that determines whether an Apache Geode-based Cluster is available in the runtime environment has been evaluated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RUNTIME_ENVIRONMENT_NAME

protected static final java.lang.String RUNTIME_ENVIRONMENT_NAME

See Also:

Constant Field Values

Constructor Detail

ClusterAwareCondition

public ClusterAwareCondition()

Method Detail

isAvailable

public static boolean isAvailable()

Determines whether an Apache Geode-based Cluster is available in the runtime environment.

Returns:

a boolean value indicating whether an Apache Geode-based Cluster is available in the runtime environment.

See Also:

wasClusterAvailabilityEvaluated()

reset

public static void reset()

Resets the state of this Condition to reevaluate whether an Apache Geode-based Cluster is available in the runtime environment.

See Also:

set(Boolean)

set

protected static void set(@Nullable
                          java.lang.Boolean available)

Sets the state of the clusterAvailable variable.

Parameters:

available - state to set the clusterAvailable variable to.

See Also:

reset()

wasClusterAvailabilityEvaluated

public static boolean wasClusterAvailabilityEvaluated()

Determines whether the Condition that determines whether an Apache Geode-based Cluster is available in the runtime environment has been evaluated.

Returns:

a boolean value indicating whether the Condition that determines whether an Apache Geode-based Cluster is available in the runtime environment has been evaluated.

See Also:

isAvailable()

getRuntimeEnvironmentName

protected java.lang.String getRuntimeEnvironmentName()

Returns a String containing a description of the runtime environment.

Returns:

a String containing a description of the runtime environment.

matches

public boolean matches(@NonNull
                       org.springframework.context.annotation.ConditionContext conditionContext,
                       @NonNull
                       org.springframework.core.type.AnnotatedTypeMetadata typeMetadata)

Specified by:

matches in interface org.springframework.context.annotation.Condition

isStrictMatch

protected boolean isStrictMatch(@NonNull
                                org.springframework.context.annotation.ConditionContext conditionContext,
                                @NonNull
                                org.springframework.core.type.AnnotatedTypeMetadata typeMetadata)

isStrictMatchAndNoMatches

protected boolean isStrictMatchAndNoMatches(boolean strictMatch,
                                            boolean matches)

failOnStrictMatchAndNoMatches

protected void failOnStrictMatchAndNoMatches(boolean strictMatch,
                                             boolean matches)

doCachedMatch

protected boolean doCachedMatch(@NonNull
                                org.springframework.context.annotation.ConditionContext conditionContext)

Caches the result of the computed doMatch(ConditionContext) operation. Subsequent calls returns the cached value of the computed (once) doMatch(ConditionContext) operation.

Parameters:

conditionContext - Spring ConditionContext capturing the context in which the conditions are evaluated; must not be null.

Returns:

a boolean value indicating whether the conditions match (i.e. true).

See Also:

ConditionContext, registerApplicationListener(ConditionContext), doMatch(ConditionContext)

registerApplicationListener

@NonNull
protected org.springframework.context.annotation.ConditionContext registerApplicationListener(@NonNull
                                                                                                       org.springframework.context.annotation.ConditionContext conditionContext)

doMatch

protected boolean doMatch(@NonNull
                          org.springframework.context.annotation.ConditionContext conditionContext)

Performs the actual conditional match to determine whether this Spring Boot for Apache Geode application can connect to an available Apache Geode cluster available in any environment (e.g. Standalone or Cloud).

Parameters:

conditionContext - Spring ConditionContext capturing the context in which the condition(s) are evaluated; must not be null.

Returns:

the given ConditionContext.

See Also:

ConditionContext, doCachedMatch(ConditionContext), getConnectionEndpoints(Environment), countConnections(ConnectionEndpointList), configureTopology(Environment, ConnectionEndpointList, int), logRuntimeEnvironment(Logger, int), isMatch(ConnectionEndpointList, int)

getLogger

@NonNull
protected org.slf4j.Logger getLogger()

getConnectionEndpoints

protected org.springframework.data.gemfire.support.ConnectionEndpointList getConnectionEndpoints(@NonNull
                                                                                                 org.springframework.core.env.Environment environment)

getDefaultConnectionEndpoints

protected java.util.List<org.springframework.data.gemfire.support.ConnectionEndpoint> getDefaultConnectionEndpoints(@NonNull
                                                                                                                    org.springframework.core.env.Environment environment)

getConfiguredConnectionEndpoints

protected java.util.List<org.springframework.data.gemfire.support.ConnectionEndpoint> getConfiguredConnectionEndpoints(@NonNull
                                                                                                                       org.springframework.core.env.Environment environment)

getPooledConnectionEndpoints

protected java.util.List<org.springframework.data.gemfire.support.ConnectionEndpoint> getPooledConnectionEndpoints(@NonNull
                                                                                                                   org.springframework.core.env.Environment environment)

getPoolsFromApacheGeode

protected java.util.Collection<org.apache.geode.cache.client.Pool> getPoolsFromApacheGeode()

countConnections

protected int countConnections(@NonNull
                               org.springframework.data.gemfire.support.ConnectionEndpointList connectionEndpoints)

isConnected

protected boolean isConnected(@NonNull
                              java.net.Socket socket)

connect

@NonNull
protected java.net.Socket connect(@NonNull
                                           org.springframework.data.gemfire.support.ConnectionEndpoint connectionEndpoint)
                                    throws java.io.IOException

Throws:

java.io.IOException

newSocket

@NonNull
protected java.net.Socket newSocket(@NonNull
                                             org.springframework.data.gemfire.support.ConnectionEndpoint connectionEndpoint)
                                      throws java.io.IOException

Throws:

java.io.IOException

newSocket

@NonNull
protected java.net.Socket newSocket(@NonNull
                                             ClusterAwareConfiguration.PoolConnectionEndpoint poolConnectionEndpoint)

close

protected boolean close(@Nullable
                        java.net.Socket socket)

isConnected

protected boolean isConnected(int connectionCount)

isNotConnected

protected boolean isNotConnected(int connectionCount)

configureTopology

protected void configureTopology(@NonNull
                                 org.springframework.core.env.Environment environment,
                                 @NonNull
                                 org.springframework.data.gemfire.support.ConnectionEndpointList connectionEndpoints,
                                 int connectionCount)

logConnectedRuntimeEnvironment

protected void logConnectedRuntimeEnvironment(@NonNull
                                              org.slf4j.Logger logger)

logConnectedRuntimeEnvironment

protected void logConnectedRuntimeEnvironment(@NonNull
                                              org.slf4j.Logger logger,
                                              int connectionCount)

logRuntimeEnvironment

protected void logRuntimeEnvironment(@NonNull
                                     org.slf4j.Logger logger,
                                     int connectionCount)

logUnconnectedRuntimeEnvironment

protected void logUnconnectedRuntimeEnvironment(@NonNull
                                                org.slf4j.Logger logger)