org.infinispan.remoting.transport
Class AbstractTransport

java.lang.Object
  org.infinispan.remoting.transport.AbstractTransport

All Implemented Interfaces:

Lifecycle, Transport

Direct Known Subclasses:

JGroupsTransport

public abstract class AbstractTransport
extends Object
implements Transport

Common transport-related behaviour

Version:

4.2

Author:

Manik Surtani

Field Summary

protected GlobalConfiguration

configuration

Constructor Summary

AbstractTransport()

Method Summary

protected boolean	parseResponseAndAddToResponseList(Object responseObject, Map<Address,Response> responseListToAddTo, boolean wasSuspected, boolean wasReceived, Address sender, boolean usedResponseFilter)
void	setConfiguration(GlobalConfiguration globalConfiguration)
protected boolean	shouldThrowException(Exception ce)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.remoting.transport.Transport

getAddress, getCoordinator, getDistributedSync, getLog, getMembers, getPhysicalAddresses, getViewId, initialize, invokeRemotely, isCoordinator, isMulticastCapable, isSupportStateTransfer, retrieveState, start, stop

Field Detail

configuration

protected GlobalConfiguration configuration

Constructor Detail

AbstractTransport

public AbstractTransport()

Method Detail

setConfiguration

public void setConfiguration(GlobalConfiguration globalConfiguration)

Specified by:

setConfiguration in interface Transport

shouldThrowException

protected final boolean shouldThrowException(Exception ce)

parseResponseAndAddToResponseList

protected boolean parseResponseAndAddToResponseList(Object responseObject,
                                                    Map<Address,Response> responseListToAddTo,
                                                    boolean wasSuspected,
                                                    boolean wasReceived,
                                                    Address sender,
                                                    boolean usedResponseFilter)
                                             throws Exception

Throws:

Exception