ChannelWrapperRemoteAsync (JPPF)

java.lang.Object

org.jppf.client.balancer.ChannelWrapper

org.jppf.client.balancer.AbstractChannelWrapperRemote

org.jppf.client.balancer.ChannelWrapperRemoteAsync

All Implemented Interfaces:: AutoCloseable, ClientConnectionStatusHandler, org.jppf.execute.ExecutorChannel<ClientTaskBundle>

public class ChannelWrapperRemoteAsync extends AbstractChannelWrapperRemote

Context associated with a remote channel serving state and tasks submission.

Author:: Martin JANDA, Laurent Cohen

Field Summary

Fields inherited from class org.jppf.client.balancer.AbstractChannelWrapperRemote
uuid

Fields inherited from class org.jppf.client.balancer.ChannelWrapper
oldStatus
Constructor Summary

Constructors

Constructor

Description

ChannelWrapperRemoteAsync(JPPFClientConnection channel)

Default initializer for remote channel wrapper.
Method Summary

Modifier and Type

Method

Description

void

close()

int

getMaxJobs()

void

initChannelID()

Init the channel id for load-balancer persistence.

boolean

isAsynchronous()

boolean

isLocal()

Future<?>

submit(ClientTaskBundle bundle)

String

toString()

Methods inherited from class org.jppf.client.balancer.AbstractChannelWrapperRemote
addClientConnectionStatusListener, cancel, getChannel, getConnectionUuid, getStatus, getUuid, removeClientConnectionStatusListener, setStatus, setSystemInformation

Methods inherited from class org.jppf.client.balancer.ChannelWrapper
addExecutionStatusListener, checkBundler, fireExecutionStatusChanged, getBundler, getCurrentNbJobs, getExecutionStatus, getManagementInfo, getMonitor, getOldStatus, getPriority, getSystemInformation, isActive, isResetting, removeExecutionStatusListener, setManagementInfo, setOldStatus, setResetting

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- ChannelWrapperRemoteAsync
  
  public ChannelWrapperRemoteAsync(JPPFClientConnection channel)
  
  Default initializer for remote channel wrapper.
  
  Parameters:
  
  channel - to the driver to use.
Method Details
- initChannelID
  
  public void initChannelID()
  
  Description copied from class: ChannelWrapper
  
  Init the channel id for load-balancer persistence.
  
  Overrides:
  
  initChannelID in class AbstractChannelWrapperRemote
- submit
  
  public Future<?> submit(ClientTaskBundle bundle)
- isLocal
  
  public boolean isLocal()
  
  Specified by:
  
  isLocal in interface org.jppf.execute.ExecutorChannel<ClientTaskBundle>
  
  Overrides:
  
  isLocal in class AbstractChannelWrapperRemote
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable
  
  Overrides:
  
  close in class ChannelWrapper
- isAsynchronous
  
  public boolean isAsynchronous()
- getMaxJobs
  
  public int getMaxJobs()
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class AbstractChannelWrapperRemote