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

Class AbstractConnectionDevice

java.lang.Object

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

Direct Known Subclasses:

DaveDevice, ModbusMaster

public abstract class AbstractConnectionDevice
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractConnectionDevice.ConnectionState

Field Summary

Fields

Modifier and Type	Field and Description
protected org.osgi.framework.BundleContext	context
protected ScheduledExecutorService	executor
protected String	id
protected DataItemFactory	itemFactory

Constructor Summary

Constructors

Constructor and Description
AbstractConnectionDevice(org.osgi.framework.BundleContext context, String id, org.apache.mina.transport.socket.nio.NioProcessor processor, ScheduledExecutorService executor, String itemPrefix)
AbstractConnectionDevice(org.osgi.framework.BundleContext context, String id, org.apache.mina.transport.socket.nio.NioProcessor processor, String threadPrefix, String itemPrefix)

Method Summary

Modifier and Type	Method and Description
protected void	checkSession(org.apache.mina.core.session.IoSession session)
protected void	configure(Map<String,String> properties)
protected abstract void	configureConnector(org.apache.mina.transport.socket.nio.NioSocketConnector connector)
protected void	disconnect()
void	dispose()
protected ScheduledExecutorService	getExecutor()
String	getItemId(String localId)
protected static int	getTimeout(Map<String,String> properties, String specificTimeoutKey, int defaultValue)
String	getVarItemId(String localId)
protected void	handleExceptionCaught(org.apache.mina.core.session.IoSession session, Throwable error)
protected void	handleMessageReceived(org.apache.mina.core.session.IoSession session, Object message)
protected void	handleMessageSent(org.apache.mina.core.session.IoSession session, Object message)
protected void	handleSessionClosed(org.apache.mina.core.session.IoSession session)
protected void	handleSessionCreated(org.apache.mina.core.session.IoSession session)
protected void	handleSessionDisconnected()
protected void	handleSessionIdle(org.apache.mina.core.session.IoSession session, org.apache.mina.core.session.IdleStatus status)
protected void	handleSessionOpened(org.apache.mina.core.session.IoSession session)
protected void	performDispose()
protected void	setSession(org.apache.mina.core.session.IoSession session)

Methods inherited from class java.lang.Object

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

Field Detail

executor

protected final ScheduledExecutorService executor

context

protected final org.osgi.framework.BundleContext context

id

protected final String id

itemFactory

protected final DataItemFactory itemFactory

Constructor Detail

AbstractConnectionDevice

public AbstractConnectionDevice(org.osgi.framework.BundleContext context,
                                String id,
                                org.apache.mina.transport.socket.nio.NioProcessor processor,
                                ScheduledExecutorService executor,
                                String itemPrefix)

AbstractConnectionDevice

public AbstractConnectionDevice(org.osgi.framework.BundleContext context,
                                String id,
                                org.apache.mina.transport.socket.nio.NioProcessor processor,
                                String threadPrefix,
                                String itemPrefix)

Method Detail

getItemId

public String getItemId(String localId)

getVarItemId

public String getVarItemId(String localId)

getExecutor

protected ScheduledExecutorService getExecutor()

dispose

public void dispose()

performDispose

protected void performDispose()

configure

protected void configure(Map<String,String> properties)
                  throws Exception

Throws:

Exception

getTimeout

protected static int getTimeout(Map<String,String> properties,
                                String specificTimeoutKey,
                                int defaultValue)

configureConnector

protected abstract void configureConnector(org.apache.mina.transport.socket.nio.NioSocketConnector connector)

setSession

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

handleSessionDisconnected

protected void handleSessionDisconnected()

disconnect

protected void disconnect()

handleExceptionCaught

protected void handleExceptionCaught(org.apache.mina.core.session.IoSession session,
                                     Throwable error)
                              throws Exception

Throws:

Exception

handleMessageReceived

protected void handleMessageReceived(org.apache.mina.core.session.IoSession session,
                                     Object message)
                              throws Exception

Throws:

Exception

handleMessageSent

protected void handleMessageSent(org.apache.mina.core.session.IoSession session,
                                 Object message)
                          throws Exception

Throws:

Exception

checkSession

protected void checkSession(org.apache.mina.core.session.IoSession session)

handleSessionClosed

protected void handleSessionClosed(org.apache.mina.core.session.IoSession session)
                            throws Exception

Throws:

Exception

handleSessionCreated

protected void handleSessionCreated(org.apache.mina.core.session.IoSession session)
                             throws Exception

Throws:

Exception

handleSessionIdle

protected void handleSessionIdle(org.apache.mina.core.session.IoSession session,
                                 org.apache.mina.core.session.IdleStatus status)
                          throws Exception

Throws:

Exception

handleSessionOpened

protected void handleSessionOpened(org.apache.mina.core.session.IoSession session)
                            throws Exception

Throws:

Exception