org.eclipse.scada.ae.server.common

Class ServiceImpl

java.lang.Object

org.eclipse.scada.core.server.common.ServiceCommon<S,SI>

org.eclipse.scada.core.server.common.osgi.AbstractServiceImpl<Session,SessionImpl>

org.eclipse.scada.ae.server.common.ServiceImpl

All Implemented Interfaces:

EventListener, Service<Session>, LifecycleAware, org.osgi.framework.ServiceListener

public class ServiceImpl
extends AbstractServiceImpl<Session,SessionImpl>
implements Service, org.osgi.framework.ServiceListener

Field Summary

Fields inherited from class org.eclipse.scada.core.server.common.osgi.AbstractServiceImpl

authorizationProvider, sessions

Fields inherited from class org.eclipse.scada.core.server.common.ServiceCommon

DEFAULT_RESULT

Constructor Summary

Constructors

Constructor and Description
ServiceImpl(org.osgi.framework.BundleContext context, Executor executor)

Method Summary

Modifier and Type	Method and Description
NotifyFuture<Void>	acknowledge(Session session, String monitorId, Date aknTimestamp, OperationParameters operationParameters, CallbackHandler callbackHandler)
protected void	addEventQuery(String id, EventQuery query)
protected void	addMonitorQuery(String id, MonitorQuery query)
void	closeSession(Session session) Close the provided session Closing the session includes: unregistering from all items, canceling all running operations
Query	createQuery(Session session, String queryType, String queryData, QueryListener listener)
protected SessionImpl	createSessionInstance(UserInformation user, Map<String,String> sessionProperties)
protected void	processAcknowledge(String monitorId, Date aknTimestamp, OperationParameters operationParameters, CallbackHandler callbackHandler)
protected void	removeEventQuery(String id, EventQuery query)
protected void	removeMonitorQuery(String id, MonitorQuery query)
void	serviceChanged(org.osgi.framework.ServiceEvent event)
void	start()
void	stop()
void	subscribeConditionQuery(Session session, String queryId)
void	subscribeEventQuery(Session session, String queryId)
protected void	triggerBrowserChange(List<BrowserEntry> entries, Set<String> removed, boolean full)
void	unsubscribeConditionQuery(Session session, String queryId)
void	unsubscribeEventQuery(Session session, String queryId)

Methods inherited from class org.eclipse.scada.core.server.common.osgi.AbstractServiceImpl

createSession, createSession, handleSessionClosed, handleSessionCreated, validateSession

Methods inherited from class org.eclipse.scada.core.server.common.ServiceCommon

authorize, authorize, extractPrivileges, fillSessionProperties, loginUser, makeEffectiveUserInformation, setAuditLogService, setAuthenticationImplementation, setAuthorizationImplementation

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.server.Service

createSession

Constructor Detail

ServiceImpl

public ServiceImpl(org.osgi.framework.BundleContext context,
                   Executor executor)
            throws org.osgi.framework.InvalidSyntaxException

Throws:

org.osgi.framework.InvalidSyntaxException

Method Detail

acknowledge

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

Throws:

InvalidSessionException

processAcknowledge

protected void processAcknowledge(String monitorId,
                                  Date aknTimestamp,
                                  OperationParameters operationParameters,
                                  CallbackHandler callbackHandler)

addMonitorQuery

protected void addMonitorQuery(String id,
                               MonitorQuery query)

removeMonitorQuery

protected void removeMonitorQuery(String id,
                                  MonitorQuery query)

addEventQuery

protected void addEventQuery(String id,
                             EventQuery query)

removeEventQuery

protected void removeEventQuery(String id,
                                EventQuery query)

triggerBrowserChange

protected void triggerBrowserChange(List<BrowserEntry> entries,
                                    Set<String> removed,
                                    boolean full)

createQuery

public Query createQuery(Session session,
                         String queryType,
                         String queryData,
                         QueryListener listener)
                  throws InvalidSessionException

Throws:

InvalidSessionException

subscribeConditionQuery

public void subscribeConditionQuery(Session session,
                                    String queryId)
                             throws InvalidSessionException,
                                    UnknownQueryException

Throws:

InvalidSessionException

UnknownQueryException

unsubscribeConditionQuery

public void unsubscribeConditionQuery(Session session,
                                      String queryId)
                               throws InvalidSessionException

Throws:

InvalidSessionException

subscribeEventQuery

public void subscribeEventQuery(Session session,
                                String queryId)
                         throws InvalidSessionException,
                                UnknownQueryException

Throws:

InvalidSessionException

UnknownQueryException

unsubscribeEventQuery

public void unsubscribeEventQuery(Session session,
                                  String queryId)
                           throws InvalidSessionException

Throws:

InvalidSessionException

closeSession

public void closeSession(Session session)
                  throws InvalidSessionException

Description copied from interface: Service

Close the provided session Closing the session includes: unregistering from all items, canceling all running operations

Specified by:

closeSession in interface Service<Session>

Overrides:

closeSession in class AbstractServiceImpl<Session,SessionImpl>

Parameters:

session - the session to close

Throws:

InvalidSessionException - In the case the session is not a valid session

createSessionInstance

protected SessionImpl createSessionInstance(UserInformation user,
                                            Map<String,String> sessionProperties)

Specified by:

createSessionInstance in class AbstractServiceImpl<Session,SessionImpl>

start

public void start()
           throws Exception

Specified by:

start in interface LifecycleAware

Overrides:

start in class AbstractServiceImpl<Session,SessionImpl>

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface LifecycleAware

Overrides:

stop in class AbstractServiceImpl<Session,SessionImpl>

Throws:

Exception

serviceChanged

public void serviceChanged(org.osgi.framework.ServiceEvent event)

Specified by:

serviceChanged in interface org.osgi.framework.ServiceListener