org.eclipse.scada.ae.client.net

Class ConnectionImpl

java.lang.Object

org.eclipse.scada.core.client.net.ConnectionBase

org.eclipse.scada.core.client.net.SessionConnectionBase

org.eclipse.scada.ae.client.net.ConnectionImpl

All Implemented Interfaces:

org.apache.mina.core.service.IoHandler, Connection, StatisticsProvider

public class ConnectionImpl
extends SessionConnectionBase
implements Connection

Field Summary

Fields

Modifier and Type	Field and Description
static String	VERSION

Fields inherited from class org.eclipse.scada.core.client.net.SessionConnectionBase

executor, SESSION_CLIENT_VERSION

Fields inherited from class org.eclipse.scada.core.client.net.ConnectionBase

messenger, session, statistics

Constructor Summary

Constructors

Constructor and Description
ConnectionImpl(ConnectionInformation connectionInformantion)

Method Summary

Methods

Modifier and Type	Method and Description
NotifyFuture<Void>	acknowledge(String monitorId, Date aknTimestamp, OperationParameters operationParameters, CallbackHandler callbackHandler) Acknowledge the monitor if the akn state was reached at or before the provided timestamp
void	addBrowserListener(BrowserListener listener) Add browser listener
void	closeQuery(long queryId)
Query	createQuery(String queryType, String queryData, QueryListener listener)
protected void	fireBrowserListener(List<BrowserEntry> added, Set<String> removed, boolean full)
Executor	getExecutor()
String	getRequiredVersion()
protected void	handleBrowserUpdate(Message message)
protected void	handleConditionData(Message message)
protected void	handleConditionStatus(Message message)
protected void	handleEventData(Message message)
protected void	handleEventStatus(Message message)
protected void	handleQueryData(Message message)
protected void	handleQueryStateChange(Message message)
protected void	init()
void	loadMore(long queryId, int count)
protected void	onConnectionBound()
void	removeBrowserListener(BrowserListener listener)
void	sessionClosed(org.apache.mina.core.session.IoSession session)
void	setEventListener(String eventQueryId, EventListener listener) Set the listener that should receive event updates
void	setMonitorListener(String conditionQueryId, MonitorListener listener) Set the listener that should receive monitor updates

Methods inherited from class org.eclipse.scada.core.client.net.SessionConnectionBase

addPrivilegeListener, dispose, getPrivileges, handlePrivChange, modifyFilterChain, onConnectionClosed, onConnectionEstablished, processSessionReply, removePrivilegeListener, requestSession

Methods inherited from class org.eclipse.scada.core.client.net.ConnectionBase

addConnectionStateListener, cancelConnection, connect, connect, connectFailed, disconnect, disconnect, exceptionCaught, finalize, getConnectionInformation, getConnectTimeout, getIntProperty, getMessageTimeout, getPingPeriod, getSessionProperties, getSocketReceiveBufferSize, getSocketSendBufferSize, getState, getStatistics, isConnected, messageReceived, messageSent, performConnect, performLookup, removeConnectionStateListener, resolvedRemoteAddress, sessionCreated, sessionIdle, sessionOpened, setBound, setCallbackFactory, setupConnector, switchState

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.scada.core.client.Connection

addConnectionStateListener, addPrivilegeListener, connect, connect, disconnect, dispose, getConnectionInformation, getPrivileges, getSessionProperties, getState, removeConnectionStateListener, removePrivilegeListener, setCallbackFactory

Field Detail

VERSION

public static final String VERSION

See Also:

Constant Field Values

Constructor Detail

ConnectionImpl

public ConnectionImpl(ConnectionInformation connectionInformantion)

Method Detail

getRequiredVersion

public String getRequiredVersion()

Specified by:

getRequiredVersion in class SessionConnectionBase

init

protected void init()

handleQueryData

protected void handleQueryData(Message message)

handleQueryStateChange

protected void handleQueryStateChange(Message message)

handleBrowserUpdate

protected void handleBrowserUpdate(Message message)

handleEventData

protected void handleEventData(Message message)

handleConditionData

protected void handleConditionData(Message message)

handleEventStatus

protected void handleEventStatus(Message message)

handleConditionStatus

protected void handleConditionStatus(Message message)

getExecutor

public Executor getExecutor()

createQuery

public Query createQuery(String queryType,
                String queryData,
                QueryListener listener)

setMonitorListener

public void setMonitorListener(String conditionQueryId,
                      MonitorListener listener)

Description copied from interface: Connection

Set the listener that should receive monitor updates

setEventListener

public void setEventListener(String eventQueryId,
                    EventListener listener)

Description copied from interface: Connection

Set the listener that should receive event updates

onConnectionBound

protected void onConnectionBound()

Overrides:

onConnectionBound in class ConnectionBase

sessionClosed

public void sessionClosed(org.apache.mina.core.session.IoSession session)
                   throws Exception

Specified by:

sessionClosed in interface org.apache.mina.core.service.IoHandler

Overrides:

sessionClosed in class ConnectionBase

Throws:

Exception

addBrowserListener

public void addBrowserListener(BrowserListener listener)

Description copied from interface: Connection

Add browser listener

Parameters:

listener - the listener to add

removeBrowserListener

public void removeBrowserListener(BrowserListener listener)

fireBrowserListener

protected void fireBrowserListener(List<BrowserEntry> added,
                       Set<String> removed,
                       boolean full)

acknowledge

public NotifyFuture<Void> acknowledge(String monitorId,
                             Date aknTimestamp,
                             OperationParameters operationParameters,
                             CallbackHandler callbackHandler)

Description copied from interface: Connection

Acknowledge the monitor if the akn state was reached at or before the provided timestamp

Parameters:

monitorId - the id of the condition

aknTimestamp - the timestamp up to which the state may be acknowledged

operationParameters - optionally provide some user information which performs the aknowledgement. If the information is not provided the current logged in user will be used. If the information is present but the current logged in user is not allowed to change the user performing acknowledgement the server may fall back to use the actual information of the logged in user instead.

closeQuery

public void closeQuery(long queryId)

loadMore

public void loadMore(long queryId,
            int count)