Package org.jppf.client.balancer

Class AbstractChannelWrapperRemote

java.lang.Object

org.jppf.client.balancer.ChannelWrapper

org.jppf.client.balancer.AbstractChannelWrapperRemote

All Implemented Interfaces:

AutoCloseable, ClientConnectionStatusHandler, org.jppf.execute.ExecutorChannel<ClientTaskBundle>

Direct Known Subclasses:

ChannelWrapperRemoteAsync

public abstract class AbstractChannelWrapperRemote
extends ChannelWrapper
implements ClientConnectionStatusHandler

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

Author:

Martin JANDA, Laurent Cohen

Field Summary

Fields

Modifier and Type	Field	Description
protected String	uuid	Unique identifier of the client.

Fields inherited from class org.jppf.client.balancer.ChannelWrapper

oldStatus

Constructor Summary

Constructors

Constructor	Description
AbstractChannelWrapperRemote(JPPFClientConnection channel)	Default initializer for remote channel wrapper.

Method Summary

Modifier and Type	Method	Description
void	addClientConnectionStatusListener(ClientConnectionStatusListener listener)	Add a connection status listener to this connection's list of listeners.
boolean	cancel(ClientTaskBundle bundle)	Cancel the currently executing job, if any.
JPPFClientConnection	getChannel()	Get the wrapped channel.
String	getConnectionUuid()
JPPFClientConnectionStatus	getStatus()	Get the status of this connection.
String	getUuid()
void	initChannelID()	Init the channel id for load-balancer persistence.
boolean	isLocal()
void	removeClientConnectionStatusListener(ClientConnectionStatusListener listener)	Remove a connection status listener from this connection's list of listeners.
void	setStatus(JPPFClientConnectionStatus status)	Set the status of this connection.
void	setSystemInformation(org.jppf.management.JPPFSystemInformation systemInfo)	Set the system information.
String	toString()

Methods inherited from class org.jppf.client.balancer.ChannelWrapper

addExecutionStatusListener, checkBundler, close, 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

Methods inherited from interface org.jppf.execute.ExecutorChannel

getMaxJobs, isAsynchronous, submit

Field Details

uuid

protected String uuid

Unique identifier of the client.

Constructor Details

AbstractChannelWrapperRemote

public AbstractChannelWrapperRemote(JPPFClientConnection channel)

Default initializer for remote channel wrapper.

Parameters:

channel - to the driver to use.

Method Details

setSystemInformation

public void setSystemInformation(org.jppf.management.JPPFSystemInformation systemInfo)

Description copied from class: ChannelWrapper

Set the system information.

Overrides:

setSystemInformation in class ChannelWrapper

Parameters:

systemInfo - a JPPFSystemInformation instance.

initChannelID

public void initChannelID()

Description copied from class: ChannelWrapper

Init the channel id for load-balancer persistence.

Overrides:

initChannelID in class ChannelWrapper

getUuid

public String getUuid()

Specified by:

getUuid in interface org.jppf.execute.ExecutorChannel<ClientTaskBundle>

getConnectionUuid

public String getConnectionUuid()

Specified by:

getConnectionUuid in interface org.jppf.execute.ExecutorChannel<ClientTaskBundle>

getStatus

public JPPFClientConnectionStatus getStatus()

Description copied from class: ChannelWrapper

Get the status of this connection.

Specified by:

getStatus in interface ClientConnectionStatusHandler

Specified by:

getStatus in class ChannelWrapper

Returns:

a JPPFClientConnectionStatus enumerated value.

setStatus

public void setStatus(JPPFClientConnectionStatus status)

Description copied from interface: ClientConnectionStatusHandler

Set the status of this connection.

Specified by:

setStatus in interface ClientConnectionStatusHandler

Parameters:

status - a JPPFClientConnectionStatus enumerated value.

getChannel

public JPPFClientConnection getChannel()

Get the wrapped channel.

Returns:

a AbstractJPPFClientConnection instance.

addClientConnectionStatusListener

public void addClientConnectionStatusListener(ClientConnectionStatusListener listener)

Description copied from class: ChannelWrapper

Add a connection status listener to this connection's list of listeners.

Specified by:

addClientConnectionStatusListener in interface ClientConnectionStatusHandler

Specified by:

addClientConnectionStatusListener in class ChannelWrapper

Parameters:

listener - the listener to add to the list.

removeClientConnectionStatusListener

public void removeClientConnectionStatusListener(ClientConnectionStatusListener listener)

Description copied from class: ChannelWrapper

Remove a connection status listener from this connection's list of listeners.

Specified by:

removeClientConnectionStatusListener in interface ClientConnectionStatusHandler

Specified by:

removeClientConnectionStatusListener in class ChannelWrapper

Parameters:

listener - the listener to remove from the list.

isLocal

public boolean isLocal()

Specified by:

isLocal in interface org.jppf.execute.ExecutorChannel<ClientTaskBundle>

cancel

public boolean cancel(ClientTaskBundle bundle)

Description copied from class: ChannelWrapper

Cancel the currently executing job, if any.

Specified by:

cancel in class ChannelWrapper

Parameters:

bundle - the bundle to cancel.

Returns:

true if the job is effectively cancelled, false otherwise.

toString

public String toString()

Overrides:

toString in class Object