com.digitalpetri.opcua.sdk.server.subscriptions

Class Subscription

java.lang.Object

com.digitalpetri.opcua.sdk.server.subscriptions.Subscription

public class Subscription
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Subscription.State
static interface	Subscription.StateListener

Constructor Summary

Constructors

Constructor and Description
Subscription(SubscriptionManager subscriptionManager, com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, double publishingInterval, long maxKeepAliveCount, long lifetimeCount, long maxNotificationsPerPublish, boolean publishingEnabled, int priority)

Method Summary

Modifier and Type	Method and Description
com.digitalpetri.opcua.stack.core.types.builtin.StatusCode	acknowledge(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger sequenceNumber)
void	addMonitoredItems(List<BaseMonitoredItem<?>> createdItems)
List<BaseMonitoredItem<?>>	deleteSubscription()
com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger[]	getAvailableSequenceNumbers()
com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger	getId()
long	getLifetimeCount()
long	getMaxKeepAliveCount()
int	getMaxNotificationsPerPublish()
Map<com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger,BaseMonitoredItem<?>>	getMonitoredItems()
int	getPriority()
double	getPublishingInterval()
Session	getSession()
SubscriptionManager	getSubscriptionManager()
boolean	isPublishingEnabled()
void	modifySubscription(com.digitalpetri.opcua.stack.core.types.structured.ModifySubscriptionRequest request)
long	nextItemId()
void	removeMonitoredItems(List<BaseMonitoredItem<?>> deletedItems)
com.digitalpetri.opcua.stack.core.types.structured.NotificationMessage	republish(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger sequenceNumber)
void	setPublishingMode(com.digitalpetri.opcua.stack.core.types.structured.SetPublishingModeRequest request)
void	setStateListener(Subscription.StateListener listener)
void	setSubscriptionManager(SubscriptionManager subscriptionManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

Subscription

public Subscription(SubscriptionManager subscriptionManager,
                    com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId,
                    double publishingInterval,
                    long maxKeepAliveCount,
                    long lifetimeCount,
                    long maxNotificationsPerPublish,
                    boolean publishingEnabled,
                    int priority)

Method Detail

modifySubscription

public void modifySubscription(com.digitalpetri.opcua.stack.core.types.structured.ModifySubscriptionRequest request)

deleteSubscription

public List<BaseMonitoredItem<?>> deleteSubscription()

setPublishingMode

public void setPublishingMode(com.digitalpetri.opcua.stack.core.types.structured.SetPublishingModeRequest request)

addMonitoredItems

public void addMonitoredItems(List<BaseMonitoredItem<?>> createdItems)

removeMonitoredItems

public void removeMonitoredItems(List<BaseMonitoredItem<?>> deletedItems)

getMonitoredItems

public Map<com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger,BaseMonitoredItem<?>> getMonitoredItems()

getId

public com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger getId()

getPublishingInterval

public double getPublishingInterval()

getMaxKeepAliveCount

public long getMaxKeepAliveCount()

getLifetimeCount

public long getLifetimeCount()

getMaxNotificationsPerPublish

public int getMaxNotificationsPerPublish()

isPublishingEnabled

public boolean isPublishingEnabled()

getPriority

public int getPriority()

getAvailableSequenceNumbers

public com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger[] getAvailableSequenceNumbers()

getSubscriptionManager

public SubscriptionManager getSubscriptionManager()

setSubscriptionManager

public void setSubscriptionManager(SubscriptionManager subscriptionManager)

getSession

public Session getSession()

nextItemId

public long nextItemId()

setStateListener

public void setStateListener(Subscription.StateListener listener)

acknowledge

public com.digitalpetri.opcua.stack.core.types.builtin.StatusCode acknowledge(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger sequenceNumber)

republish

public com.digitalpetri.opcua.stack.core.types.structured.NotificationMessage republish(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger sequenceNumber)