Package org.jppf.client.balancer

Class ChannelWrapperLocal

java.lang.Object

org.jppf.client.balancer.ChannelWrapper

org.jppf.client.balancer.ChannelWrapperLocal

All Implemented Interfaces:

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

public class ChannelWrapperLocal
extends ChannelWrapper
implements JPPFClientConnection

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

Author:

Martin JANDA

Field Summary

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

oldStatus

Constructor Summary

Constructors

Constructor	Description
ChannelWrapperLocal(JPPFClient client)	Default initializer for local 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.
void	close()	Shutdown this connection and release all the resources it is using.
protected void	fireStatusChanged(JPPFClientConnectionStatus oldStatus, JPPFClientConnectionStatus newStatus)	Notify all listeners that the status of this connection has changed.
JPPFConnectionPool	getConnectionPool()	Get the pool this connection belongs to.
String	getConnectionUuid()	Get the unique ID for this connection and its two channels.
String	getDriverUuid()	Get the unique identifier of the remote driver.
String	getHost()	Get the driver's host name or ip address.
String	getName()	Get the name assigned to this client connection.
int	getPort()	Get the port number on which the dirver is listeneing for connections.
JPPFClientConnectionStatus	getStatus()	Get the status of this connection.
org.jppf.management.JPPFSystemInformation	getSystemInfo()	Get the system information for the remote driver this connection refers to.
String	getUuid()
boolean	isClosed()	Determine whether this connection was closed.
boolean	isLocal()	Determine whether this connection is local, that is, whether it executes jobs in the local JVM.
boolean	isSSLEnabled()	Determines if this connection is over SSL.
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.
Future<?>	submit(ClientTaskBundle bundle)
String	toString()

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

addExecutionStatusListener, checkBundler, fireExecutionStatusChanged, getBundler, getCurrentNbJobs, getExecutionStatus, getManagementInfo, getMonitor, getOldStatus, getPriority, getSystemInformation, initChannelID, isActive, isResetting, removeExecutionStatusListener, setManagementInfo, setOldStatus, setResetting, setSystemInformation

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

Methods inherited from interface org.jppf.client.JPPFClientConnection

getPriority

Constructor Details

ChannelWrapperLocal

public ChannelWrapperLocal(JPPFClient client)

Default initializer for local channel wrapper.

Parameters:

client - reference to the JPPF client.

Method Details

getUuid

public String getUuid()

Specified by:

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

getConnectionUuid

public String getConnectionUuid()

Description copied from interface: JPPFClientConnection

Get the unique ID for this connection and its two channels.

Specified by:

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

Specified by:

getConnectionUuid in interface JPPFClientConnection

Returns:

the id as a string.

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.

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.

fireStatusChanged

protected void fireStatusChanged(JPPFClientConnectionStatus oldStatus,
 JPPFClientConnectionStatus newStatus)

Notify all listeners that the status of this connection has changed.

Parameters:

oldStatus - the connection status before the change.

newStatus - the connection status after the change.

submit

public Future<?> submit(ClientTaskBundle bundle)

Specified by:

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

isLocal

public boolean isLocal()

Description copied from interface: JPPFClientConnection

Determine whether this connection is local, that is, whether it executes jobs in the local JVM.

Specified by:

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

Specified by:

isLocal in interface JPPFClientConnection

Returns:

true if this connection is local, false otherwise.

toString

public String toString()

Overrides:

toString in class Object

close

public void close()

Description copied from interface: JPPFClientConnection

Shutdown this connection and release all the resources it is using.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface JPPFClientConnection

Overrides:

close in class ChannelWrapper

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.

isClosed

public boolean isClosed()

Description copied from interface: JPPFClientConnection

Determine whether this connection was closed.

Specified by:

isClosed in interface JPPFClientConnection

Returns:

whether this channel is closed.

getName

public String getName()

Description copied from interface: JPPFClientConnection

Get the name assigned to this client connection.

Specified by:

getName in interface JPPFClientConnection

Returns:

the name as a string.

isSSLEnabled

public boolean isSSLEnabled()

Description copied from interface: JPPFClientConnection

Determines if this connection is over SSL.

Specified by:

isSSLEnabled in interface JPPFClientConnection

Returns:

true if this is an SSL connection, false otherwise.

getHost

public String getHost()

Description copied from interface: JPPFClientConnection

Get the driver's host name or ip address.

Specified by:

getHost in interface JPPFClientConnection

Returns:

the host as a stirng.

getPort

public int getPort()

Description copied from interface: JPPFClientConnection

Get the port number on which the dirver is listeneing for connections.

Specified by:

getPort in interface JPPFClientConnection

Returns:

the port number as an int.

getDriverUuid

public String getDriverUuid()

Description copied from interface: JPPFClientConnection

Get the unique identifier of the remote driver.

Specified by:

getDriverUuid in interface JPPFClientConnection

Returns:

the uuid as a string.

getSystemInfo

public org.jppf.management.JPPFSystemInformation getSystemInfo()

Description copied from interface: JPPFClientConnection

Get the system information for the remote driver this connection refers to.

Specified by:

getSystemInfo in interface JPPFClientConnection

Returns:

a JPPFSystemInformation instance.

getConnectionPool

public JPPFConnectionPool getConnectionPool()

Description copied from interface: JPPFClientConnection

Get the pool this connection belongs to.

Specified by:

getConnectionPool in interface JPPFClientConnection

Returns:

a JPPFConnectionPool instance.