org.jppf.client

Class AbstractClientConnectionHandler

java.lang.Object

org.jppf.client.AbstractClientConnectionHandler

All Implemented Interfaces:

ClientConnectionHandler

public abstract class AbstractClientConnectionHandler
extends Object
implements ClientConnectionHandler

Common abstract superclass for client connections to a server.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	host The name or IP address of the host the class server is running on.
protected List<ClientConnectionStatusListener>	listeners List of status listeners for this connection.
protected String	name The name given to this connection handler.
protected JPPFClientConnection	owner The client connection which owns this connection handler.
protected int	port The TCP port the class server is listening to.
protected SocketWrapper	socketClient The socket client uses to communicate over a socket connection.
protected SocketInitializer	socketInitializer Used to synchronize access to the underlying socket from multiple threads.
protected AtomicReference<JPPFClientConnectionStatus>	status Status of the connection.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractClientConnectionHandler(JPPFClientConnection owner, String name) Initialize this connection with the specified owner.

Method Summary

Methods

Modifier and Type	Method and Description
void	addClientConnectionStatusListener(ClientConnectionStatusListener listener) Add a connection status listener to this connection's list of listeners.
void	close() Close and cleanup this connection handler.
protected abstract SocketInitializer	createSocketInitializer() Create a socket initializer for this connection handler.
protected void	createSSLConnection() Create the ssl connection over an established plain connection.
protected void	fireStatusChanged(JPPFClientConnectionStatus oldStatus) Notify all listeners that the status of this connection has changed.
SocketWrapper	getSocketClient() Get the socket client used to communicate over a socket connection.
JPPFClientConnectionStatus	getStatus() Get the status of this connection.
void	removeClientConnectionStatusListener(ClientConnectionStatusListener listener) Remove a connection status listener from this connection's list of listeners.
void	setStatus(JPPFClientConnectionStatus newStatus) Set the status of this connection.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jppf.client.ClientConnectionHandler

init, initSocketClient

Field Detail

socketClient

protected SocketWrapper socketClient

The socket client uses to communicate over a socket connection.

socketInitializer

protected SocketInitializer socketInitializer

Used to synchronize access to the underlying socket from multiple threads.

host

protected String host

The name or IP address of the host the class server is running on.

port

protected int port

The TCP port the class server is listening to.

owner

protected JPPFClientConnection owner

The client connection which owns this connection handler.

name

protected String name

The name given to this connection handler.

status

protected final AtomicReference<JPPFClientConnectionStatus> status

Status of the connection.

listeners

protected final List<ClientConnectionStatusListener> listeners

List of status listeners for this connection.

Constructor Detail

AbstractClientConnectionHandler

protected AbstractClientConnectionHandler(JPPFClientConnection owner,
                               String name)

Initialize this connection with the specified owner.

Parameters:

owner - the client connection which owns this connection handler.

name - the name given to this connection.

Method Detail

getStatus

public JPPFClientConnectionStatus getStatus()

Get the status of this connection.

Returns:

a JPPFClientConnectionStatus enumerated value.

See Also:

ClientConnectionStatusHandler.getStatus()

setStatus

public void setStatus(JPPFClientConnectionStatus newStatus)

Set the status of this connection.

Parameters:

newStatus - a JPPFClientConnectionStatus enumerated value.

See Also:

ClientConnectionStatusHandler.setStatus(org.jppf.client.JPPFClientConnectionStatus)

addClientConnectionStatusListener

public void addClientConnectionStatusListener(ClientConnectionStatusListener listener)

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

Parameters:

listener - the listener to add to the list.

See Also:

ClientConnectionStatusHandler.addClientConnectionStatusListener(org.jppf.client.event.ClientConnectionStatusListener)

removeClientConnectionStatusListener

public void removeClientConnectionStatusListener(ClientConnectionStatusListener listener)

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

Parameters:

listener - the listener to remove from the list.

See Also:

ClientConnectionStatusHandler.removeClientConnectionStatusListener(org.jppf.client.event.ClientConnectionStatusListener)

createSocketInitializer

protected abstract SocketInitializer createSocketInitializer()

Create a socket initializer for this connection handler.

Returns:

a SocketInitializer instance.

fireStatusChanged

protected void fireStatusChanged(JPPFClientConnectionStatus oldStatus)

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

Parameters:

oldStatus - the connection status before the change.

getSocketClient

public SocketWrapper getSocketClient()
                              throws Exception

Get the socket client used to communicate over a socket connection.

Specified by:

getSocketClient in interface ClientConnectionHandler

Returns:

a SocketWrapper instance.

Throws:

Exception - if any error occurs.

createSSLConnection

protected void createSSLConnection()
                            throws Exception

Create the ssl connection over an established plain connection.

Throws:

Exception - if any error occurs.

close

public void close()

Description copied from interface: ClientConnectionHandler

Close and cleanup this connection handler.

Specified by:

close in interface ClientConnectionHandler