org.eclipse.scada.da.server.common.io

Class JobManager

java.lang.Object

org.eclipse.scada.da.server.common.io.JobManager

Direct Known Subclasses:

DaveJobManager, ModbusJobManager

public class JobManager
extends Object

Constructor Summary

Constructors

Constructor and Description
JobManager(ScheduledExecutorService executor)
JobManager(String threadName)

Method Summary

Modifier and Type	Method and Description
void	addBlock(String id, PollRequest block)
void	addWriteRequest(Object request, long timeout)
void	dispose()
protected void	handleDataDisconnected()
void	handleException(Throwable e)
protected boolean	isCurrentJobTimeout()
void	messageReceived(Object message)
void	removeBlock(String id) Remove and dispose a block
void	setSession(org.apache.mina.core.session.IoSession session)
protected void	tick()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobManager

public JobManager(String threadName)

JobManager

public JobManager(ScheduledExecutorService executor)

Method Detail

setSession

public void setSession(org.apache.mina.core.session.IoSession session)

messageReceived

public void messageReceived(Object message)

tick

protected void tick()

isCurrentJobTimeout

protected boolean isCurrentJobTimeout()

handleException

public void handleException(Throwable e)

dispose

public void dispose()

handleDataDisconnected

protected void handleDataDisconnected()

addBlock

public void addBlock(String id,
                     PollRequest block)

removeBlock

public void removeBlock(String id)

Remove and dispose a block

Parameters:

id - the id of the block to remove

addWriteRequest

public void addWriteRequest(Object request,
                            long timeout)