org.eclipse.scada.ca.client.ngp

Class ConnectionImpl

java.lang.Object

org.eclipse.scada.core.client.common.BaseConnection

org.eclipse.scada.core.client.common.ClientBaseConnection

org.eclipse.scada.core.client.ngp.ConnectionBaseImpl

org.eclipse.scada.ca.client.ngp.ConnectionImpl

All Implemented Interfaces:

Connection, StatisticsProvider

public class ConnectionImpl
extends ConnectionBaseImpl
implements Connection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ConnectionImpl.ErrorAwareFuture<Res extends ResponseMessage,M>

Field Summary

Fields inherited from class org.eclipse.scada.core.client.common.ClientBaseConnection

connectCallbackHandler

Fields inherited from class org.eclipse.scada.core.client.common.BaseConnection

connectionInformation, executor, statistics

Constructor Summary

Constructors

Constructor and Description
ConnectionImpl(ConnectionInformation connectionInformation)
ConnectionImpl(ConnectionInformation connectionInformation, org.apache.mina.core.service.IoProcessor<org.apache.mina.transport.socket.nio.NioSession> processor) Create a new connection

Method Summary

Modifier and Type	Method and Description
void	addFactoriesListener(FactoriesListener listener)
NotifyFuture<Void>	applyDiff(List<DiffEntry> changeSet, OperationParameters operationParameters, CallbackHandler callbackHandler)
NotifyFuture<ConfigurationInformation>	getConfiguration(String factoryId, String configurationId)
NotifyFuture<FactoryInformation[]>	getFactories()
NotifyFuture<FactoryInformation>	getFactoryWithData(String factoryId)
protected void	onConnectionBound() Called when the connection got bound
protected void	onConnectionClosed() Called when the connection got closed
void	removeFactoriesListener(FactoriesListener listener)
protected void	setFactories(FactoryInformation[] factories)

Methods inherited from class org.eclipse.scada.core.client.ngp.ConnectionBaseImpl

handleMessage, makeProperties, nextRequest, onConnectionConnected, processCallbackFuture, registerCallbackHandler, sendRequestMessage, setCallbackFactory

Methods inherited from class org.eclipse.scada.core.client.common.ClientBaseConnection

addConnectionStateListener, addPrivilegeListener, connect, connect, disconnect, dispose, firePrivilegeChange, getPrivileges, getSession, getSslSession, getState, handleConnectComplete, isDisposed, messageReceived, performClosed, performDisconnected, performOpened, removeConnectionStateListener, removePrivilegeListener, sendMessage, sendMessageChecked, setState, switchState

Methods inherited from class org.eclipse.scada.core.client.common.BaseConnection

getConnectionInformation, getSessionProperties, getStatistics, setSessionProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, 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

Constructor Detail

ConnectionImpl

public ConnectionImpl(ConnectionInformation connectionInformation)
               throws Exception

Throws:

Exception

ConnectionImpl

public ConnectionImpl(ConnectionInformation connectionInformation,
                      org.apache.mina.core.service.IoProcessor<org.apache.mina.transport.socket.nio.NioSession> processor)
               throws Exception

Create a new connection

Parameters:

connectionInformation - the information where to connect to

processor - the socket processor, may be null to use the default

Throws:

Exception - if anything goes wrong

Method Detail

onConnectionBound

protected void onConnectionBound()

Description copied from class: ClientBaseConnection

Called when the connection got bound

This method is called while the connection lock is held.

The default implementation does nothing.

Overrides:

onConnectionBound in class ClientBaseConnection

onConnectionClosed

protected void onConnectionClosed()

Description copied from class: ClientBaseConnection

Called when the connection got closed

This method is called while the connection lock is held.

The default implementation does nothing.

Overrides:

onConnectionClosed in class ConnectionBaseImpl

setFactories

protected void setFactories(FactoryInformation[] factories)

addFactoriesListener

public void addFactoriesListener(FactoriesListener listener)

removeFactoriesListener

public void removeFactoriesListener(FactoriesListener listener)

getFactories

public NotifyFuture<FactoryInformation[]> getFactories()

getFactoryWithData

public NotifyFuture<FactoryInformation> getFactoryWithData(String factoryId)

getConfiguration

public NotifyFuture<ConfigurationInformation> getConfiguration(String factoryId,
                                                               String configurationId)

applyDiff

public NotifyFuture<Void> applyDiff(List<DiffEntry> changeSet,
                                    OperationParameters operationParameters,
                                    CallbackHandler callbackHandler)