com.digitalpetri.opcua.sdk.server.items

Class BaseMonitoredItem<ValueType>

java.lang.Object

com.digitalpetri.opcua.sdk.server.items.BaseMonitoredItem<ValueType>

All Implemented Interfaces:

MonitoredItem

Direct Known Subclasses:

MonitoredDataItem, MonitoredEventItem

public abstract class BaseMonitoredItem<ValueType>
extends Object
implements MonitoredItem

Field Summary

Fields

Modifier and Type	Field and Description
protected long	clientHandle
protected boolean	discardOldest
protected com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger	id
protected com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode	monitoringMode
protected RingBuffer<ValueType>	queue
protected int	queueSize
protected com.digitalpetri.opcua.stack.core.types.structured.ReadValueId	readValueId
protected double	samplingInterval
protected com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger	subscriptionId
protected com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn	timestamps
protected boolean	triggered
protected Map<com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger,BaseMonitoredItem<?>>	triggeredItems

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

BaseMonitoredItem(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger id, com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, com.digitalpetri.opcua.stack.core.types.structured.ReadValueId readValueId, com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode, com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn timestamps, com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger clientHandle, double samplingInterval, com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger queueSize, boolean discardOldest)

Method Summary

Modifier and Type	Method and Description
protected abstract void	enqueue(ValueType value)
long	getClientHandle()
abstract com.digitalpetri.opcua.stack.core.types.builtin.ExtensionObject	getFilterResult()
com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger	getId()
com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode	getMonitoringMode()
boolean	getNotifications(List<com.digitalpetri.opcua.stack.core.serialization.UaStructure> notifications, int max)
int	getQueueSize()
com.digitalpetri.opcua.stack.core.types.structured.ReadValueId	getReadValueId()
double	getSamplingInterval()
com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger	getSubscriptionId()
com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn	getTimestampsToReturn()
Map<com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger,BaseMonitoredItem<?>>	getTriggeredItems()
boolean	hasNotifications()
protected abstract void	installFilter(com.digitalpetri.opcua.stack.core.types.builtin.ExtensionObject filterXo)
boolean	isDiscardOldest()
boolean	isTriggered()
void	modify(com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn timestamps, com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger clientHandle, double samplingInterval, com.digitalpetri.opcua.stack.core.types.builtin.ExtensionObject filter, com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger queueSize, boolean discardOldest)
void	setMonitoringMode(com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode)
protected void	setQueueSize(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger queueSize)
protected abstract com.digitalpetri.opcua.stack.core.serialization.UaStructure	wrapQueueValue(ValueType value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.digitalpetri.opcua.sdk.server.api.MonitoredItem

isSamplingEnabled

Field Detail

triggeredItems

protected volatile Map<com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger,BaseMonitoredItem<?>> triggeredItems

triggered

protected volatile boolean triggered

queue

protected volatile RingBuffer<ValueType> queue

clientHandle

protected volatile long clientHandle

queueSize

protected volatile int queueSize

samplingInterval

protected volatile double samplingInterval

discardOldest

protected volatile boolean discardOldest

id

protected final com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger id

subscriptionId

protected final com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId

readValueId

protected final com.digitalpetri.opcua.stack.core.types.structured.ReadValueId readValueId

monitoringMode

protected volatile com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode

timestamps

protected volatile com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn timestamps

Constructor Detail

BaseMonitoredItem

protected BaseMonitoredItem(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger id,
                            com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId,
                            com.digitalpetri.opcua.stack.core.types.structured.ReadValueId readValueId,
                            com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode,
                            com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn timestamps,
                            com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger clientHandle,
                            double samplingInterval,
                            com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger queueSize,
                            boolean discardOldest)

Method Detail

setQueueSize

protected void setQueueSize(com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger queueSize)

getNotifications

public boolean getNotifications(List<com.digitalpetri.opcua.stack.core.serialization.UaStructure> notifications,
                                int max)

hasNotifications

public boolean hasNotifications()

modify

public void modify(com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn timestamps,
                   com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger clientHandle,
                   double samplingInterval,
                   com.digitalpetri.opcua.stack.core.types.builtin.ExtensionObject filter,
                   com.digitalpetri.opcua.stack.core.types.builtin.unsigned.UInteger queueSize,
                   boolean discardOldest)
            throws com.digitalpetri.opcua.stack.core.UaException

Throws:

com.digitalpetri.opcua.stack.core.UaException

enqueue

protected abstract void enqueue(ValueType value)

setMonitoringMode

public void setMonitoringMode(com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode)

getId

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

Specified by:

getId in interface MonitoredItem

Returns:

the server-side id of this item.

getSubscriptionId

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

Specified by:

getSubscriptionId in interface MonitoredItem

Returns:

the id of the Subscription this item belongs to.

getReadValueId

public com.digitalpetri.opcua.stack.core.types.structured.ReadValueId getReadValueId()

Specified by:

getReadValueId in interface MonitoredItem

Returns:

the ReadValueId being monitored.

getTimestampsToReturn

public com.digitalpetri.opcua.stack.core.types.enumerated.TimestampsToReturn getTimestampsToReturn()

Specified by:

getTimestampsToReturn in interface MonitoredItem

Returns:

the TimestampsToReturn.

getClientHandle

public long getClientHandle()

getQueueSize

public int getQueueSize()

getSamplingInterval

public double getSamplingInterval()

isDiscardOldest

public boolean isDiscardOldest()

getMonitoringMode

public com.digitalpetri.opcua.stack.core.types.enumerated.MonitoringMode getMonitoringMode()

getTriggeredItems

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

isTriggered

public boolean isTriggered()

getFilterResult

public abstract com.digitalpetri.opcua.stack.core.types.builtin.ExtensionObject getFilterResult()

installFilter

protected abstract void installFilter(com.digitalpetri.opcua.stack.core.types.builtin.ExtensionObject filterXo)
                               throws com.digitalpetri.opcua.stack.core.UaException

Throws:

com.digitalpetri.opcua.stack.core.UaException

wrapQueueValue

protected abstract com.digitalpetri.opcua.stack.core.serialization.UaStructure wrapQueueValue(ValueType value)