org.eclipse.scada.ae.server.net

Class ServerConnectionHandler

java.lang.Object

org.eclipse.scada.core.server.net.AbstractServerConnectionHandler

org.eclipse.scada.ae.server.net.ServerConnectionHandler

All Implemented Interfaces:

org.apache.mina.handler.multiton.SingleSessionIoHandler, BrowserListener

public class ServerConnectionHandler
extends AbstractServerConnectionHandler
implements BrowserListener

Field Summary

Fields

Modifier and Type	Field and Description
static String	VERSION

Fields inherited from class org.eclipse.scada.core.server.net.AbstractServerConnectionHandler

connectionInformation, ioSession, messenger, pingService

Constructor Summary

Constructors

Constructor and Description
ServerConnectionHandler(Service service, org.apache.mina.core.session.IoSession ioSession, ConnectionInformation connectionInformation)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	acknowledge(Message message)
protected void	cleanUp()
void	dataChanged(List<BrowserEntry> addedOrUpdated, Set<String> removed, boolean full)
void	dataChangedConditions(String subscriptionId, List<MonitorStatusInformation> addedOrUpdated, Set<String> removed, boolean full)
void	dataChangedEvents(String poolId, List<Event> addedEvents)
protected void	handleCreateSessionComplete(Future<Session> future, Message message, Properties props)
protected void	queryClose(Message message)
protected void	queryCreate(Message message)
protected void	queryLoadMore(Message message)
void	sendQueryData(QueryImpl queryImpl, List<Event> events)
void	sendQueryState(QueryImpl queryImpl, QueryState state, Throwable error)
void	statusChangedConditions(String subscriptionId, SubscriptionState status)
void	statusChangedEvents(String poolId, SubscriptionState status)
protected void	subscribeEventPool(Message message)
protected void	subscribeMonitors(Message message)
protected void	unsubscribeEventPool(Message message)
protected void	unsubscribeMonitors(Message message)

Methods inherited from class org.eclipse.scada.core.server.net.AbstractServerConnectionHandler

createDefaultContext, exceptionCaught, getBooleanProperty, getIntProperty, getMessageTimeout, getPingPeriod, getTransportProperties, messageReceived, messageSent, modifyFilterChain, replySessionCreated, sendPrivilegeChange, sessionClosed, sessionConfigured, sessionCreated, sessionIdle, sessionOpened, startSession

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final String VERSION

See Also:

Constant Field Values

Constructor Detail

ServerConnectionHandler

public ServerConnectionHandler(Service service,
                       org.apache.mina.core.session.IoSession ioSession,
                       ConnectionInformation connectionInformation)

Method Detail

queryCreate

protected void queryCreate(Message message)

queryClose

protected void queryClose(Message message)

queryLoadMore

protected void queryLoadMore(Message message)

acknowledge

protected void acknowledge(Message message)

subscribeEventPool

protected void subscribeEventPool(Message message)

unsubscribeEventPool

protected void unsubscribeEventPool(Message message)

subscribeMonitors

protected void subscribeMonitors(Message message)

unsubscribeMonitors

protected void unsubscribeMonitors(Message message)

handleCreateSessionComplete

protected void handleCreateSessionComplete(Future<Session> future,
                               Message message,
                               Properties props)

Since:

1.1

cleanUp

protected void cleanUp()

Overrides:

cleanUp in class AbstractServerConnectionHandler

dataChangedEvents

public void dataChangedEvents(String poolId,
                     List<Event> addedEvents)

statusChangedEvents

public void statusChangedEvents(String poolId,
                       SubscriptionState status)

dataChangedConditions

public void dataChangedConditions(String subscriptionId,
                         List<MonitorStatusInformation> addedOrUpdated,
                         Set<String> removed,
                         boolean full)

statusChangedConditions

public void statusChangedConditions(String subscriptionId,
                           SubscriptionState status)

dataChanged

public void dataChanged(List<BrowserEntry> addedOrUpdated,
               Set<String> removed,
               boolean full)

Specified by:

dataChanged in interface BrowserListener

sendQueryData

public void sendQueryData(QueryImpl queryImpl,
                 List<Event> events)

sendQueryState

public void sendQueryState(QueryImpl queryImpl,
                  QueryState state,
                  Throwable error)