org.apache.geode.distributed

Class ServerLauncher.Builder

java.lang.Object

org.apache.geode.distributed.ServerLauncher.Builder

Enclosing class:

ServerLauncher

public static class ServerLauncher.Builder
extends java.lang.Object

The Builder class, modeled after the Builder creational design pattern, is used to construct a properly configured and initialized instance of the ServerLauncher to control and run GemFire servers (in particular, cache servers).

Field Summary

Fields

Modifier and Type	Field and Description
protected static ServerLauncher.Command	DEFAULT_COMMAND

Constructor Summary

Constructors

Constructor and Description
Builder() Default constructor used to create an instance of the Builder class for programmatical access.
Builder(java.lang.String... args) Constructor used to create and configure an instance of the Builder class with the specified arguments, passed in from the command-line when launching an instance of this class from the command-line using the Java launcher.

Method Summary

Modifier and Type	Method and Description
ServerLauncher	build() Validates the Builder configuration settings and then constructs an instance of the ServerLauncher class to invoke operations on a GemFire Server.
java.lang.Boolean	getAssignBuckets() Determines whether buckets should be assigned to partitioned regions in the cache upon Server start.
ServerLauncher.Command	getCommand() Gets the Server launcher command used during the invocation of the ServerLauncher.
java.lang.Float	getCriticalHeapPercentage()
java.lang.Float	getCriticalOffHeapPercentage()
java.lang.Boolean	getDebug() Determines whether the new instance of the ServerLauncher will be set to debug mode.
java.lang.Boolean	getDisableDefaultServer() Determines whether a default cache server will be added when the GemFire Server comes online.
java.util.Properties	getDistributedSystemProperties() Gets the GemFire Distributed System (cluster) Properties configuration.
java.lang.Float	getEvictionHeapPercentage()
java.lang.Float	getEvictionOffHeapPercentage()
java.lang.Boolean	getForce() Gets the boolean value used by the Server to determine if it should overwrite the PID file if it already exists.
java.lang.Boolean	getHelp() Determines whether the new instance of the ServerLauncher will be used to output help information for either a specific command, or for using ServerLauncher in general.
java.lang.String	getHostNameForClients()
java.lang.Integer	getMaxConnections()
java.lang.Integer	getMaxMessageCount()
java.lang.Integer	getMaxThreads()
java.lang.String	getMemberName() Gets the member name of this Server in GemFire.
java.lang.Integer	getMessageTimeToLive()
java.lang.Integer	getPid() Gets the process ID (PID) of the running Server indicated by the user as an argument to the ServerLauncher.
java.lang.Boolean	getRebalance() Determines whether a rebalance operation on the cache will occur upon starting the GemFire server.
java.lang.Boolean	getRedirectOutput() Determines whether the new instance of LocatorLauncher will redirect output to system logs when starting a Locator.
java.net.InetAddress	getServerBindAddress() Gets the IP address to which the Server will be bound listening for and accepting cache client connections in a client/server topology.
java.lang.Integer	getServerPort() Gets the port on which the Server will listen for and accept cache client connections in a client/server topology.
java.lang.Integer	getSocketBufferSize()
java.lang.String	getSpringXmlLocation() Gets the location of the Spring XML configuration meta-data file used to bootstrap, configure and initialize the GemFire Server on start.
java.lang.String	getWorkingDirectory() Gets the working directory pathname in which the Server will be ran.
protected boolean	isHelping() Determines whether help has been enabled.
protected void	parseArguments(java.lang.String... args) Parses the list of arguments to configure this Builder with the intent of constructing a Server launcher to invoke a Cache Server.
protected void	parseCommand(java.lang.String... args) Iterates the list of arguments in search of the target Server launcher command.
protected void	parseMemberName(java.lang.String... args) Iterates the list of arguments in search of the Server's GemFire member name.
ServerLauncher.Builder	set(java.lang.String propertyName, java.lang.String propertyValue) Sets a GemFire Distributed System Property.
ServerLauncher.Builder	setAssignBuckets(java.lang.Boolean assignBuckets) Sets whether buckets should be assigned to partitioned regions in the cache upon Server start.
ServerLauncher.Builder	setCommand(ServerLauncher.Command command) Sets the Sever launcher command used during the invocation of the ServerLauncher
ServerLauncher.Builder	setCriticalHeapPercentage(java.lang.Float criticalHeapPercentage)
ServerLauncher.Builder	setCriticalOffHeapPercentage(java.lang.Float criticalOffHeapPercentage)
ServerLauncher.Builder	setDebug(java.lang.Boolean debug) Sets whether the new instance of the ServerLauncher will be set to debug mode.
ServerLauncher.Builder	setDisableDefaultServer(java.lang.Boolean disableDefaultServer) Sets a boolean value indicating whether to add a default cache when the GemFire Server comes online.
ServerLauncher.Builder	setEvictionHeapPercentage(java.lang.Float evictionHeapPercentage)
ServerLauncher.Builder	setEvictionOffHeapPercentage(java.lang.Float evictionOffHeapPercentage)
ServerLauncher.Builder	setForce(java.lang.Boolean force) Sets the boolean value used by the Server to determine if it should overwrite the PID file if it already exists.
ServerLauncher.Builder	setHelp(java.lang.Boolean help) Sets whether the new instance of ServerLauncher will be used to output help information for either a specific command, or for using ServerLauncher in general.
ServerLauncher.Builder	setHostNameForClients(java.lang.String hostNameForClients)
ServerLauncher.Builder	setMaxConnections(java.lang.Integer maxConnections)
ServerLauncher.Builder	setMaxMessageCount(java.lang.Integer maxMessageCount)
ServerLauncher.Builder	setMaxThreads(java.lang.Integer maxThreads)
ServerLauncher.Builder	setMemberName(java.lang.String memberName) Sets the member name of the Server in GemFire.
ServerLauncher.Builder	setMessageTimeToLive(java.lang.Integer messageTimeToLive)
ServerLauncher.Builder	setPdxDiskStore(java.lang.String pdxDiskStore) Sets the GemFire Disk Store to be used to persist PDX type meta-data.
ServerLauncher.Builder	setPdxIgnoreUnreadFields(boolean ignore) Sets whether fields in the PDX instance should be ignored when unread.
ServerLauncher.Builder	setPdxPersistent(boolean persistent) Sets whether the PDX type meta-data should be persisted to disk.
ServerLauncher.Builder	setPdxReadSerialized(boolean readSerialized) Sets whether PDX instances should be returned as is when Region.get(key:String):Object is called.
ServerLauncher.Builder	setPdxSerializer(PdxSerializer pdxSerializer) Set the PdxSerializer to use to serialize POJOs to the GemFire Cache Region or when sent between peers, client/server, or during persistence to disk.
ServerLauncher.Builder	setPid(java.lang.Integer pid) Sets the process ID (PID) of the running Server indicated by the user as an argument to the ServerLauncher.
ServerLauncher.Builder	setRebalance(java.lang.Boolean rebalance) Set a boolean value indicating whether a rebalance operation on the cache should occur upon starting the GemFire server.
ServerLauncher.Builder	setRedirectOutput(java.lang.Boolean redirectOutput) Sets whether the new instance of LocatorLauncher will redirect output to system logs when starting a Locator.
ServerLauncher.Builder	setServerBindAddress(java.lang.String serverBindAddress) Sets the IP address to which the Server will be bound listening for and accepting cache client connections in a client/server topology.
ServerLauncher.Builder	setServerPort(java.lang.Integer serverPort) Sets the port on which the Server will listen for and accept cache client connections in a client/server topology.
ServerLauncher.Builder	setSocketBufferSize(java.lang.Integer socketBufferSize)
ServerLauncher.Builder	setSpringXmlLocation(java.lang.String springXmlLocation) Sets the location of the Spring XML configuration meta-data file used to bootstrap, configure and initialize the GemFire Server on start.
ServerLauncher.Builder	setWorkingDirectory(java.lang.String workingDirectory) Sets the working directory in which the Server will be ran.
protected void	validate() Validates the configuration settings and properties of this Builder, ensuring that all invariants have been met.
protected void	validateOnStart() Validates the arguments passed to the Builder when the 'start' command has been issued.
protected void	validateOnStatus() Validates the arguments passed to the Builder when the 'status' command has been issued.
protected void	validateOnStop() Validates the arguments passed to the Builder when the 'stop' command has been issued.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_COMMAND

protected static final ServerLauncher.Command DEFAULT_COMMAND

Constructor Detail

Builder

public Builder()

Default constructor used to create an instance of the Builder class for programmatical access.

Builder

public Builder(java.lang.String... args)

Constructor used to create and configure an instance of the Builder class with the specified arguments, passed in from the command-line when launching an instance of this class from the command-line using the Java launcher.

Parameters:

args - the array of arguments used to configure the Builder.

See Also:

parseArguments(String...)

Method Detail

parseArguments

protected void parseArguments(java.lang.String... args)

Parses the list of arguments to configure this Builder with the intent of constructing a Server launcher to invoke a Cache Server. This method is called to parse the arguments specified by the user on the command-line.

Parameters:

args - the array of arguments used to configure this Builder and create an instance of ServerLauncher.

parseCommand

protected void parseCommand(java.lang.String... args)

Iterates the list of arguments in search of the target Server launcher command.

Parameters:

args - an array of arguments from which to search for the Server launcher command.

See Also:

ServerLauncher.Command.valueOfName(String), parseArguments(String...)

parseMemberName

protected void parseMemberName(java.lang.String... args)

Iterates the list of arguments in search of the Server's GemFire member name. If the argument does not start with '-' or is not the name of a Server launcher command, then the value is presumed to be the member name for the Server in GemFire.

Parameters:

args - the array of arguments from which to search for the Server's member name in GemFire.

See Also:

ServerLauncher.Command.isCommand(String), parseArguments(String...)

getCommand

public ServerLauncher.Command getCommand()

Gets the Server launcher command used during the invocation of the ServerLauncher.

Returns:

the Server launcher command used to invoke (run) the ServerLauncher class.

See Also:

setCommand(org.apache.geode.distributed.ServerLauncher.Command), ServerLauncher.Command

setCommand

public ServerLauncher.Builder setCommand(ServerLauncher.Command command)

Sets the Sever launcher command used during the invocation of the ServerLauncher

Parameters:

command - the targeted Server launcher command used during the invocation (run) of ServerLauncher.

Returns:

this Builder instance.

See Also:

getCommand(), ServerLauncher.Command

getAssignBuckets

public java.lang.Boolean getAssignBuckets()

Determines whether buckets should be assigned to partitioned regions in the cache upon Server start.

Returns:

a boolean indicating if buckets should be assigned upon Server start.

See Also:

setAssignBuckets(Boolean)

setAssignBuckets

public ServerLauncher.Builder setAssignBuckets(java.lang.Boolean assignBuckets)

Sets whether buckets should be assigned to partitioned regions in the cache upon Server start.

Parameters:

assignBuckets - a boolean indicating if buckets should be assigned upon Server start.

Returns:

this Builder instance.

See Also:

getAssignBuckets()

getDebug

public java.lang.Boolean getDebug()

Determines whether the new instance of the ServerLauncher will be set to debug mode.

Returns:

a boolean value indicating whether debug mode is enabled or disabled.

See Also:

setDebug(Boolean)

setDebug

public ServerLauncher.Builder setDebug(java.lang.Boolean debug)

Sets whether the new instance of the ServerLauncher will be set to debug mode.

Parameters:

debug - a boolean value indicating whether debug mode is to be enabled or disabled.

Returns:

this Builder instance.

See Also:

getDebug()

getDisableDefaultServer

public java.lang.Boolean getDisableDefaultServer()

Determines whether a default cache server will be added when the GemFire Server comes online.

Returns:

a boolean value indicating whether to add a default cache server.

See Also:

setDisableDefaultServer(Boolean)

setDisableDefaultServer

public ServerLauncher.Builder setDisableDefaultServer(java.lang.Boolean disableDefaultServer)

Sets a boolean value indicating whether to add a default cache when the GemFire Server comes online.

Parameters:

disableDefaultServer - a boolean value indicating whether to add a default cache server.

Returns:

this Builder instance.

See Also:

getDisableDefaultServer()

getDistributedSystemProperties

public java.util.Properties getDistributedSystemProperties()

Gets the GemFire Distributed System (cluster) Properties configuration.

Returns:

a Properties object containing configuration settings for the GemFire Distributed System (cluster).

See Also:

Properties

getForce

public java.lang.Boolean getForce()

Gets the boolean value used by the Server to determine if it should overwrite the PID file if it already exists.

Returns:

the boolean value specifying whether or not to overwrite the PID file if it already exists.

See Also:

LocalProcessLauncher, setForce(Boolean)

setForce

public ServerLauncher.Builder setForce(java.lang.Boolean force)

Sets the boolean value used by the Server to determine if it should overwrite the PID file if it already exists.

Parameters:

force - a boolean value indicating whether to overwrite the PID file when it already exists.

Returns:

this Builder instance.

See Also:

LocalProcessLauncher, getForce()

getHelp

public java.lang.Boolean getHelp()

Determines whether the new instance of the ServerLauncher will be used to output help information for either a specific command, or for using ServerLauncher in general.

Returns:

a boolean value indicating whether help will be output during the invocation of the ServerLauncher.

See Also:

setHelp(Boolean)

isHelping

protected final boolean isHelping()

Determines whether help has been enabled.

Returns:

a boolean indicating if help was enabled.

setHelp

public ServerLauncher.Builder setHelp(java.lang.Boolean help)

Sets whether the new instance of ServerLauncher will be used to output help information for either a specific command, or for using ServerLauncher in general.

Parameters:

help - a boolean indicating whether help information is to be displayed during invocation of ServerLauncher.

Returns:

this Builder instance.

See Also:

getHelp()

getRebalance

public java.lang.Boolean getRebalance()

Determines whether a rebalance operation on the cache will occur upon starting the GemFire server.

Returns:

a boolean indicating if the cache will be rebalance when the GemFire server starts.

See Also:

setRebalance(Boolean)

setRebalance

public ServerLauncher.Builder setRebalance(java.lang.Boolean rebalance)

Set a boolean value indicating whether a rebalance operation on the cache should occur upon starting the GemFire server.

Parameters:

rebalance - a boolean indicating if the cache will be rebalanced when the GemFire server starts.

Returns:

this Builder instance.

See Also:

getRebalance()

getMemberName

public java.lang.String getMemberName()

Gets the member name of this Server in GemFire.

Returns:

a String indicating the member name of this Server in GemFire.

See Also:

setMemberName(String)

setMemberName

public ServerLauncher.Builder setMemberName(java.lang.String memberName)

Sets the member name of the Server in GemFire.

Parameters:

memberName - a String indicating the member name of this Server in GemFire.

Returns:

this Builder instance.

Throws:

java.lang.IllegalArgumentException - if the member name is invalid.

See Also:

getMemberName()

getPid

public java.lang.Integer getPid()

Gets the process ID (PID) of the running Server indicated by the user as an argument to the ServerLauncher. This PID is used by the Server launcher to determine the Server's status, or invoke shutdown on the Server.

Returns:

a user specified Integer value indicating the process ID of the running Server.

See Also:

setPid(Integer)

setPid

public ServerLauncher.Builder setPid(java.lang.Integer pid)

Sets the process ID (PID) of the running Server indicated by the user as an argument to the ServerLauncher. This PID will be used by the Server launcher to determine the Server's status, or invoke shutdown on the Server.

Parameters:

pid - a user specified Integer value indicating the process ID of the running Server.

Returns:

this Builder instance.

Throws:

java.lang.IllegalArgumentException - if the process ID (PID) is not valid (greater than zero if not null).

See Also:

getPid()

getRedirectOutput

public java.lang.Boolean getRedirectOutput()

Determines whether the new instance of LocatorLauncher will redirect output to system logs when starting a Locator.

Returns:

a boolean value indicating if output will be redirected to system logs when starting a Locator

See Also:

setRedirectOutput(Boolean)

setRedirectOutput

public ServerLauncher.Builder setRedirectOutput(java.lang.Boolean redirectOutput)

Sets whether the new instance of LocatorLauncher will redirect output to system logs when starting a Locator.

Parameters:

redirectOutput - a boolean value indicating if output will be redirected to system logs when starting a Locator.

Returns:

this Builder instance.

See Also:

getRedirectOutput()

getServerBindAddress

public java.net.InetAddress getServerBindAddress()

Gets the IP address to which the Server will be bound listening for and accepting cache client connections in a client/server topology.

Returns:

an InetAddress indicating the IP address that the Server is bound to listening for and accepting cache client connections in a client/server topology.

See Also:

setServerBindAddress(String)

setServerBindAddress

public ServerLauncher.Builder setServerBindAddress(java.lang.String serverBindAddress)

Sets the IP address to which the Server will be bound listening for and accepting cache client connections in a client/server topology.

Parameters:

serverBindAddress - a String specifying the IP address or hostname that the Server will be bound to listen for and accept cache client connections in a client/server topology.

Returns:

this Builder instance.

Throws:

java.lang.IllegalArgumentException - wrapping the UnknownHostException if the IP address or hostname for the server bind address is unknown.

See Also:

getServerBindAddress()

getServerPort

public java.lang.Integer getServerPort()

Gets the port on which the Server will listen for and accept cache client connections in a client/server topology.

Returns:

an Integer value specifying the port the Server will listen on and accept cache client connections in a client/server topology.

See Also:

setServerPort(Integer)

setServerPort

public ServerLauncher.Builder setServerPort(java.lang.Integer serverPort)

Sets the port on which the Server will listen for and accept cache client connections in a client/server topology.

Parameters:

serverPort - an Integer value specifying the port the Server will listen on and accept cache client connections in a client/server topology.

Returns:

this Builder instance.

Throws:

java.lang.IllegalArgumentException - if the port number is not valid.

See Also:

getServerPort()

getSpringXmlLocation

public java.lang.String getSpringXmlLocation()

Gets the location of the Spring XML configuration meta-data file used to bootstrap, configure and initialize the GemFire Server on start.

Returns:

a String indicating the location of the Spring XML configuration file.

See Also:

setSpringXmlLocation(String)

setSpringXmlLocation

public ServerLauncher.Builder setSpringXmlLocation(java.lang.String springXmlLocation)

Sets the location of the Spring XML configuration meta-data file used to bootstrap, configure and initialize the GemFire Server on start.

Parameters:

springXmlLocation - a String indicating the location of the Spring XML configuration file.

Returns:

this Builder instance.

See Also:

getSpringXmlLocation()

getWorkingDirectory

public java.lang.String getWorkingDirectory()

Gets the working directory pathname in which the Server will be ran. If the directory is unspecified, then working directory defaults to the current directory.

Returns:

a String indicating the working directory pathname.

See Also:

setWorkingDirectory(String)

setWorkingDirectory

public ServerLauncher.Builder setWorkingDirectory(java.lang.String workingDirectory)

Sets the working directory in which the Server will be ran. This also the directory in which all Server files (such as log and license files) will be written. If the directory is unspecified, then the working directory defaults to the current directory.

Parameters:

workingDirectory - a String indicating the pathname of the directory in which the Server will be ran.

Returns:

this Builder instance.

Throws:

java.lang.IllegalArgumentException - wrapping a FileNotFoundException if the working directory pathname cannot be found.

See Also:

getWorkingDirectory(), FileNotFoundException

getCriticalHeapPercentage

public java.lang.Float getCriticalHeapPercentage()

setCriticalHeapPercentage

public ServerLauncher.Builder setCriticalHeapPercentage(java.lang.Float criticalHeapPercentage)

getCriticalOffHeapPercentage

public java.lang.Float getCriticalOffHeapPercentage()

setCriticalOffHeapPercentage

public ServerLauncher.Builder setCriticalOffHeapPercentage(java.lang.Float criticalOffHeapPercentage)

getEvictionHeapPercentage

public java.lang.Float getEvictionHeapPercentage()

setEvictionHeapPercentage

public ServerLauncher.Builder setEvictionHeapPercentage(java.lang.Float evictionHeapPercentage)

getEvictionOffHeapPercentage

public java.lang.Float getEvictionOffHeapPercentage()

setEvictionOffHeapPercentage

public ServerLauncher.Builder setEvictionOffHeapPercentage(java.lang.Float evictionOffHeapPercentage)

getHostNameForClients

public java.lang.String getHostNameForClients()

setHostNameForClients

public ServerLauncher.Builder setHostNameForClients(java.lang.String hostNameForClients)

getMaxConnections

public java.lang.Integer getMaxConnections()

setMaxConnections

public ServerLauncher.Builder setMaxConnections(java.lang.Integer maxConnections)

getMaxMessageCount

public java.lang.Integer getMaxMessageCount()

setMaxMessageCount

public ServerLauncher.Builder setMaxMessageCount(java.lang.Integer maxMessageCount)

getMaxThreads

public java.lang.Integer getMaxThreads()

setMaxThreads

public ServerLauncher.Builder setMaxThreads(java.lang.Integer maxThreads)

getMessageTimeToLive

public java.lang.Integer getMessageTimeToLive()

setMessageTimeToLive

public ServerLauncher.Builder setMessageTimeToLive(java.lang.Integer messageTimeToLive)

getSocketBufferSize

public java.lang.Integer getSocketBufferSize()

setSocketBufferSize

public ServerLauncher.Builder setSocketBufferSize(java.lang.Integer socketBufferSize)

set

public ServerLauncher.Builder set(java.lang.String propertyName,
                                  java.lang.String propertyValue)

Sets a GemFire Distributed System Property.

Parameters:

propertyName - a String indicating the name of the GemFire Distributed System property as described in ConfigurationProperties

propertyValue - a String value for the GemFire Distributed System property.

Returns:

this Builder instance.

setPdxPersistent

public ServerLauncher.Builder setPdxPersistent(boolean persistent)

Sets whether the PDX type meta-data should be persisted to disk.

Parameters:

persistent - a boolean indicating whether PDX type meta-data should be persisted to disk.

Returns:

this Builder instance.

setPdxDiskStore

public ServerLauncher.Builder setPdxDiskStore(java.lang.String pdxDiskStore)

Sets the GemFire Disk Store to be used to persist PDX type meta-data.

Parameters:

pdxDiskStore - a String indicating the name of the GemFire Disk Store to use to store PDX type meta-data

Returns:

this Builder instance.

setPdxIgnoreUnreadFields

public ServerLauncher.Builder setPdxIgnoreUnreadFields(boolean ignore)

Sets whether fields in the PDX instance should be ignored when unread.

Parameters:

ignore - a boolean indicating whether unread fields in the PDX instance should be ignored.

Returns:

this Builder instance.

setPdxReadSerialized

public ServerLauncher.Builder setPdxReadSerialized(boolean readSerialized)

Sets whether PDX instances should be returned as is when Region.get(key:String):Object is called.

Parameters:

readSerialized - a boolean indicating whether the PDX instance should be returned from a call to Region.get(key:String):Object

Returns:

this Builder instance.

setPdxSerializer

public ServerLauncher.Builder setPdxSerializer(PdxSerializer pdxSerializer)

Set the PdxSerializer to use to serialize POJOs to the GemFire Cache Region or when sent between peers, client/server, or during persistence to disk.

Parameters:

pdxSerializer - the PdxSerializer that is used to serialize application domain objects into PDX.

Returns:

this Builder instance.

validate

protected void validate()

Validates the configuration settings and properties of this Builder, ensuring that all invariants have been met. Currently, the only invariant constraining the Builder is that the user must specify the member name for the Server in the GemFire distributed system as a command-line argument, or by setting the memberName property programmatically using the corresponding setter method.

Throws:

java.lang.IllegalStateException - if the Builder is not properly configured.

validateOnStart

protected void validateOnStart()

Validates the arguments passed to the Builder when the 'start' command has been issued.

See Also:

ServerLauncher.Command.START

validateOnStatus

protected void validateOnStatus()

Validates the arguments passed to the Builder when the 'status' command has been issued.

See Also:

ServerLauncher.Command.STATUS

validateOnStop

protected void validateOnStop()

Validates the arguments passed to the Builder when the 'stop' command has been issued.

See Also:

ServerLauncher.Command.STOP

build

public ServerLauncher build()

Validates the Builder configuration settings and then constructs an instance of the ServerLauncher class to invoke operations on a GemFire Server.

Returns:

a newly constructed instance of the ServerLauncher configured with this Builder.

See Also:

validate(), ServerLauncher