org.infinispan.config
Interface FluentGlobalConfiguration.TransportConfig

All Known Implementing Classes:

GlobalConfiguration.TransportType

Enclosing class:

FluentGlobalConfiguration

public static interface FluentGlobalConfiguration.TransportConfig

Configures the transport used for network communications across the cluster.

Method Summary

FluentGlobalConfiguration.TransportConfig	addProperty(String key, String value) TODO
FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory>	asyncListenerExecutor()
FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory>	asyncTransportExecutor()
GlobalConfiguration	build()
FluentGlobalConfiguration.TransportConfig	clusterName(String clusterName) Defines the name of the cluster.
FluentGlobalConfiguration.TransportConfig	distributedSyncTimeout(Long distributedSyncTimeout) TODO
FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory>	evictionScheduledExecutor()
FluentGlobalConfiguration.GlobalJmxStatisticsConfig	globalJmxStatistics() This method allows configuration of the global, or cache manager level, jmx statistics.
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.SerializationConfig	serialization()
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	transportClass(Class<? extends Transport> transportClass) Class that represents a network transport.
FluentGlobalConfiguration.TransportConfig	withProperties(Properties properties) Sets transport properties

Method Detail

clusterName

FluentGlobalConfiguration.TransportConfig clusterName(String clusterName)

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

Parameters:

clusterName -

machineId

FluentGlobalConfiguration.TransportConfig machineId(String machineId)

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

rackId

FluentGlobalConfiguration.TransportConfig rackId(String rackId)

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

siteId

FluentGlobalConfiguration.TransportConfig siteId(String siteId)

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

distributedSyncTimeout

FluentGlobalConfiguration.TransportConfig distributedSyncTimeout(Long distributedSyncTimeout)

TODO

Parameters:

distributedSyncTimeout -

Returns:

transportClass

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

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

Parameters:

transportClass -

nodeName

FluentGlobalConfiguration.TransportConfig 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

FluentGlobalConfiguration.TransportConfig withProperties(Properties properties)

Sets transport properties

Parameters:

properties -

Returns:

this TransportConfig

strictPeerToPeer

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. 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.

Parameters:

strictPeerToPeer - flag controlling this behavior

addProperty

FluentGlobalConfiguration.TransportConfig addProperty(String key,
                                                      String value)

TODO

Parameters:

key -

value -

Returns:

transport

FluentGlobalConfiguration.TransportConfig transport()

globalJmxStatistics

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

FluentGlobalConfiguration.SerializationConfig serialization()

asyncTransportExecutor

FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory> asyncTransportExecutor()

asyncListenerExecutor

FluentGlobalConfiguration.ExecutorFactoryConfig<ExecutorFactory> asyncListenerExecutor()

evictionScheduledExecutor

FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory> evictionScheduledExecutor()

replicationQueueScheduledExecutor

FluentGlobalConfiguration.ExecutorFactoryConfig<ScheduledExecutorFactory> replicationQueueScheduledExecutor()

shutdown

FluentGlobalConfiguration.ShutdownConfig shutdown()

build

GlobalConfiguration build()