org.infinispan.config
Class GlobalConfiguration.TransportType

java.lang.Object
  org.infinispan.config.AbstractConfigurationBean
      org.infinispan.config.GlobalConfiguration.TransportType

All Implemented Interfaces:

Serializable, Cloneable, CloneableConfigurationComponent, FluentGlobalConfiguration.TransportConfig, JAXBUnmarshallable

Enclosing class:

GlobalConfiguration

public static class GlobalConfiguration.TransportType
extends AbstractConfigurationBean
implements FluentGlobalConfiguration.TransportConfig

This element configures the transport used for network communications across the cluster.

See Also:

Configuration reference, Serialized Form

Field Summary

protected String	clusterName
protected Long	distributedSyncTimeout
protected String	machineId
protected String	nodeName
protected TypedProperties	properties
protected String	rackId
protected String	siteId
protected Boolean	strictPeerToPeer
protected String	transportClass

Fields inherited from class org.infinispan.config.AbstractConfigurationBean

overriddenConfigurationElements

Constructor Summary

GlobalConfiguration.TransportType()

GlobalConfiguration.TransportType(String transportClass)

Method Summary

void	accept(ConfigurationBeanVisitor v)
FluentGlobalConfiguration.TransportConfig	addProperty(String key, String value) TODO
FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory>	asyncListenerExecutor()
FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory>	asyncListenerExecutor()
FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory>	asyncTransportExecutor()
FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory>	asyncTransportExecutor()
GlobalConfiguration	build()
GlobalConfiguration	build()
GlobalConfiguration.TransportType	clone()
FluentGlobalConfiguration.TransportConfig	clusterName(String clusterName) Defines the name of the cluster.
FluentGlobalConfiguration.TransportConfig	distributedSyncTimeout(Long distributedSyncTimeout) TODO
FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory>	evictionScheduledExecutor()
FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory>	evictionScheduledExecutor()
String	getClusterName()
Long	getDistributedSyncTimeout()
String	getMachineId()
String	getNodeName()
String	getRackId()
String	getSiteId()
Boolean	getStrictPeerToPeer()
String	getTransportClass()
FluentGlobalConfiguration.GlobalJmxStatisticsConfig	globalJmxStatistics() This method allows configuration of the global, or cache manager level, jmx statistics.
FluentGlobalConfiguration.GlobalJmxStatisticsConfig	globalJmxStatistics() This method allows configuration of the global, or cache manager level, jmx statistics.
protected boolean	hasComponentStarted() Tests whether the component this configuration bean intents to configure has already started.
void	inject(GlobalComponentRegistry gcr, GlobalConfiguration globalConfig)
FluentGlobalConfiguration.TransportConfig	machineId(String machineId) The id of the machine where this node runs.
FluentGlobalConfiguration.TransportConfig	nodeName(String nodeName) Name of the current node.
FluentGlobalConfiguration.TransportConfig	rackId(String rackId) The id of the rack where this node runs.
FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory>	replicationQueueScheduledExecutor()
FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory>	replicationQueueScheduledExecutor()
FluentGlobalConfiguration.SerializationConfig	serialization()
FluentGlobalConfiguration.SerializationConfig	serialization()
void	setClusterName(String clusterName) Deprecated. The visibility of this will be reduced, use clusterName(String) instead
void	setDistributedSyncTimeout(Long distributedSyncTimeout) Deprecated. The visibility of this will be reduced, use distributedSyncTimeout(Long) instead
void	setMachineId(String machineId) Deprecated. The visibility of this will be reduced, use machineId(String) instead
void	setNodeName(String nodeName) Deprecated. The visibility of this will be reduced, use nodeName(String) instead
void	setProperties(TypedProperties properties) Deprecated. The visibility of this will be reduced, use withProperties(java.util.Properties) or addProperty(String, String) instead
void	setRackId(String rackId) Deprecated. The visibility of this will be reduced, use rackId(String) instead
void	setSiteId(String siteId) Deprecated. The visibility of this will be reduced, use siteId(String) instead
void	setStrictPeerToPeer(Boolean strictPeerToPeer) Deprecated. The visibility of this will be reduced, use strictPeerToPeer(Boolean) instead
void	setTransportClass(String transportClass) Deprecated. The visibility of this will be reduced, use transportClass(Class) instead
FluentGlobalConfiguration.ShutdownConfig	shutdown()
FluentGlobalConfiguration.ShutdownConfig	shutdown()
FluentGlobalConfiguration.TransportConfig	siteId(String siteId) The id of the site where this node runs.
FluentGlobalConfiguration.TransportConfig	strictPeerToPeer(Boolean strictPeerToPeer) If set to true, RPC operations will fail if the named cache does not exist on remote nodes with a NamedCacheNotFoundException.
FluentGlobalConfiguration.TransportConfig	transport()
FluentGlobalConfiguration.TransportConfig	transport()
FluentGlobalConfiguration.TransportConfig	transportClass(Class<? extends Transport> transportClass) Class that represents a network transport.
FluentGlobalConfiguration.TransportConfig	withProperties(Properties properties) Sets transport properties

Methods inherited from class org.infinispan.config.AbstractConfigurationBean

testImmutability, toTypedProperties, toTypedProperties, uc, willUnmarshall

Methods inherited from class java.lang.Object

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

Field Detail

clusterName

protected String clusterName

machineId

protected String machineId

rackId

protected String rackId

siteId

protected String siteId

strictPeerToPeer

protected Boolean strictPeerToPeer

distributedSyncTimeout

protected Long distributedSyncTimeout

transportClass

protected String transportClass

nodeName

protected String nodeName

properties

protected TypedProperties properties

Constructor Detail

GlobalConfiguration.TransportType

public GlobalConfiguration.TransportType()

GlobalConfiguration.TransportType

public GlobalConfiguration.TransportType(String transportClass)

Method Detail

accept

public void accept(ConfigurationBeanVisitor v)

getClusterName

public String getClusterName()

setClusterName

@Deprecated
public void setClusterName(String clusterName)

Deprecated. The visibility of this will be reduced, use clusterName(String) instead

clusterName

public FluentGlobalConfiguration.TransportConfig clusterName(String clusterName)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

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

Specified by:

clusterName in interface FluentGlobalConfiguration.TransportConfig

getMachineId

public String getMachineId()

setMachineId

@Deprecated
public void setMachineId(String machineId)

Deprecated. The visibility of this will be reduced, use machineId(String) instead

machineId

public FluentGlobalConfiguration.TransportConfig machineId(String machineId)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

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

Specified by:

machineId in interface FluentGlobalConfiguration.TransportConfig

getRackId

public String getRackId()

setRackId

@Deprecated
public void setRackId(String rackId)

Deprecated. The visibility of this will be reduced, use rackId(String) instead

rackId

public FluentGlobalConfiguration.TransportConfig rackId(String rackId)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

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

Specified by:

rackId in interface FluentGlobalConfiguration.TransportConfig

getSiteId

public String getSiteId()

setSiteId

@Deprecated
public void setSiteId(String siteId)

Deprecated. The visibility of this will be reduced, use siteId(String) instead

siteId

public FluentGlobalConfiguration.TransportConfig siteId(String siteId)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

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

Specified by:

siteId in interface FluentGlobalConfiguration.TransportConfig

getDistributedSyncTimeout

public Long getDistributedSyncTimeout()

setDistributedSyncTimeout

@Deprecated
public void setDistributedSyncTimeout(Long distributedSyncTimeout)

Deprecated. The visibility of this will be reduced, use distributedSyncTimeout(Long) instead

distributedSyncTimeout

public FluentGlobalConfiguration.TransportConfig distributedSyncTimeout(Long distributedSyncTimeout)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

TODO

Specified by:

distributedSyncTimeout in interface FluentGlobalConfiguration.TransportConfig

Returns:

getTransportClass

public String getTransportClass()

setTransportClass

@Deprecated
public void setTransportClass(String transportClass)

Deprecated. The visibility of this will be reduced, use transportClass(Class) instead

transportClass

public FluentGlobalConfiguration.TransportConfig transportClass(Class<? extends Transport> transportClass)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

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

Specified by:

transportClass in interface FluentGlobalConfiguration.TransportConfig

getNodeName

public String getNodeName()

setNodeName

@Deprecated
public void setNodeName(String nodeName)

Deprecated. The visibility of this will be reduced, use nodeName(String) instead

nodeName

public FluentGlobalConfiguration.TransportConfig nodeName(String nodeName)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

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)

Specified by:

nodeName in interface FluentGlobalConfiguration.TransportConfig

setProperties

@Deprecated
public void setProperties(TypedProperties properties)

Deprecated. The visibility of this will be reduced, use withProperties(java.util.Properties) or addProperty(String, String) instead

withProperties

public FluentGlobalConfiguration.TransportConfig withProperties(Properties properties)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

Sets transport properties

Specified by:

withProperties in interface FluentGlobalConfiguration.TransportConfig

Returns:

this TransportConfig

addProperty

public FluentGlobalConfiguration.TransportConfig addProperty(String key,
                                                             String value)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

TODO

Specified by:

addProperty in interface FluentGlobalConfiguration.TransportConfig

Returns:

getStrictPeerToPeer

public Boolean getStrictPeerToPeer()

setStrictPeerToPeer

@Deprecated
public void setStrictPeerToPeer(Boolean strictPeerToPeer)

Deprecated. The visibility of this will be reduced, use strictPeerToPeer(Boolean) instead

strictPeerToPeer

public FluentGlobalConfiguration.TransportConfig strictPeerToPeer(Boolean strictPeerToPeer)

Description copied from interface: FluentGlobalConfiguration.TransportConfig

If set to true, RPC operations will fail if the named cache does not exist on remote nodes with a NamedCacheNotFoundException. Otherwise, operations will succeed but it will be logged on the caller that the RPC did not succeed on certain nodes due to the named cache not being available.

Specified by:

strictPeerToPeer in interface FluentGlobalConfiguration.TransportConfig

Parameters:

strictPeerToPeer - flag controlling this behavior

clone

public GlobalConfiguration.TransportType clone()
                                        throws CloneNotSupportedException

Specified by:

clone in interface CloneableConfigurationComponent

Throws:

CloneNotSupportedException

transport

public FluentGlobalConfiguration.TransportConfig transport()

globalJmxStatistics

public FluentGlobalConfiguration.GlobalJmxStatisticsConfig globalJmxStatistics()

This method allows configuration of the global, or cache manager level, jmx statistics. When this method is called, it automatically enables global jmx statistics. So, if you want it to be disabled, make sure you call FluentGlobalConfiguration.GlobalJmxStatisticsConfig.disable()

serialization

public FluentGlobalConfiguration.SerializationConfig serialization()

asyncTransportExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory> asyncTransportExecutor()

asyncListenerExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory> asyncListenerExecutor()

evictionScheduledExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory> evictionScheduledExecutor()

replicationQueueScheduledExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory> replicationQueueScheduledExecutor()

shutdown

public FluentGlobalConfiguration.ShutdownConfig shutdown()

build

public GlobalConfiguration build()

inject

public void inject(GlobalComponentRegistry gcr,
                   GlobalConfiguration globalConfig)

hasComponentStarted

protected boolean hasComponentStarted()

Description copied from class: AbstractConfigurationBean

Tests whether the component this configuration bean intents to configure has already started.

Specified by:

hasComponentStarted in class AbstractConfigurationBean

Returns:

true if the component has started; false otherwise.

transport

public FluentGlobalConfiguration.TransportConfig transport()

globalJmxStatistics

public FluentGlobalConfiguration.GlobalJmxStatisticsConfig globalJmxStatistics()

This method allows configuration of the global, or cache manager level, jmx statistics. When this method is called, it automatically enables global jmx statistics. So, if you want it to be disabled, make sure you call FluentGlobalConfiguration.GlobalJmxStatisticsConfig.disable()

serialization

public FluentGlobalConfiguration.SerializationConfig serialization()

asyncListenerExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory> asyncListenerExecutor()

asyncTransportExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory> asyncTransportExecutor()

evictionScheduledExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory> evictionScheduledExecutor()

replicationQueueScheduledExecutor

public FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory> replicationQueueScheduledExecutor()

shutdown

public FluentGlobalConfiguration.ShutdownConfig shutdown()

build

public GlobalConfiguration build()