com.digitalpetri.opcua.sdk.server.subscriptions

Class SubscriptionManager

java.lang.Object

com.digitalpetri.opcua.sdk.server.subscriptions.SubscriptionManager

public class SubscriptionManager
extends Object

Constructor Summary

Constructors

Constructor and Description
SubscriptionManager(Session session, OpcUaServer server)

Method Summary

Modifier and Type	Method and Description
void	addSubscription(Subscription subscription)
void	createMonitoredItems(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.CreateMonitoredItemsRequest,com.digitalpetri.opcua.stack.core.types.structured.CreateMonitoredItemsResponse> service)
void	createSubscription(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.CreateSubscriptionRequest,com.digitalpetri.opcua.stack.core.types.structured.CreateSubscriptionResponse> service)
void	deleteMonitoredItems(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.DeleteMonitoredItemsRequest,com.digitalpetri.opcua.stack.core.types.structured.DeleteMonitoredItemsResponse> service)
void	deleteSubscription(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.DeleteSubscriptionsRequest,com.digitalpetri.opcua.stack.core.types.structured.DeleteSubscriptionsResponse> service)
PublishQueue	getPublishQueue()
OpcUaServer	getServer()
Session	getSession()
void	modifyMonitoredItems(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.ModifyMonitoredItemsRequest,com.digitalpetri.opcua.stack.core.types.structured.ModifyMonitoredItemsResponse> service)
void	modifySubscription(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.ModifySubscriptionRequest,com.digitalpetri.opcua.stack.core.types.structured.ModifySubscriptionResponse> service)
void	publish(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.PublishRequest,com.digitalpetri.opcua.stack.core.types.structured.PublishResponse> service)
Subscription	removeSubscription(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId)
void	republish(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.RepublishRequest,com.digitalpetri.opcua.stack.core.types.structured.RepublishResponse> service)
void	sendStatusChangeNotification(Subscription subscription)
void	sessionClosed(boolean deleteSubscriptions)
void	setMonitoringMode(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.SetMonitoringModeRequest,com.digitalpetri.opcua.stack.core.types.structured.SetMonitoringModeResponse> service)
void	setPublishingMode(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.SetPublishingModeRequest,com.digitalpetri.opcua.stack.core.types.structured.SetPublishingModeResponse> service)
void	setTriggering(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.SetTriggeringRequest,com.digitalpetri.opcua.stack.core.types.structured.SetTriggeringResponse> service)

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriptionManager

public SubscriptionManager(Session session,
                           OpcUaServer server)

Method Detail

getSession

public Session getSession()

getPublishQueue

public PublishQueue getPublishQueue()

getServer

public OpcUaServer getServer()

createSubscription

public void createSubscription(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.CreateSubscriptionRequest,com.digitalpetri.opcua.stack.core.types.structured.CreateSubscriptionResponse> service)

modifySubscription

public void modifySubscription(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.ModifySubscriptionRequest,com.digitalpetri.opcua.stack.core.types.structured.ModifySubscriptionResponse> service)

deleteSubscription

public void deleteSubscription(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.DeleteSubscriptionsRequest,com.digitalpetri.opcua.stack.core.types.structured.DeleteSubscriptionsResponse> service)

setPublishingMode

public void setPublishingMode(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.SetPublishingModeRequest,com.digitalpetri.opcua.stack.core.types.structured.SetPublishingModeResponse> service)

createMonitoredItems

public void createMonitoredItems(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.CreateMonitoredItemsRequest,com.digitalpetri.opcua.stack.core.types.structured.CreateMonitoredItemsResponse> service)

modifyMonitoredItems

public void modifyMonitoredItems(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.ModifyMonitoredItemsRequest,com.digitalpetri.opcua.stack.core.types.structured.ModifyMonitoredItemsResponse> service)

deleteMonitoredItems

public void deleteMonitoredItems(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.DeleteMonitoredItemsRequest,com.digitalpetri.opcua.stack.core.types.structured.DeleteMonitoredItemsResponse> service)

setMonitoringMode

public void setMonitoringMode(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.SetMonitoringModeRequest,com.digitalpetri.opcua.stack.core.types.structured.SetMonitoringModeResponse> service)

publish

public void publish(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.PublishRequest,com.digitalpetri.opcua.stack.core.types.structured.PublishResponse> service)

republish

public void republish(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.RepublishRequest,com.digitalpetri.opcua.stack.core.types.structured.RepublishResponse> service)

setTriggering

public void setTriggering(com.digitalpetri.opcua.stack.core.application.services.ServiceRequest<com.digitalpetri.opcua.stack.core.types.structured.SetTriggeringRequest,com.digitalpetri.opcua.stack.core.types.structured.SetTriggeringResponse> service)

sessionClosed

public void sessionClosed(boolean deleteSubscriptions)

removeSubscription

public Subscription removeSubscription(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId)

addSubscription

public void addSubscription(Subscription subscription)

sendStatusChangeNotification

public void sendStatusChangeNotification(Subscription subscription)