Uses of Interface
org.infinispan.remoting.transport.Address

Packages that use Address

Package	Description
org.infinispan.affinity
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.commands.remote	Meta-commands that wrap other commands for remote execution.
org.infinispan.commands.tx	Commands that represent transactional lifecycle transitions.
org.infinispan.commands.write	Commands that alter the state of the cache.
org.infinispan.context	Contexts contain information of a specific invocation on the cache, such as its origins, scope (transactional or non-transactional), as well as invocation-specific flags.
org.infinispan.context.impl	This package contains different context implementations, selected dynamically based on the type of invocation.
org.infinispan.demo	Classes, programs and applications that help demonstrate how Infinispan can be used.
org.infinispan.distexec
org.infinispan.distexec.mapreduce
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.distribution.ch
org.infinispan.distribution.group	Groups allow keys with differeing hash codes to be co-located on the same node.
org.infinispan.distribution.topologyaware
org.infinispan.interceptors.base	Base interceptors containing common, reusable behavior.
org.infinispan.interceptors.distribution
org.infinispan.interceptors.locking
org.infinispan.interceptors.totalorder
org.infinispan.lucenedemo
org.infinispan.manager	Cache manager package
org.infinispan.notifications.cachelistener.event
org.infinispan.notifications.cachemanagerlistener	CacheManager-specific notifications and eventing.
org.infinispan.notifications.cachemanagerlistener.event
org.infinispan.query.clustered
org.infinispan.query.logging
org.infinispan.remoting	Remote communication between cache instances.
org.infinispan.remoting.responses	Abstractions of the different response types allowed during RPC.
org.infinispan.remoting.rpc	Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
org.infinispan.remoting.transport	Transports handle the low-level networking, used by the remoting components.
org.infinispan.remoting.transport.jgroups	A transport implementation based on JGroups.
org.infinispan.rest
org.infinispan.server.hotrod
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.stats.wrappers
org.infinispan.topology
org.infinispan.transaction	JTA transaction support.
org.infinispan.transaction.xa	XA transaction support.
org.infinispan.transaction.xa.recovery
org.infinispan.util.logging	Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.

Uses of Address in org.infinispan.affinity

Methods in org.infinispan.affinity that return types with arguments of type Address

Modifier and Type	Method and Description
Map<Address,BlockingQueue<K>>	KeyAffinityServiceImpl.getAddress2KeysMapping()

Methods in org.infinispan.affinity with parameters of type Address

Modifier and Type	Method and Description
K	KeyAffinityService.getKeyForAddress(Address address) Returns a key that will be distributed on the cluster node identified by address.
K	KeyAffinityServiceImpl.getKeyForAddress(Address address)

Method parameters in org.infinispan.affinity with type arguments of type Address

Modifier and Type	Method and Description
static <K,V> KeyAffinityService<K>	KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache, Collection<Address> filter, KeyGenerator<K> keyGenerator, Executor ex, int keyBufferSize) Same as KeyAffinityServiceFactory.newKeyAffinityService(org.infinispan.Cache, java.util.Collection, KeyGenerator, java.util.concurrent.Executor, int, boolean) with start == true.
static <K,V> KeyAffinityService<K>	KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache, Collection<Address> filter, KeyGenerator<K> keyGenerator, Executor ex, int keyBufferSize, boolean start) Creates a service that would only generate keys for addresses specified in filter.

Constructor parameters in org.infinispan.affinity with type arguments of type Address

Constructor and Description
KeyAffinityServiceImpl(Executor executor, Cache<? extends K,?> cache, KeyGenerator<? extends K> keyGenerator, int bufferSize, Collection<Address> filter, boolean start)

Uses of Address in org.infinispan.commands

Methods in org.infinispan.commands with parameters of type Address

Modifier and Type	Method and Description
<T> DistributedExecuteCommand<T>	CommandsFactoryImpl.buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys)
<T> DistributedExecuteCommand<T>	CommandsFactory.buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys) Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.
InvalidateCommand	CommandsFactoryImpl.buildInvalidateFromL1Command(Address origin, boolean forRehash, Set<Flag> flags, Collection<Object> keys)
InvalidateCommand	CommandsFactory.buildInvalidateFromL1Command(Address origin, boolean forRehash, Set<Flag> flags, Collection<Object> keys)
StateRequestCommand	CommandsFactoryImpl.buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int viewId, Set<Integer> segments)
StateRequestCommand	CommandsFactory.buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int viewId, Set<Integer> segments) Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.
StateResponseCommand	CommandsFactoryImpl.buildStateResponseCommand(Address sender, int viewId, Collection<StateChunk> stateChunks)
StateResponseCommand	CommandsFactory.buildStateResponseCommand(Address sender, int viewId, Collection<StateChunk> stateChunks) Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.

Uses of Address in org.infinispan.commands.remote

Methods in org.infinispan.commands.remote that return Address

Modifier and Type	Method and Description
Address	BaseRpcCommand.getOrigin()
Address	CacheRpcCommand.getOrigin() Get the origin of the command

Methods in org.infinispan.commands.remote with parameters of type Address

Modifier and Type	Method and Description
void	BaseRpcCommand.setOrigin(Address origin)
void	CacheRpcCommand.setOrigin(Address origin) Set the origin of the command

Uses of Address in org.infinispan.commands.tx

Methods in org.infinispan.commands.tx that return Address

Modifier and Type	Method and Description
Address	AbstractTransactionBoundaryCommand.getOrigin()

Methods in org.infinispan.commands.tx with parameters of type Address

Modifier and Type	Method and Description
void	AbstractTransactionBoundaryCommand.setOrigin(Address origin)

Uses of Address in org.infinispan.commands.write

Methods in org.infinispan.commands.write with parameters of type Address

Modifier and Type	Method and Description
boolean	InvalidateL1Command.isCausedByALocalWrite(Address address) Returns true if the write that caused the invalidation was performed on this node.

Constructors in org.infinispan.commands.write with parameters of type Address

Constructor and Description
InvalidateL1Command(Address writeOrigin, boolean forRehash, DataContainer dc, Configuration config, DistributionManager dm, CacheNotifier notifier, Set<Flag> flags, Collection<Object> keys)

Uses of Address in org.infinispan.context

Methods in org.infinispan.context that return Address

Modifier and Type	Method and Description
Address	SingleKeyNonTxInvocationContext.getOrigin()
Address	InvocationContext.getOrigin() Get the origin of the command, or null if the command originated locally

Methods in org.infinispan.context with parameters of type Address

Modifier and Type	Method and Description
NonTxInvocationContext	NonTransactionalInvocationContextFactory.createRemoteInvocationContext(Address origin)
InvocationContext	InvocationContextFactory.createRemoteInvocationContext(Address origin) Returns an NonTxInvocationContext whose AbstractInvocationContext.isOriginLocal() flag will be true.
NonTxInvocationContext	TransactionalInvocationContextFactory.createRemoteInvocationContext(Address origin)
InvocationContext	AbstractInvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin)
InvocationContext	InvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin) As InvocationContextFactory.createRemoteInvocationContext(org.infinispan.remoting.transport.Address), but returning the flags to the context from the Command if any Flag was set.
RemoteTxInvocationContext	NonTransactionalInvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)
RemoteTxInvocationContext	InvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin) Returns an RemoteTxInvocationContext.
RemoteTxInvocationContext	TransactionalInvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)

Uses of Address in org.infinispan.context.impl

Methods in org.infinispan.context.impl that return Address

Modifier and Type	Method and Description
Address	ImmutableContext.getOrigin()
Address	AbstractInvocationContext.getOrigin()

Methods in org.infinispan.context.impl that return types with arguments of type Address

Modifier and Type	Method and Description
Collection<Address>	LocalTxInvocationContext.getRemoteLocksAcquired()

Methods in org.infinispan.context.impl with parameters of type Address

Modifier and Type	Method and Description
void	AbstractInvocationContext.setOrigin(Address origin)

Method parameters in org.infinispan.context.impl with type arguments of type Address

Modifier and Type	Method and Description
void	LocalTxInvocationContext.remoteLocksAcquired(Collection<Address> nodes)

Uses of Address in org.infinispan.demo

Method parameters in org.infinispan.demo with type arguments of type Address

Modifier and Type	Method and Description
void	InfinispanDemo.ClusterTableModel.setMembers(List<Address> m)

Uses of Address in org.infinispan.distexec

Methods in org.infinispan.distexec that return Address

Modifier and Type	Method and Description
Address	FailoverContext.executionFailureLocation() Returns an Address of the node where the task failed
Address	DistributedTaskFailoverPolicy.failover(FailoverContext context) As parts of distributively executed task can fail due to the task itself throwing an exception or it can be an Infinispan system caused failure (e.g node failed or left cluster during task execution etc).
protected <T> Address	DefaultExecutorService.selectExecutionNode(DistributedTask<T> task)
protected Address	DefaultExecutorService.selectExecutionNode(List<Address> candidates)

Methods in org.infinispan.distexec that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	FailoverContext.executionCandidates() Returns a list of candidates for possible repeated execution governed by installed DistributedTaskFailoverPolicy
protected <T> List<Address>	DefaultExecutorService.executionCandidates(DistributedTask<T> task)
protected List<Address>	DefaultExecutorService.getMembers()
protected <K> Map<Address,List<K>>	DefaultExecutorService.keysToExecutionNodes(DistributedTaskExecutionPolicy policy, K... input)
protected List<Address>	DefaultExecutorService.randomClusterMembers(List<Address> members, int numNeeded)

Methods in org.infinispan.distexec with parameters of type Address

Modifier and Type	Method and Description
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T>	DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task, DistributedExecuteCommand<T> c, Address target, int failoverCount)
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T>	DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task, DistributedExecuteCommand<T> c, List<K> inputKeys, Address target, int failoverCount)
<T> Future<T>	DistributedExecutorService.submit(Address target, Callable<T> task) Submits the given Callable task for execution on the specified target Infinispan node.
<T> Future<T>	DefaultExecutorService.submit(Address target, Callable<T> task)
<T> Future<T>	DistributedExecutorService.submit(Address target, DistributedTask<T> task) Submits the given DistributedTask for execution on the specified target Infinispan node.
<T> Future<T>	DefaultExecutorService.submit(Address target, DistributedTask<T> task)

Method parameters in org.infinispan.distexec with type arguments of type Address

Modifier and Type	Method and Description
protected List<Address>	DefaultExecutorService.randomClusterMembers(List<Address> members, int numNeeded)
protected Address	DefaultExecutorService.selectExecutionNode(List<Address> candidates)

Uses of Address in org.infinispan.distexec.mapreduce

Methods in org.infinispan.distexec.mapreduce that return types with arguments of type Address

Modifier and Type	Method and Description
protected <T> Map<Address,? extends Collection<T>>	MapReduceTask.mapKeysToNodes(Collection<T> keysToMap)
protected <T> Map<Address,? extends Collection<T>>	MapReduceTask.mapKeysToNodes(Collection<T> keysToMap, boolean useIntermediateCompositeKey)
protected <T> Map<Address,? extends Collection<T>>	MapReduceTask.mapKeysToNodes(DistributionManager dm, Collection<T> keysToMap, boolean useIntermediateCompositeKey)
<T> Map<Address,List<T>>	MapReduceManagerImpl.mapKeysToNodes(DistributionManager dm, String taskId, Collection<T> keysToMap, boolean useIntermediateCompositeKey)
<T> Map<Address,List<T>>	MapReduceManager.mapKeysToNodes(DistributionManager dm, String taskId, Collection<T> keysToMap, boolean useIntermediateCompositeKey) Maps Map/Reduce task intermediate or input keys to nodes on Infinispan cluster

Methods in org.infinispan.distexec.mapreduce with parameters of type Address

Modifier and Type	Method and Description
protected <V> org.infinispan.distexec.mapreduce.MapReduceTask.ReduceTaskPart<V>	MapReduceTask.createReducePart(ReduceCommand<KOut,VOut> cmd, Address target, String destCacheName)
protected <V> org.infinispan.distexec.mapreduce.MapReduceTask.MapTaskPart<V>	MapReduceTask.createTaskMapPart(MapCombineCommand<KIn,VIn,KOut,VOut> cmd, Address target, boolean distributedReduce)

Uses of Address in org.infinispan.distribution

Methods in org.infinispan.distribution that return Address

Modifier and Type	Method and Description
Address	DistributionManager.getPrimaryLocation(Object key) Returns the first Address containing the key.
Address	DistributionManagerImpl.getPrimaryLocation(Object key)

Methods in org.infinispan.distribution that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	DistributionManager.locate(Object key) Locates a key in a cluster.
List<Address>	DistributionManagerImpl.locate(Object key)
Set<Address>	DistributionManager.locateAll(Collection<Object> keys) Locates a list of keys in a cluster.
Set<Address>	DistributionManagerImpl.locateAll(Collection<Object> keys)

Methods in org.infinispan.distribution with parameters of type Address

Modifier and Type	Method and Description
void	L1Manager.addRequestor(Object key, Address requestor) Records a request that will be cached in another nodes L1
void	L1ManagerImpl.addRequestor(Object key, Address origin)
Future<Object>	L1Manager.flushCache(Collection<Object> key, Address origin, boolean assumeOriginKeptEntryInL1)
Future<Object>	L1ManagerImpl.flushCache(Collection<Object> keys, Address origin, boolean assumeOriginKeptEntryInL1)
Future<Object>	L1Manager.flushCacheWithSimpleFuture(Collection<Object> keys, Object retval, Address origin, boolean assumeOriginKeptEntryInL1)
Future<Object>	L1ManagerImpl.flushCacheWithSimpleFuture(Collection<Object> keys, Object retval, Address origin, boolean assumeOriginKeptEntryInL1)

Uses of Address in org.infinispan.distribution.ch

Methods in org.infinispan.distribution.ch that return Address

Modifier and Type	Method and Description
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	DefaultConsistentHashFactory.findNewPrimaryOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
Address	DefaultConsistentHashFactory.Builder.getPrimaryOwner(int segment)
Address	ReplicatedConsistentHash.locatePrimaryOwner(Object key)
Address	ConsistentHash.locatePrimaryOwner(Object key) Should be equivalent to return the first element of ConsistentHash.locateOwners(java.lang.Object).
Address	DefaultConsistentHash.locatePrimaryOwner(Object key)
Address	ReplicatedConsistentHash.locatePrimaryOwnerForSegment(int segmentId)
Address	ConsistentHash.locatePrimaryOwnerForSegment(int segmentId)
Address	DefaultConsistentHash.locatePrimaryOwnerForSegment(int segmentId)

Methods in org.infinispan.distribution.ch that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	DefaultConsistentHashFactory.Builder.getBackupOwners(int segment)
Map<Address,Float>	DefaultConsistentHashFactory.Builder.getCapacityFactors()
Map<Address,Float>	DefaultConsistentHash.getCapacityFactors()
List<Address>	DefaultConsistentHashFactory.Builder.getMembers()
List<Address>	ReplicatedConsistentHash.getMembers()
List<Address>	ConsistentHash.getMembers() Should return the addresses of the nodes used to create this consistent hash.
List<Address>	DefaultConsistentHash.getMembers()
List<Address>	DefaultConsistentHashFactory.Builder.getOwners(int segment)
List<Address>	SyncConsistentHashFactory.Builder.getOwners(int i)
List<Address>	SyncConsistentHashFactory.Builder.getSortedMembers()
Set<Address>	ReplicatedConsistentHash.locateAllOwners(Collection<Object> keys)
Set<Address>	ConsistentHash.locateAllOwners(Collection<Object> keys) The logical equivalent of calling ConsistentHash.locateOwners(java.lang.Object) multiple times for each key in the collection of keys and merging the results.
Set<Address>	DefaultConsistentHash.locateAllOwners(Collection<Object> keys)
List<Address>	ReplicatedConsistentHash.locateOwners(Object key)
List<Address>	ConsistentHash.locateOwners(Object key) Finds all the owners of a key.
List<Address>	DefaultConsistentHash.locateOwners(Object key)
List<Address>	ReplicatedConsistentHash.locateOwnersForSegment(int segmentId)
List<Address>	ConsistentHash.locateOwnersForSegment(int segmentId)
List<Address>	DefaultConsistentHash.locateOwnersForSegment(int segmentId)

Methods in org.infinispan.distribution.ch with parameters of type Address

Modifier and Type	Method and Description
boolean	DefaultConsistentHashFactory.Builder.addOwner(int segment, Address owner)
void	DefaultConsistentHashFactory.Builder.addPrimaryOwner(int segment, Address newPrimaryOwner)
void	OwnershipStatistics.decOwned(Address a)
void	OwnershipStatistics.decPrimaryOwned(Address a)
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	DefaultConsistentHashFactory.findNewPrimaryOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
float	DefaultConsistentHashFactory.Builder.getCapacityFactor(Address node)
float	SyncConsistentHashFactory.Builder.getCapacityFactor(Address node)
int	DefaultConsistentHashFactory.Builder.getOwned(Address node)
int	OwnershipStatistics.getOwned(Address a)
float	DefaultConsistentHashFactory.Builder.getOwnedPerCapacity(Address node)
int	OwnershipStatistics.getPrimaryOwned(Address a)
float	DefaultConsistentHashFactory.Builder.getPrimaryOwnedPerCapacity(Address node)
Set<Integer>	ReplicatedConsistentHash.getSegmentsForOwner(Address owner)
Set<Integer>	ConsistentHash.getSegmentsForOwner(Address owner) Returns the segments owned by a cache member.
Set<Integer>	DefaultConsistentHash.getSegmentsForOwner(Address owner)
void	OwnershipStatistics.incOwned(Address a)
void	OwnershipStatistics.incPrimaryOwned(Address a)
boolean	ReplicatedConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key)
boolean	ConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key) Test to see whether a key is owned by a given node.
boolean	DefaultConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key)
boolean	DefaultConsistentHashFactory.Builder.removeOwner(int segment, Address owner)
void	DefaultConsistentHashFactory.Builder.replacePrimaryOwnerWithBackup(int segment, Address newPrimaryOwner)

Method parameters in org.infinispan.distribution.ch with type arguments of type Address

Modifier and Type	Method and Description
boolean	DefaultConsistentHashFactory.Builder.addOwners(int segment, Collection<Address> newOwners)
int	DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners, List<Address> members, Map<Address,Float> capacityFactors)
int	DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	DefaultConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	DefaultConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
CH	ConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors) Create a new consistent hash instance.
CH	ConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors) Create a new consistent hash instance.
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	DefaultConsistentHashFactory.findNewPrimaryOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
protected void	TopologyAwareSyncConsistentHashFactory.populateOwnersFewSegments(SyncConsistentHashFactory.Builder builder, SortedMap<Integer,Address> primarySegments)
protected void	SyncConsistentHashFactory.populateOwnersFewSegments(SyncConsistentHashFactory.Builder builder, SortedMap<Integer,Address> primarySegments)
protected void	TopologyAwareSyncConsistentHashFactory.populateOwnersManySegments(SyncConsistentHashFactory.Builder builder, SortedMap<Integer,Address> primarySegments)
protected void	SyncConsistentHashFactory.populateOwnersManySegments(SyncConsistentHashFactory.Builder builder, SortedMap<Integer,Address> primarySegments)
CH	ConsistentHashFactory.updateMembers(CH baseCH, List<Address> newMembers, Map<Address,Float> capacityFactors) Create a new consistent hash instance, based on an existing instance, but with a new list of members.
CH	ConsistentHashFactory.updateMembers(CH baseCH, List<Address> newMembers, Map<Address,Float> capacityFactors) Create a new consistent hash instance, based on an existing instance, but with a new list of members.
DefaultConsistentHash	DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors) Leavers are removed and segments without owners are assigned new owners.
DefaultConsistentHash	DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors) Leavers are removed and segments without owners are assigned new owners.
DefaultConsistentHash	SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)

Constructor parameters in org.infinispan.distribution.ch with type arguments of type Address

Constructor and Description
DefaultConsistentHash(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
DefaultConsistentHash(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
DefaultConsistentHashFactory.Builder(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHashFactory.Builder(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHashFactory.Builder(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHashFactory.Builder(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
OwnershipStatistics(ConsistentHash ch, List<Address> nodes)
OwnershipStatistics(List<Address> nodes)
ReplicatedConsistentHash(Hash hashFunction, List<Address> members, int[] primaryOwners)

Uses of Address in org.infinispan.distribution.group

Methods in org.infinispan.distribution.group that return Address

Modifier and Type	Method and Description
Address	GroupingConsistentHash.locatePrimaryOwner(Object key)
Address	GroupingConsistentHash.locatePrimaryOwnerForSegment(int segmentId)

Methods in org.infinispan.distribution.group that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	GroupingConsistentHash.getMembers()
Set<Address>	GroupingConsistentHash.locateAllOwners(Collection<Object> keys)
List<Address>	GroupingConsistentHash.locateOwners(Object key)
List<Address>	GroupingConsistentHash.locateOwnersForSegment(int segmentId)

Methods in org.infinispan.distribution.group with parameters of type Address

Modifier and Type	Method and Description
Set<Integer>	GroupingConsistentHash.getSegmentsForOwner(Address owner)
boolean	GroupingConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key)

Uses of Address in org.infinispan.distribution.topologyaware

Methods in org.infinispan.distribution.topologyaware that return types with arguments of type Address

Modifier and Type	Method and Description
Collection<Address>	TopologyInfo.getMachineNodes(String site, String rack, String machine)
Collection<Address>	TopologyInfo.getRackNodes(String site, String rack)
Collection<Address>	TopologyInfo.getSiteNodes(String site)

Methods in org.infinispan.distribution.topologyaware with parameters of type Address

Modifier and Type	Method and Description
int	TopologyInfo.computeExpectedSegments(int numSegments, int numOwners, Address node)
double	TopologyInfo.computeMaxSegmentsForMachine(int numSegments, double numCopies, Collection<org.infinispan.distribution.topologyaware.TopologyInfo.Machine> machines, org.infinispan.distribution.topologyaware.TopologyInfo.Machine machine, Address node)
double	TopologyInfo.computeMaxSegmentsForNode(int numSegments, double numCopies, Collection<Address> nodes, Address node)
double	TopologyInfo.computeMaxSegmentsForRack(int numSegments, double numCopies, Collection<org.infinispan.distribution.topologyaware.TopologyInfo.Rack> racks, org.infinispan.distribution.topologyaware.TopologyInfo.Rack rack, org.infinispan.distribution.topologyaware.TopologyInfo.Machine machine, Address node)
double	TopologyInfo.computeMaxSegmentsForSite(int numSegments, double numCopies, Collection<org.infinispan.distribution.topologyaware.TopologyInfo.Site> sites, org.infinispan.distribution.topologyaware.TopologyInfo.Site site, org.infinispan.distribution.topologyaware.TopologyInfo.Rack rack, org.infinispan.distribution.topologyaware.TopologyInfo.Machine machine, Address node)

Method parameters in org.infinispan.distribution.topologyaware with type arguments of type Address

Modifier and Type	Method and Description
double	TopologyInfo.computeMaxSegmentsForNode(int numSegments, double numCopies, Collection<Address> nodes, Address node)
float	TopologyInfo.computeTotalCapacity(Collection<Address> nodes, Map<Address,Float> capacityFactors)
float	TopologyInfo.computeTotalCapacity(Collection<Address> nodes, Map<Address,Float> capacityFactors)

Constructor parameters in org.infinispan.distribution.topologyaware with type arguments of type Address

Constructor and Description
TopologyInfo(Collection<Address> members, Map<Address,Float> capacityFactors)
TopologyInfo(Collection<Address> members, Map<Address,Float> capacityFactors)

Uses of Address in org.infinispan.interceptors.base

Methods in org.infinispan.interceptors.base that return types with arguments of type Address

Modifier and Type	Method and Description
protected Map<Address,Response>	BaseRpcInterceptor.totalOrderAnycastPrepare(Collection<Address> recipients, PrepareCommand prepareCommand, ResponseFilter responseFilter)
protected Map<Address,Response>	BaseRpcInterceptor.totalOrderBroadcastPrepare(PrepareCommand prepareCommand, ResponseFilter responseFilter)

Method parameters in org.infinispan.interceptors.base with type arguments of type Address

Modifier and Type	Method and Description
protected ResponseFilter	BaseRpcInterceptor.getIgnoreExtraResponseFilter(Collection<Address> recipients)
protected Map<Address,Response>	BaseRpcInterceptor.totalOrderAnycastPrepare(Collection<Address> recipients, PrepareCommand prepareCommand, ResponseFilter responseFilter)

Uses of Address in org.infinispan.interceptors.distribution

Method parameters in org.infinispan.interceptors.distribution with type arguments of type Address

Modifier and Type	Method and Description
protected void	VersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean ignored)
protected void	TxDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean sync)

Uses of Address in org.infinispan.interceptors.locking

Fields in org.infinispan.interceptors.locking declared as Address

Modifier and Type	Field and Description
static Address	ClusteringDependentLogic.LOCAL_MODE_ADDRESS

Methods in org.infinispan.interceptors.locking that return Address

Modifier and Type	Method and Description
Address	ClusteringDependentLogic.getAddress()
Address	ClusteringDependentLogic.LocalLogic.getAddress()
Address	ClusteringDependentLogic.InvalidationLogic.getAddress()
Address	ClusteringDependentLogic.DistributionLogic.getAddress()
Address	ClusteringDependentLogic.getPrimaryOwner(Object key)
Address	ClusteringDependentLogic.LocalLogic.getPrimaryOwner(Object key)
Address	ClusteringDependentLogic.InvalidationLogic.getPrimaryOwner(Object key)
Address	ClusteringDependentLogic.DistributionLogic.getPrimaryOwner(Object key)

Methods in org.infinispan.interceptors.locking that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	ClusteringDependentLogic.getOwners(Collection<Object> keys)
List<Address>	ClusteringDependentLogic.LocalLogic.getOwners(Collection<Object> keys)
List<Address>	ClusteringDependentLogic.InvalidationLogic.getOwners(Collection<Object> keys)
List<Address>	ClusteringDependentLogic.DistributionLogic.getOwners(Collection<Object> affectedKeys)
List<Address>	ClusteringDependentLogic.getOwners(Object key)
List<Address>	ClusteringDependentLogic.LocalLogic.getOwners(Object key)
List<Address>	ClusteringDependentLogic.InvalidationLogic.getOwners(Object key)
List<Address>	ClusteringDependentLogic.DistributionLogic.getOwners(Object key)

Uses of Address in org.infinispan.interceptors.totalorder

Method parameters in org.infinispan.interceptors.totalorder with type arguments of type Address

Modifier and Type	Method and Description
protected void	TotalOrderDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean sync)
protected void	TotalOrderVersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean sync)

Uses of Address in org.infinispan.lucenedemo

Methods in org.infinispan.lucenedemo that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	DemoActions.listAllMembers() Returns a list of Addresses of all members in the cluster

Uses of Address in org.infinispan.manager

Methods in org.infinispan.manager that return Address

Modifier and Type	Method and Description
Address	DefaultCacheManager.getAddress()
Address	EmbeddedCacheManager.getAddress()
Address	AbstractDelegatingEmbeddedCacheManager.getAddress()
Address	DefaultCacheManager.getCoordinator()
Address	EmbeddedCacheManager.getCoordinator()
Address	AbstractDelegatingEmbeddedCacheManager.getCoordinator()

Methods in org.infinispan.manager that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	DefaultCacheManager.getMembers()
List<Address>	EmbeddedCacheManager.getMembers()
List<Address>	AbstractDelegatingEmbeddedCacheManager.getMembers()

Uses of Address in org.infinispan.notifications.cachelistener.event

Methods in org.infinispan.notifications.cachelistener.event that return types with arguments of type Address

Modifier and Type	Method and Description
Collection<Address>	DataRehashedEvent.getMembersAtEnd()
Collection<Address>	EventImpl.getMembersAtEnd()
Collection<Address>	DataRehashedEvent.getMembersAtStart()
Collection<Address>	EventImpl.getMembersAtStart()

Uses of Address in org.infinispan.notifications.cachemanagerlistener

Methods in org.infinispan.notifications.cachemanagerlistener with parameters of type Address

Modifier and Type	Method and Description
void	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifierImpl.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)
void	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId) Notifies all registered listeners of a viewChange event.

Method parameters in org.infinispan.notifications.cachemanagerlistener with type arguments of type Address

Modifier and Type	Method and Description
void	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifierImpl.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)
void	CacheManagerNotifierImpl.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)
void	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId) Notifies all registered listeners of a viewChange event.
void	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId) Notifies all registered listeners of a viewChange event.

Uses of Address in org.infinispan.notifications.cachemanagerlistener.event

Methods in org.infinispan.notifications.cachemanagerlistener.event that return Address

Modifier and Type	Method and Description
Address	EventImpl.getLocalAddress()
Address	ViewChangedEvent.getLocalAddress()

Methods in org.infinispan.notifications.cachemanagerlistener.event that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	EventImpl.getNewMembers()
List<Address>	ViewChangedEvent.getNewMembers() Gets the current list of members.
List<Address>	EventImpl.getOldMembers()
List<Address>	ViewChangedEvent.getOldMembers() Gets the previous list of members.
List<List<Address>>	MergeEvent.getSubgroupsMerged()
List<List<Address>>	EventImpl.getSubgroupsMerged()

Methods in org.infinispan.notifications.cachemanagerlistener.event with parameters of type Address

Modifier and Type	Method and Description
void	EventImpl.setLocalAddress(Address localAddress)

Method parameters in org.infinispan.notifications.cachemanagerlistener.event with type arguments of type Address

Modifier and Type	Method and Description
void	EventImpl.setNewMembers(List<Address> newMembers)
void	EventImpl.setOldMembers(List<Address> oldMembers)
void	EventImpl.setSubgroupsMerged(List<List<Address>> subgroupsMerged)

Constructors in org.infinispan.notifications.cachemanagerlistener.event with parameters of type Address

Constructor and Description
EventImpl(String cacheName, EmbeddedCacheManager cacheManager, Event.Type type, List<Address> newMemberList, List<Address> oldMemberList, Address localAddress, int viewId)

Constructor parameters in org.infinispan.notifications.cachemanagerlistener.event with type arguments of type Address

Constructor and Description
EventImpl(String cacheName, EmbeddedCacheManager cacheManager, Event.Type type, List<Address> newMemberList, List<Address> oldMemberList, Address localAddress, int viewId)
EventImpl(String cacheName, EmbeddedCacheManager cacheManager, Event.Type type, List<Address> newMemberList, List<Address> oldMemberList, Address localAddress, int viewId)

Uses of Address in org.infinispan.query.clustered

Methods in org.infinispan.query.clustered that return Address

Modifier and Type	Method and Description
Address	QueryResponse.getAddress()
Address	ClusteredTopDocs.getNodeAddress()

Methods in org.infinispan.query.clustered with parameters of type Address

Modifier and Type	Method and Description
Object	ClusteredQueryInvoker.getValue(int doc, Address address, UUID queryId) Retrieves the value (using doc index) in a remote query instance
void	QueryResponse.setAddress(Address address)
void	ClusteredTopDocs.setNodeAddress(Address nodeAddress)

Uses of Address in org.infinispan.query.logging

Methods in org.infinispan.query.logging with parameters of type Address

Modifier and Type	Method and Description
void	Log.workListRemotedTo(Object workList, Address primaryNodeAddress)

Uses of Address in org.infinispan.remoting

Methods in org.infinispan.remoting with parameters of type Address

Modifier and Type	Method and Description
void	InboundInvocationHandler.handle(CacheRpcCommand command, Address origin, org.jgroups.blocks.Response response, boolean preserveOrder) Invokes a command on the cache, from a remote source.
void	InboundInvocationHandlerImpl.handle(CacheRpcCommand cmd, Address origin, org.jgroups.blocks.Response response, boolean preserveOrder)

Uses of Address in org.infinispan.remoting.responses

Methods in org.infinispan.remoting.responses with parameters of type Address

Modifier and Type	Method and Description
boolean	ClusteredGetResponseValidityFilter.isAcceptable(Response response, Address address)
boolean	KeysValidateFilter.isAcceptable(Response response, Address sender)
boolean	SelfDeliverFilter.isAcceptable(Response response, Address sender)
boolean	IgnoreExtraResponsesValidityFilter.isAcceptable(Response response, Address address)

Constructors in org.infinispan.remoting.responses with parameters of type Address

Constructor and Description
ClusteredGetResponseValidityFilter(Collection<Address> targets, Address self)
IgnoreExtraResponsesValidityFilter(Collection<Address> targets, Address self, boolean removeSelf)
KeysValidateFilter(Address localAddress, Set<Object> keysAwaitingValidation)
SelfDeliverFilter(Address localAddress)

Constructor parameters in org.infinispan.remoting.responses with type arguments of type Address

Constructor and Description
ClusteredGetResponseValidityFilter(Collection<Address> targets, Address self)
IgnoreExtraResponsesValidityFilter(Collection<Address> targets, Address self, boolean removeSelf)

Uses of Address in org.infinispan.remoting.rpc

Methods in org.infinispan.remoting.rpc that return Address

Modifier and Type	Method and Description
Address	RpcManager.getAddress() Returns the address associated with this RpcManager or null if not part of the cluster.
Address	RpcManagerImpl.getAddress()

Methods in org.infinispan.remoting.rpc that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	RpcManager.getMembers() Returns members of a cluster scoped to the cache owning this RpcManager.
List<Address>	RpcManagerImpl.getMembers()
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue, long timeout)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)

Methods in org.infinispan.remoting.rpc with parameters of type Address

Modifier and Type	Method and Description
boolean	ResponseFilter.isAcceptable(Response response, Address sender) Determines whether a response from a given sender should be added to the response list of the request

Method parameters in org.infinispan.remoting.rpc with type arguments of type Address

Modifier and Type	Method and Description
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue, long timeout)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) Deprecated. this method may be removed in the future. Use RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) Deprecated. this method may be removed in the future. Use #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture)
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout) Deprecated. this method may be removed in the future. Use #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture)
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l, long timeout)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout, boolean ignoreLeavers) Deprecated. this method may be removed in the future. Use #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture)
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l, long timeout, boolean ignoreLeavers)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) Deprecated. this method may be removed in the future. Use #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture)
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> l)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) except that the task is passed to the transport executor and a Future is returned.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options, NotifyingNotifiableFuture<Object> future)

Uses of Address in org.infinispan.remoting.transport

Subinterfaces of Address in org.infinispan.remoting.transport

Modifier and Type	Interface and Description
interface	TopologyAwareAddress Wraps a TopologyUUID JGroups address

Methods in org.infinispan.remoting.transport that return Address

Modifier and Type	Method and Description
Address	AbstractDelegatingTransport.getAddress()
Address	Transport.getAddress() Retrieves the current cache instance's network address
Address	AbstractDelegatingTransport.getCoordinator()
Address	Transport.getCoordinator()

Methods in org.infinispan.remoting.transport that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	AbstractDelegatingTransport.getMembers()
List<Address>	Transport.getMembers() Returns a list of members in the current cluster view.
List<Address>	AbstractDelegatingTransport.getPhysicalAddresses()
List<Address>	Transport.getPhysicalAddresses() Retrieves the current cache instance's physical network addresses.
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)
Map<Address,Response>	Transport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) Invokes an RPC call on other caches in the cluster.

Methods in org.infinispan.remoting.transport with parameters of type Address

Modifier and Type	Method and Description
boolean	AbstractTransport.checkResponse(Object responseObject, Address sender)
protected boolean	AbstractTransport.parseResponseAndAddToResponseList(Object responseObject, Throwable exception, Map<Address,Response> responseListToAddTo, boolean wasSuspected, boolean wasReceived, Address sender, boolean usedResponseFilter, boolean ignoreLeavers)

Method parameters in org.infinispan.remoting.transport with type arguments of type Address

Modifier and Type	Method and Description
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)
Map<Address,Response>	Transport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) Invokes an RPC call on other caches in the cluster.
protected boolean	AbstractTransport.parseResponseAndAddToResponseList(Object responseObject, Throwable exception, Map<Address,Response> responseListToAddTo, boolean wasSuspected, boolean wasReceived, Address sender, boolean usedResponseFilter, boolean ignoreLeavers)

Uses of Address in org.infinispan.remoting.transport.jgroups

Classes in org.infinispan.remoting.transport.jgroups that implement Address

Modifier and Type	Class and Description
class	JGroupsAddress An encapsulation of a JGroups Address
class	JGroupsTopologyAwareAddress An encapsulation of a JGroups Address

Fields in org.infinispan.remoting.transport.jgroups declared as Address

Modifier and Type	Field and Description
protected Address	JGroupsTransport.address
protected Address	JGroupsTransport.coordinator
protected Address	JGroupsTransport.physicalAddress

Fields in org.infinispan.remoting.transport.jgroups with type parameters of type Address

Modifier and Type	Field and Description
protected List<Address>	JGroupsTransport.members

Methods in org.infinispan.remoting.transport.jgroups that return Address

Modifier and Type	Method and Description
Address	JGroupsTransport.getAddress()
Address	JGroupsTransport.getCoordinator()
Address	SuspectException.getSuspect()

Methods in org.infinispan.remoting.transport.jgroups that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	JGroupsTransport.getMembers()
List<Address>	JGroupsTransport.getPhysicalAddresses()
Map<Address,Response>	JGroupsTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)

Methods in org.infinispan.remoting.transport.jgroups with parameters of type Address

Modifier and Type	Method and Description
int	JGroupsAddress.compareTo(Address o)
protected static org.jgroups.Address	JGroupsTransport.toJGroupsAddress(Address a)

Method parameters in org.infinispan.remoting.transport.jgroups with type arguments of type Address

Modifier and Type	Method and Description
Map<Address,Response>	JGroupsTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)

Constructors in org.infinispan.remoting.transport.jgroups with parameters of type Address

Constructor and Description
SuspectException(String msg, Address suspect)
SuspectException(String msg, Address suspect, Throwable cause)

Uses of Address in org.infinispan.rest

Methods in org.infinispan.rest that return Address

Modifier and Type	Method and Description
Address	ManagerInstance.getNodeName()

Uses of Address in org.infinispan.server.hotrod

Classes in org.infinispan.server.hotrod that implement Address

Modifier and Type	Class and Description
class	ServerAddress A Hot Rod server address

Methods in org.infinispan.server.hotrod that return types with arguments of type Address

Modifier and Type	Method and Description
AdvancedCache<Address,ServerAddress>	CrashedMemberDetectorListener.addressCache()
scala.collection.immutable.Map<Address,ServerAddress>	HashDistAware11Response.serverEndpointsMap()
scala.collection.immutable.Map<Address,ServerAddress>	AbstractHashDistAwareResponse.serverEndpointsMap()
scala.collection.immutable.Map<Address,ServerAddress>	TopologyAwareResponse.serverEndpointsMap()
scala.collection.immutable.Map<Address,ServerAddress>	AbstractTopologyResponse.serverEndpointsMap()
scala.collection.immutable.Map<Address,ServerAddress>	HashDistAwareResponse.serverEndpointsMap()

Methods in org.infinispan.server.hotrod with parameters of type Address

Modifier and Type	Method and Description
int	ServerAddress.compareTo(Address o)

Method parameters in org.infinispan.server.hotrod with type arguments of type Address

Modifier and Type	Method and Description
protected AbstractHashDistAwareResponse	AbstractEncoder1x.createHashDistAwareResp(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
protected AbstractHashDistAwareResponse	AbstractTopologyAwareEncoder1x.createHashDistAwareResp(int lastViewId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
AbstractTopologyResponse	AbstractEncoder1x.getTopologyResponse(Response r, Cache<Address,ServerAddress> addressCache, HotRodServer server)
abstract void	AbstractVersionedEncoder.writeHeader(Response r, org.jboss.netty.buffer.ChannelBuffer buf, Cache<Address,ServerAddress> addressCache, HotRodServer server) Write the header to the given channel buffer
void	AbstractEncoder1x.writeHeader(Response r, org.jboss.netty.buffer.ChannelBuffer buf, Cache<Address,ServerAddress> addressCache, HotRodServer server)

Constructor parameters in org.infinispan.server.hotrod with type arguments of type Address

Constructor and Description
AbstractHashDistAwareResponse(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, int numOwners, byte hashFunction, int hashSpace)
AbstractTopologyResponse(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap)
CrashedMemberDetectorListener(Cache<Address,ServerAddress> cache, HotRodServer server)
HashDistAware11Response(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, int numOwners, byte hashFunction, int hashSpace, int numVNodes)
HashDistAwareResponse(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, int numOwners, byte hashFunction, int hashSpace)
TopologyAwareResponse(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap)

Uses of Address in org.infinispan.statetransfer

Methods in org.infinispan.statetransfer that return Address

Modifier and Type	Method and Description
Address	OutboundTransferTask.getDestination()
Address	InboundTransferTask.getSource()

Methods in org.infinispan.statetransfer that return types with arguments of type Address

Modifier and Type	Method and Description
Map<Address,Response>	StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync) If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.
Map<Address,Response>	StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync)

Methods in org.infinispan.statetransfer with parameters of type Address

Modifier and Type	Method and Description
void	StateConsumer.applyState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
void	StateConsumerImpl.applyState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
void	StateProvider.cancelOutboundTransfer(Address destination, int topologyId, Set<Integer> segments) Cancel sending of cache entries that belong to the given set of segments.
void	StateProviderImpl.cancelOutboundTransfer(Address destination, int topologyId, Set<Integer> segments)
Map<Address,Response>	StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync) If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.
Map<Address,Response>	StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync)
List<TransactionInfo>	StateProvider.getTransactionsForSegments(Address destination, int topologyId, Set<Integer> segments) Gets the list of transactions that affect keys from the given segments.
List<TransactionInfo>	StateProviderImpl.getTransactionsForSegments(Address destination, int requestTopologyId, Set<Integer> segments)
void	StateProvider.startOutboundTransfer(Address destination, int topologyId, Set<Integer> segments) Start to send cache entries that belong to the given set of segments.
void	StateProviderImpl.startOutboundTransfer(Address destination, int requestTopologyId, Set<Integer> segments)

Constructors in org.infinispan.statetransfer with parameters of type Address

Constructor and Description
InboundTransferTask(Set<Integer> segments, Address source, int topologyId, StateConsumerImpl stateConsumer, RpcManager rpcManager, CommandsFactory commandsFactory, long timeout, String cacheName)
OutboundTransferTask(Address destination, Set<Integer> segments, int stateTransferChunkSize, int topologyId, ConsistentHash readCh, StateProviderImpl stateProvider, DataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, CommandsFactory commandsFactory, InternalEntryFactory ef, long timeout, String cacheName)
StateRequestCommand(String cacheName, StateRequestCommand.Type type, Address origin, int topologyId, Set<Integer> segments)
StateResponseCommand(String cacheName, Address origin, int topologyId, Collection<StateChunk> stateChunks)

Uses of Address in org.infinispan.stats.wrappers

Methods in org.infinispan.stats.wrappers that return Address

Modifier and Type	Method and Description
Address	ExtendedStatisticRpcManager.getAddress()

Methods in org.infinispan.stats.wrappers that return types with arguments of type Address

Modifier and Type	Method and Description
List<Address>	ExtendedStatisticRpcManager.getMembers()
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)

Method parameters in org.infinispan.stats.wrappers with type arguments of type Address

Modifier and Type	Method and Description
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
void	ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future)
void	ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout)
void	ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout, boolean ignoreLeavers)
void	ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future)
void	ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options, NotifyingNotifiableFuture<Object> future)

Uses of Address in org.infinispan.topology

Methods in org.infinispan.topology that return Address

Modifier and Type	Method and Description
Address	CacheTopologyControlCommand.getOrigin()

Methods in org.infinispan.topology that return types with arguments of type Address

Modifier and Type	Method and Description
Map<Address,Float>	ClusterCacheStatus.getCapacityFactors()
List<Address>	ClusterCacheStatus.getJoiners()
List<Address>	ClusterCacheStatus.getMembers()
List<Address>	CacheTopology.getMembers()
List<Address>	ClusterCacheStatus.pruneInvalidMembers(List<Address> possibleMembers)

Methods in org.infinispan.topology with parameters of type Address

Modifier and Type	Method and Description
boolean	ClusterCacheStatus.addMember(Address joiner, float capacityFactor)
boolean	ClusterCacheStatus.confirmRebalanceOnNode(Address member, int receivedTopologyId)
CacheTopology	ClusterTopologyManager.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId) Updates the members list and notifies the RebalancePolicy.
CacheTopology	ClusterTopologyManagerImpl.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId)
void	ClusterTopologyManager.handleLeave(String cacheName, Address leaver, int viewId) Updates the members list and notifies the RebalancePolicy
void	ClusterTopologyManagerImpl.handleLeave(String cacheName, Address leaver, int viewId)
void	ClusterTopologyManager.handleRebalanceCompleted(String cacheName, Address node, int topologyId, Throwable throwable, int viewId) Marks the rebalance as complete on the sender.
void	ClusterTopologyManagerImpl.handleRebalanceCompleted(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)
boolean	ClusterCacheStatus.removeMember(Address leaver)

Method parameters in org.infinispan.topology with type arguments of type Address

Modifier and Type	Method and Description
protected void	ClusterTopologyManagerImpl.handleNewView(List<Address> ignored, boolean mergeView, int newViewId)
List<Address>	ClusterCacheStatus.pruneInvalidMembers(List<Address> possibleMembers)
void	ClusterTopologyManagerImpl.updateCacheStatusAfterMerge(String cacheName, List<Address> clusterMembers, List<CacheTopology> partitionTopologies)
boolean	ClusterCacheStatus.updateClusterMembers(List<Address> newClusterMembers)
void	ClusterTopologyManagerImpl.updateClusterMembers(List<Address> newClusterMembers)

Constructors in org.infinispan.topology with parameters of type Address

Constructor and Description
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, CacheJoinInfo joinInfo, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, CacheTopology cacheTopology, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, int topologyId, Throwable throwable, int viewId)

Uses of Address in org.infinispan.transaction

Methods in org.infinispan.transaction that return types with arguments of type Address

Modifier and Type	Method and Description
Collection<Address>	LocalTransaction.getCommitNodes(Collection<Address> recipients, int currentTopologyId, Collection<Address> members) Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare was sent.
Collection<Address>	LocalTransaction.getRemoteLocksAcquired()

Method parameters in org.infinispan.transaction with type arguments of type Address

Modifier and Type	Method and Description
Collection<Address>	LocalTransaction.getCommitNodes(Collection<Address> recipients, int currentTopologyId, Collection<Address> members) Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare was sent.
Collection<Address>	LocalTransaction.getCommitNodes(Collection<Address> recipients, int currentTopologyId, Collection<Address> members) Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare was sent.
void	LocalTransaction.locksAcquired(Collection<Address> nodes)

Uses of Address in org.infinispan.transaction.xa

Fields in org.infinispan.transaction.xa declared as Address

Modifier and Type	Field and Description
protected Address	GlobalTransaction.addr

Methods in org.infinispan.transaction.xa that return Address

Modifier and Type	Method and Description
Address	GlobalTransaction.getAddress()

Methods in org.infinispan.transaction.xa with parameters of type Address

Modifier and Type	Method and Description
GlobalTransaction	TransactionFactory.newGlobalTransaction(Address addr, boolean remote)
abstract GlobalTransaction	TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr, boolean remote, VersionGenerator clusterIdGenerator, boolean clustered)
void	GlobalTransaction.setAddress(Address address)

Constructors in org.infinispan.transaction.xa with parameters of type Address

Constructor and Description
DldGlobalTransaction(Address addr, boolean remote)
GlobalTransaction(Address addr, boolean remote)

Uses of Address in org.infinispan.transaction.xa.recovery

Methods in org.infinispan.transaction.xa.recovery that return types with arguments of type Address

Modifier and Type	Method and Description
Set<Address>	InDoubtTxInfoImpl.getOwners()
Set<Address>	RecoveryManager.InDoubtTxInfo.getOwners() Returns the set of nodes where this transaction information is maintained.

Methods in org.infinispan.transaction.xa.recovery with parameters of type Address

Modifier and Type	Method and Description
void	InDoubtTxInfoImpl.addOwner(Address owner)
String	RecoveryManager.forceTransactionCompletionFromCluster(Xid xid, Address where, boolean commit) This method invokes RecoveryManager.forceTransactionCompletion(javax.transaction.xa.Xid, boolean) on the specified node.
String	RecoveryManagerImpl.forceTransactionCompletionFromCluster(Xid xid, Address where, boolean commit)

Method parameters in org.infinispan.transaction.xa.recovery with type arguments of type Address

Modifier and Type	Method and Description
void	RecoveryAwareRemoteTransaction.computeOrphan(Collection<Address> currentMembers) Check's if this transaction's originator is no longer part of the cluster (orphan transaction) and updates RecoveryAwareRemoteTransaction.isOrphan().
void	RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where, long internalId, boolean sync) Same as #removeRecoveryInformationFromCluster(java.util.Collection but the transaction is identified by its internal id, and not by its xid.
void	RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> where, long internalId, boolean sync)
void	RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where, Xid xid, boolean sync, GlobalTransaction gtx) Removes from the specified nodes (or all nodes if the value of 'where' is null) the recovery information associated with these Xids.
void	RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> lockOwners, Xid xid, boolean sync, GlobalTransaction gtx)

Constructors in org.infinispan.transaction.xa.recovery with parameters of type Address

Constructor and Description
RecoveryAwareDldGlobalTransaction(Address addr, boolean remote)
RecoveryAwareGlobalTransaction(Address addr, boolean remote)

Uses of Address in org.infinispan.util.logging

Methods in org.infinispan.util.logging with parameters of type Address

Modifier and Type	Method and Description
void	Log.failedToRequestSegments(Collection<Integer> segments, String cacheName, Address source, Throwable e)
void	Log.failedToRetrieveTransactionsForSegments(Collection<Integer> segments, String cacheName, Address source, Exception e)
void	Log.joinRehashAborted(Address self, String duration)
void	Log.joinRehashCompleted(Address self, String duration)
void	Log.localAndPhysicalAddress(Address address, List<Address> physicalAddresses)
void	Log.rebalanceError(String cacheName, Address node, Throwable cause)
RemoteException	Log.remoteException(Address sender, Exception e)
void	Log.remoteExecutionFailed(Address address, Throwable t)
void	Log.segmentsRequestedByNodeWithOlderTopology(Address node, int requestTopologyId, int localTopologyId)
SuspectException	Log.thirdPartySuspected(Address sender, SuspectException e)
void	Log.transactionsRequestedByNodeWithOlderTopology(Address node, int requestTopologyId, int localTopologyId)
void	Log.unableToLockToInvalidate(Object key, Address address)
void	Log.unableToUnlockRebalancedKeys(GlobalTransaction gtx, List<Object> keys, Address self, Throwable t)

Method parameters in org.infinispan.util.logging with type arguments of type Address

Modifier and Type	Method and Description
void	Log.cannotSelectRandomMembers(int numNeeded, List<Address> members)
void	Log.expectedJustOneResponse(Map<Address,Response> lr)
void	Log.keyDoesNotMapToLocalNode(Object key, Collection<Address> nodes)
void	Log.localAndPhysicalAddress(Address address, List<Address> physicalAddresses)
void	Log.noLiveOwnersFoundForSegment(int segmentId, String cacheName, Collection<Address> owners, Collection<Address> faultySources)
void	Log.noLiveOwnersFoundForSegment(int segmentId, String cacheName, Collection<Address> owners, Collection<Address> faultySources)