org.infinispan.config
Class GlobalConfiguration.TransportType

java.lang.Object
  extended by org.infinispan.config.AbstractConfigurationBean
      extended by org.infinispan.config.GlobalConfiguration.TransportType
All Implemented Interfaces:
Serializable, Cloneable, CloneableConfigurationComponent, GlobalConfiguration.TransportConfig, JAXBUnmarshallable
Enclosing class:
GlobalConfiguration

public static class GlobalConfiguration.TransportType
extends AbstractConfigurationBean
implements GlobalConfiguration.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
EMPTY_PROPERTIES, log, overriddenConfigurationElements
 
Constructor Summary
GlobalConfiguration.TransportType()
           
GlobalConfiguration.TransportType(String transportClass)
           
 
Method Summary
 void accept(ConfigurationBeanVisitor v)
           
 Object addProperty(String key, String value)
           
 GlobalConfiguration.TransportType clone()
           
 GlobalConfiguration.TransportConfig clusterName(String clusterName)
          Defines the name of the cluster.
 GlobalConfiguration.TransportConfig distributedSyncTimeout(Long distributedSyncTimeout)
           
protected  boolean hasComponentStarted()
          Tests whether the component this configuration bean intents to configure has already started.
 void inject(GlobalComponentRegistry gcr)
           
 GlobalConfiguration.TransportConfig machineId(String machineId)
          The id of the machine where this node runs.
 GlobalConfiguration.TransportConfig nodeName(String nodeName)
          Name of the current node.
 GlobalConfiguration.TransportConfig rackId(String rackId)
          The id of the rack where this node runs.
 void setClusterName(String clusterName)
           
 void setDistributedSyncTimeout(Long distributedSyncTimeout)
           
 void setMachineId(String machineId)
           
 void setNodeName(String nodeName)
           
 void setProperties(TypedProperties properties)
           
 void setRackId(String rackId)
           
 void setSiteId(String siteId)
           
 void setStrictPeerToPeer(Boolean strictPeerToPeer)
           
 void setTransportClass(String transportClass)
           
 GlobalConfiguration.TransportConfig siteId(String siteId)
          The id of the site where this node runs.
 GlobalConfiguration.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.
 GlobalConfiguration.TransportConfig transportClass(Class<? extends Transport> transportClass)
          Class that represents a network transport.
 GlobalConfiguration.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)

clusterName

public GlobalConfiguration.TransportConfig clusterName(String clusterName)
Description copied from interface: GlobalConfiguration.TransportConfig
Defines the name of the cluster. Nodes only connect to clusters sharing the same name.

Specified by:
clusterName in interface GlobalConfiguration.TransportConfig

machineId

public GlobalConfiguration.TransportConfig machineId(String machineId)
Description copied from interface: GlobalConfiguration.TransportConfig
The id of the machine where this node runs. Used for server hinting .

Specified by:
machineId in interface GlobalConfiguration.TransportConfig

rackId

public GlobalConfiguration.TransportConfig rackId(String rackId)
Description copied from interface: GlobalConfiguration.TransportConfig
The id of the rack where this node runs. Used for server hinting .

Specified by:
rackId in interface GlobalConfiguration.TransportConfig

siteId

public GlobalConfiguration.TransportConfig siteId(String siteId)
Description copied from interface: GlobalConfiguration.TransportConfig
The id of the site where this node runs. Used for server hinting .

Specified by:
siteId in interface GlobalConfiguration.TransportConfig

setClusterName

public void setClusterName(String clusterName)

setMachineId

public void setMachineId(String machineId)

setRackId

public void setRackId(String rackId)

setSiteId

public void setSiteId(String siteId)

distributedSyncTimeout

public GlobalConfiguration.TransportConfig distributedSyncTimeout(Long distributedSyncTimeout)
Specified by:
distributedSyncTimeout in interface GlobalConfiguration.TransportConfig

setDistributedSyncTimeout

public void setDistributedSyncTimeout(Long distributedSyncTimeout)

setTransportClass

public void setTransportClass(String transportClass)

transportClass

public GlobalConfiguration.TransportConfig transportClass(Class<? extends Transport> transportClass)
Description copied from interface: GlobalConfiguration.TransportConfig
Class that represents a network transport. Must implement org.infinispan.remoting.transport.Transport

Specified by:
transportClass in interface GlobalConfiguration.TransportConfig

nodeName

public GlobalConfiguration.TransportConfig nodeName(String nodeName)
Description copied from interface: GlobalConfiguration.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 GlobalConfiguration.TransportConfig

setNodeName

public void setNodeName(String nodeName)

setProperties

public void setProperties(TypedProperties properties)

withProperties

public GlobalConfiguration.TransportConfig withProperties(Properties properties)
Description copied from interface: GlobalConfiguration.TransportConfig
Sets transport properties

Specified by:
withProperties in interface GlobalConfiguration.TransportConfig
Returns:
this TransportConfig

addProperty

public Object addProperty(String key,
                          String value)
Specified by:
addProperty in interface GlobalConfiguration.TransportConfig

strictPeerToPeer

public GlobalConfiguration.TransportConfig strictPeerToPeer(Boolean strictPeerToPeer)
Description copied from interface: GlobalConfiguration.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 GlobalConfiguration.TransportConfig
Parameters:
strictPeerToPeer - flag controlling this behavior

setStrictPeerToPeer

public void setStrictPeerToPeer(Boolean strictPeerToPeer)

clone

public GlobalConfiguration.TransportType clone()
                                        throws CloneNotSupportedException
Specified by:
clone in interface CloneableConfigurationComponent
Throws:
CloneNotSupportedException

inject

public void inject(GlobalComponentRegistry gcr)

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.


Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.