Modifier | Constructor and Description |
---|---|
protected |
AbstractDelegatingTransport(Transport actual) |
Modifier and Type | Method and Description |
---|---|
protected BackupResponse |
afterBackupRemotely(ReplicableCommand command,
BackupResponse response)
method invoked after a successful backup remote invocation.
|
protected Map<Address,Response> |
afterInvokeRemotely(ReplicableCommand command,
Map<Address,Response> responseMap)
method invoked after a successful remote invocation.
|
BackupResponse |
backupRemotely(Collection<XSiteBackup> backups,
XSiteReplicateCommand rpcCommand) |
protected void |
beforeBackupRemotely(XSiteReplicateCommand command)
method invoked before a backup remote invocation.
|
protected void |
beforeInvokeRemotely(ReplicableCommand command)
method invoked before a remote invocation.
|
void |
checkTotalOrderSupported()
check if the transport has configured with total order deliver properties (has the sequencer in JGroups
protocol stack.
|
Address |
getAddress()
Retrieves the current cache instance's network address
|
Address |
getCoordinator() |
Transport |
getDelegate() |
Log |
getLog() |
List<Address> |
getMembers()
Returns a list of members in the current cluster view.
|
List<Address> |
getPhysicalAddresses()
Retrieves the current cache instance's physical network addresses.
|
int |
getViewId() |
Map<Address,Response> |
invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
boolean |
isCoordinator() |
boolean |
isMulticastCapable()
Tests whether the transport supports true multicast
|
void |
start()
Invoked on component start
|
void |
stop()
Invoked on component stop
|
void |
waitForView(int viewId) |
protected final Transport actual
protected AbstractDelegatingTransport(Transport actual)
public Map<Address,Response> invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast) throws Exception
Transport
invokeRemotely
in interface Transport
recipients
- a list of Addresses to invoke the call on. If this is null, the call is broadcast to the
entire cluster.rpcCommand
- the cache command to invokemode
- the response mode to usetimeout
- a timeout after which to throw a replication exception. implementations.responseFilter
- a response filter with which to filter out failed/unwanted/invalid responses.deliverOrder
- the DeliverOrder
.anycast
- used when is true
, it means that it must use TOA instead of
TOB.Exception
- in the event of problems.public Map<Address,Response> invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) throws Exception
invokeRemotely
in interface Transport
Exception
public Map<Address,Response> invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast) throws Exception
invokeRemotely
in interface Transport
Exception
public CompletableFuture<Map<Address,Response>> invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast) throws Exception
invokeRemotelyAsync
in interface Transport
Exception
public BackupResponse backupRemotely(Collection<XSiteBackup> backups, XSiteReplicateCommand rpcCommand) throws Exception
backupRemotely
in interface Transport
Exception
public boolean isCoordinator()
isCoordinator
in interface Transport
public Address getCoordinator()
getCoordinator
in interface Transport
public Address getAddress()
Transport
getAddress
in interface Transport
public List<Address> getPhysicalAddresses()
Transport
Transport.getAddress()
.getPhysicalAddresses
in interface Transport
public List<Address> getMembers()
Transport
getMembers
in interface Transport
public boolean isMulticastCapable()
Transport
isMulticastCapable
in interface Transport
public void start()
Lifecycle
public void stop()
Lifecycle
public void waitForView(int viewId) throws InterruptedException
waitForView
in interface Transport
InterruptedException
public void checkTotalOrderSupported()
Transport
checkTotalOrderSupported
in interface Transport
public Transport getDelegate()
protected void beforeInvokeRemotely(ReplicableCommand command)
command
- the command to be invoked remotelyprotected Map<Address,Response> afterInvokeRemotely(ReplicableCommand command, Map<Address,Response> responseMap)
command
- the command invoked remotely.responseMap
- can be null if not response is expected.protected void beforeBackupRemotely(XSiteReplicateCommand command)
command
- the command to be invoked remotelyprotected BackupResponse afterBackupRemotely(ReplicableCommand command, BackupResponse response)
command
- the command invoked remotely.response
- can be null if not response is expected.Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.