Class TransportConfigurationBuilder

java.lang.Object

org.infinispan.configuration.global.AbstractGlobalConfigurationBuilder

org.infinispan.configuration.global.TransportConfigurationBuilder

All Implemented Interfaces:

org.infinispan.commons.configuration.Builder<TransportConfiguration>, GlobalConfigurationChildBuilder

public class TransportConfigurationBuilder
extends AbstractGlobalConfigurationBuilder
implements org.infinispan.commons.configuration.Builder<TransportConfiguration>

Configures the transport used for network communications across the cluster.

Method Summary

Modifier and Type	Method	Description
TransportConfigurationBuilder	addProperty(String key, Object value)
org.infinispan.commons.configuration.attributes.AttributeSet	attributes()
TransportConfigurationBuilder	clearProperties()	Clears the transport properties
TransportConfigurationBuilder	clusterName(String clusterName)	Defines the name of the cluster.
TransportConfiguration	create()
TransportConfigurationBuilder	defaultTransport()
TransportConfigurationBuilder	distributedSyncTimeout(long distributedSyncTimeout)	Timeout for coordinating cluster formation when nodes join or leave the cluster.
TransportConfigurationBuilder	distributedSyncTimeout(long distributedSyncTimeout, TimeUnit unit)	Timeout for coordinating cluster formation when nodes join or leave the cluster.
TransportConfigurationBuilder	distributedSyncTimeout(String distributedSyncTimeout)	Same as distributedSyncTimeout(long) but supporting time units
String	getProperty(String key)
Transport	getTransport()
TransportConfigurationBuilder	initialClusterSize(int clusterSize)	Sets the number of nodes that need to join before the cache container can start.
TransportConfigurationBuilder	initialClusterTimeout(long initialClusterTimeout, TimeUnit unit)	Sets the timeout for the initial cluster to form.
TransportConfigurationBuilder	initialClusterTimeout(String initialClusterTimeout)	Same as initialClusterTimeout(long, TimeUnit) but supporting time units.
JGroupsConfigurationBuilder	jgroups()
TransportConfigurationBuilder	machineId(String machineId)	The id of the machine where this node runs.
TransportConfigurationBuilder	nodeName(String nodeName)	Name of the current node.
TransportConfigurationBuilder	rackId(String rackId)	The id of the rack where this node runs.
TransportConfigurationBuilder	raftMember(String member)	Adds a single member to the raft-members.
TransportConfigurationBuilder	raftMembers(String... members)	Adds multiple members to the raft-members.
TransportConfigurationBuilder	raftMembers(Collection<String> members)	Adds multiple members to the raft-members.
TransportConfigurationBuilder	read(TransportConfiguration template, org.infinispan.commons.configuration.Combine combine)
TransportConfigurationBuilder	removeProperty(String key)
TransportConfigurationBuilder	siteId(String siteId)	The id of the site where this node runs.
TransportConfigurationBuilder	stack(String stack)
String	toString()
TransportConfigurationBuilder	transport(JGroupsTransport transport)	Class that represents a network transport.
void	validate()
TransportConfigurationBuilder	withProperties(Properties properties)	Sets transport properties

Methods inherited from class AbstractGlobalConfigurationBuilder

addModule, asyncThreadPool, blockingThreadPool, build, clearModules, defaultCacheName, expirationThreadPool, getGlobalConfig, globalState, jmx, listenerThreadPool, metrics, module, modules, nonBlockingThreadPool, persistenceThreadPool, security, serialization, shutdown, tracing, transport

Methods inherited from class Object

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

Methods inherited from interface org.infinispan.commons.configuration.Builder

read, reset

Method Details

attributes

public org.infinispan.commons.configuration.attributes.AttributeSet attributes()

Specified by:

attributes in interface org.infinispan.commons.configuration.Builder<TransportConfiguration>

clusterName

public TransportConfigurationBuilder clusterName(String clusterName)

Defines the name of the cluster. Nodes only connect to clusters sharing the same name.

Parameters:

clusterName -

machineId

public TransportConfigurationBuilder machineId(String machineId)

The id of the machine where this node runs. Used for server hinting .

rackId

public TransportConfigurationBuilder rackId(String rackId)

The id of the rack where this node runs. Used for server hinting .

siteId

public TransportConfigurationBuilder siteId(String siteId)

The id of the site where this node runs. Used for server hinting .

stack

public TransportConfigurationBuilder stack(String stack)

distributedSyncTimeout

public TransportConfigurationBuilder distributedSyncTimeout(long distributedSyncTimeout)

Timeout for coordinating cluster formation when nodes join or leave the cluster.

Parameters:

distributedSyncTimeout -

Returns:

distributedSyncTimeout

public TransportConfigurationBuilder distributedSyncTimeout(String distributedSyncTimeout)

Same as distributedSyncTimeout(long) but supporting time units

distributedSyncTimeout

public TransportConfigurationBuilder distributedSyncTimeout(long distributedSyncTimeout,
 TimeUnit unit)

Timeout for coordinating cluster formation when nodes join or leave the cluster.

Parameters:

distributedSyncTimeout -

Returns:

initialClusterSize

public TransportConfigurationBuilder initialClusterSize(int clusterSize)

Sets the number of nodes that need to join before the cache container can start. The default is to start immediately without waiting.

initialClusterTimeout

public TransportConfigurationBuilder initialClusterTimeout(long initialClusterTimeout,
 TimeUnit unit)

Sets the timeout for the initial cluster to form. Defaults to 1 minute

initialClusterTimeout

public TransportConfigurationBuilder initialClusterTimeout(String initialClusterTimeout)

Same as initialClusterTimeout(long, TimeUnit) but supporting time units.

transport

public TransportConfigurationBuilder transport(JGroupsTransport transport)

Class that represents a network transport. Must implement org.infinispan.remoting.transport.Transport

Parameters:

transport - transport instance

nodeName

public TransportConfigurationBuilder nodeName(String nodeName)

Name of the current node. This is a friendly name to make logs, etc. make more sense. Defaults to a combination of host name and a random number (to differentiate multiple nodes on the same host)

Parameters:

nodeName -

withProperties

public TransportConfigurationBuilder withProperties(Properties properties)

Sets transport properties

Parameters:

properties -

Returns:

this TransportConfig

clearProperties

public TransportConfigurationBuilder clearProperties()

Clears the transport properties

Returns:

this TransportConfig

addProperty

public TransportConfigurationBuilder addProperty(String key,
 Object value)

removeProperty

public TransportConfigurationBuilder removeProperty(String key)

getProperty

public String getProperty(String key)

validate

public void validate()

Specified by:

validate in interface org.infinispan.commons.configuration.Builder<TransportConfiguration>

jgroups

public JGroupsConfigurationBuilder jgroups()

create

public TransportConfiguration create()

Specified by:

create in interface org.infinispan.commons.configuration.Builder<TransportConfiguration>

defaultTransport

public TransportConfigurationBuilder defaultTransport()

raftMember

public TransportConfigurationBuilder raftMember(String member)

Adds a single member to the raft-members.

Parameters:

member - The member to add

raftMembers

public TransportConfigurationBuilder raftMembers(String... members)

Adds multiple members to the raft-members.

Parameters:

members - The members to add

raftMembers

public TransportConfigurationBuilder raftMembers(Collection<String> members)

Adds multiple members to the raft-members.

Parameters:

members - The members to add

read

public TransportConfigurationBuilder read(TransportConfiguration template,
 org.infinispan.commons.configuration.Combine combine)

Specified by:

read in interface org.infinispan.commons.configuration.Builder<TransportConfiguration>

getTransport

public Transport getTransport()

toString

public String toString()

Overrides:

toString in class Object