|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectcom.prosysopc.ua.SubscriptionBase
com.prosysopc.ua.client.Subscription
public class Subscription
OPC UA Subscription. The subscription is used for continuous monitoring of data values from an OPC server.
Use PublishingInterval to define the sampling frequency in the server. LifeTimeCount and MaxKeepAliveCount define the details of connection monitoring, to help keeping track that the connection is still alive to both directions. You can use PublishingEnabled to take the subscription in or out of monitoring for custom periods.
You can also define a Priority for each subscription, to give the server a hint about the relative importance of different subscriptions. Higher values mean higher priority.
| Field Summary | |
|---|---|
protected boolean |
modified
|
| Fields inherited from class com.prosysopc.ua.SubscriptionBase |
|---|
items, lifetimeCount, maxKeepAliveCount, maxNotificationsPerPublish, priority, publishingEnabled, publishingInterval, updateCount |
| Constructor Summary | |
|---|---|
Subscription()
Create a new subscription using the default values. |
|
Subscription(Boolean publishingEnabled,
Double requestedPublishingInterval,
long requestedLifetimeCount,
long requestedMaxKeepAliveCount,
long maxNotificationsPerPublish,
int priority)
|
|
Subscription(org.opcfoundation.ua.builtintypes.UnsignedInteger maxNotificationsPerPublish,
org.opcfoundation.ua.builtintypes.UnsignedInteger requestedLifetimeCount,
org.opcfoundation.ua.builtintypes.UnsignedInteger requestedMaxKeepAliveCount,
Double requestedPublishingInterval,
Boolean publishingEnabled,
org.opcfoundation.ua.builtintypes.UnsignedByte priority)
|
|
| Method Summary | |
|---|---|
void |
addAliveListener(SubscriptionAliveListener subscriptionAliveListener)
Add a listener for the subscription alive and timeout events. |
org.opcfoundation.ua.core.MonitoredItemCreateResult |
addItem(MonitoredItem item)
Adds a monitored item to the subscription. |
org.opcfoundation.ua.core.MonitoredItemCreateResult[] |
addItems(MonitoredItem... items)
Adds several monitored items to the subscription at once. |
void |
addNotificationListener(SubscriptionNotificationListener notificationListener)
Add a listener for the Notification notification event. |
protected void |
applyUpdates()
Apply the pending modifications guarded by beginUpdate/endUpdate. |
protected void |
checkOperationResult(org.opcfoundation.ua.builtintypes.StatusCode statusCode)
|
protected void |
checkServiceResult(org.opcfoundation.ua.builtintypes.ServiceResponse response,
org.opcfoundation.ua.builtintypes.DiagnosticInfo[] operationDiagnostics)
|
protected void |
checkTimeout()
|
protected void |
createItems()
|
protected org.opcfoundation.ua.core.CreateMonitoredItemsResponse |
createMonitoredItems(MonitoredItemBase... items)
|
protected org.opcfoundation.ua.core.DeleteMonitoredItemsResponse |
deleteMonitoredItems(MonitoredItemBase... items)
|
protected void |
enabledChanged()
Handles a change in PublishingEnabled |
protected void |
finalize()
|
protected void |
fireAfterCreate()
|
protected void |
fireAlive()
Fire the Alive event. |
protected void |
fireBufferOverflow(org.opcfoundation.ua.builtintypes.UnsignedInteger sequenceNumber,
org.opcfoundation.ua.builtintypes.ExtensionObject[] notificationData)
|
protected void |
fireDataChange(MonitoredDataItem item,
org.opcfoundation.ua.builtintypes.DataValue newValue)
|
protected void |
fireError(Object notification,
Exception exception)
|
protected void |
fireEvent(MonitoredEventItem item,
org.opcfoundation.ua.builtintypes.Variant[] values)
|
protected long |
fireMissingData(org.opcfoundation.ua.builtintypes.UnsignedInteger lastSequenceNumber2,
long sequenceNumber,
long newSequenceNumber,
org.opcfoundation.ua.builtintypes.StatusCode serviceResult)
|
protected void |
fireNotification(org.opcfoundation.ua.core.NotificationData notification)
Fire the Notification event. |
protected void |
fireStatusChange(org.opcfoundation.ua.builtintypes.StatusCode oldStatus,
org.opcfoundation.ua.builtintypes.StatusCode newStatus,
org.opcfoundation.ua.builtintypes.DiagnosticInfo diagnosticInfo)
|
protected void |
fireTimeout()
Fire the Timeout event. |
SubscriptionAliveListener[] |
getAliveListeners()
|
org.opcfoundation.ua.builtintypes.UnsignedInteger[] |
getAvailableSequenceNumbers()
|
protected List<org.opcfoundation.ua.builtintypes.UnsignedInteger> |
getAvailableSequenceNumbersList()
|
UaClient |
getClient()
|
org.opcfoundation.ua.builtintypes.DiagnosticInfo |
getDiagnosticInfo()
|
MonitoredItem |
getItem(org.opcfoundation.ua.builtintypes.NodeId nodeId,
org.opcfoundation.ua.builtintypes.UnsignedInteger attributeId)
Find the item that is listening to the specified node attribute. |
Calendar |
getLastAlive()
|
org.opcfoundation.ua.builtintypes.DiagnosticInfo[] |
getLastOperationDiagnostics()
The operation level diagnostic information related to the last service call. |
org.opcfoundation.ua.builtintypes.UnsignedInteger |
getLastSequenceNumber()
|
org.opcfoundation.ua.builtintypes.DiagnosticInfo |
getLastServiceDiagnostics()
The service level diagnostic information related to the last service call. |
org.opcfoundation.ua.builtintypes.StatusCode |
getLastServiceResult()
The latest service result received for the service calls used to control the subscription. |
int |
getMaxMonitoredItemsPerCall()
|
protected org.opcfoundation.ua.core.MonitoringParameters |
getMonitoringParameters(MonitoredItemBase item)
|
int |
getNotificationBufferSize()
The maximum size of the internal buffer used for incoming data packets. |
SubscriptionNotificationListener[] |
getNotificationListeners()
|
org.opcfoundation.ua.builtintypes.StatusCode |
getStatus()
The status received from the latest StatusChange notification. |
double |
getTimeoutDetectionFactor()
|
org.opcfoundation.ua.core.TimestampsToReturn |
getTimestampsToReturn()
|
protected void |
handleNotificationDatas()
Handles all pending notifications from the responseQueue, where they have been recorded by onPublishResponse(PublishResponse) |
boolean |
hasAliveListener(SubscriptionAliveListener subscriptionAliveListener)
Check if the subscription already has the specified alive listener. |
boolean |
hasNotificationListener(SubscriptionNotificationListener notificationListener)
Check if the subscription already has the specified notification listener. |
protected boolean |
hasPublishResponses()
|
protected boolean |
isAliveNotification(org.opcfoundation.ua.builtintypes.ExtensionObject[] notificationData)
|
boolean |
isConnected()
Is the subscription connected to the server. |
boolean |
isModified()
|
boolean |
isRetransmissionEnabled()
Whether the Subscription is enabled to call Republish to the server. |
boolean |
isTimeout()
Check whether the subscription timeout has occurred. |
protected void |
itemChanged(MonitoredItem item)
|
String |
itemsToString()
Convert the monitored items to a string for output purposes |
protected org.opcfoundation.ua.core.ModifyMonitoredItemsResponse |
modifyMonitoredItems(List<MonitoredItem> items)
|
protected void |
monitoringModeChanged(MonitoredItem monitoredItem)
|
protected void |
onPublishResponse(org.opcfoundation.ua.core.PublishResponse response)
Records the new notification to the responseQueue to be handled later at #handleNotificationData in another thread. this method is called in the stack thread that provides the asynchronous response to Publish |
protected void |
paramChanged()
Parameter change "event". |
org.opcfoundation.ua.builtintypes.DataValue[] |
readAll(Double maxAge,
org.opcfoundation.ua.core.TimestampsToReturn timestamps)
Read the current value of each MonitoredDataItem in the subscription. |
void |
removeAliveListener(SubscriptionAliveListener subscriptionAliveListener)
Remove a listener for the subscription alive event. |
MonitoredItemBase |
removeItem(MonitoredItemBase item)
Remove a monitored item from the subscription. |
MonitoredItemBase |
removeItem(org.opcfoundation.ua.builtintypes.UnsignedInteger clientHandle)
Remove a monitored item from the subscription. |
org.opcfoundation.ua.builtintypes.StatusCode[] |
removeItems()
Removes all monitored items from the subscription at once. |
org.opcfoundation.ua.builtintypes.StatusCode[] |
removeItems(MonitoredItemBase... items)
Removes several monitored items from the subscription at once. |
void |
removeNotificationListener(SubscriptionNotificationListener listener)
Remove a listener from the Notification event. |
void |
republishAllAvailable()
|
protected void |
reset()
Reset the subscription to a "removed" state. |
protected boolean |
serverConnected()
|
protected void |
setClient(UaClient server)
|
void |
setMaxMonitoredItemsPerCall(int maxMonitoredItemsPerCall)
Define the maximum number of items in one service call: this may reflect the respective OperationLimit (default) of the server or you can define a sensible limit to avoid too big requests, for example when the client is reconnecting. |
void |
setMonitoringMode(org.opcfoundation.ua.core.MonitoringMode monitoringMode)
Set the monitoring mode of all items in the subscription. |
protected org.opcfoundation.ua.core.SetMonitoringModeResponse |
setMonitoringMode(org.opcfoundation.ua.core.MonitoringMode monitoringMode,
List<MonitoredItem> items)
Set the monitoring mode of the specified items. |
void |
setNotificationBufferSize(int maxNotificationDataQueueSize)
Define the maximum number of NotificationData packets to keep in the internal buffer. |
void |
setPublishingInterval(long requestedPublishingInterval,
TimeUnit unit)
This interval defines the cyclic rate that the Subscription is being requested to return Notifications to the Client. |
void |
setRetransmissionEnabled(boolean republishEnabled)
Define whether the Subscription is enabled to call Republish to the server. |
protected void |
setSubscriptionId(int i)
|
protected void |
setSubscriptionId(org.opcfoundation.ua.builtintypes.UnsignedInteger id)
|
protected void |
setTimeout(boolean value)
|
void |
setTimeoutDetectionFactor(double timeoutDetectionFactor)
Set factor, which is used to predict when the subscription has timed out. |
void |
setTimestampsToReturn(org.opcfoundation.ua.core.TimestampsToReturn timestampsToReturn)
Define the timestamps to request from the server for the data change notifications. |
void |
transferTo(UaClient newClient)
Move the subscription to another client connection. |
void |
transferTo(UaClient newClient,
org.opcfoundation.ua.builtintypes.UnsignedInteger subscriptionId)
Move the subscription to another client connection, using the provided SubscriptionId. |
void |
updateItems()
Update the locally modified monitored items in the server. |
void |
updateMonitoringModes()
Update all pending monitoring mode changes to the server. |
protected void |
updateSubscription()
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Field Detail |
|---|
protected boolean modified
| Constructor Detail |
|---|
public Subscription()
public Subscription(Boolean publishingEnabled,
Double requestedPublishingInterval,
long requestedLifetimeCount,
long requestedMaxKeepAliveCount,
long maxNotificationsPerPublish,
int priority)
public Subscription(org.opcfoundation.ua.builtintypes.UnsignedInteger maxNotificationsPerPublish,
org.opcfoundation.ua.builtintypes.UnsignedInteger requestedLifetimeCount,
org.opcfoundation.ua.builtintypes.UnsignedInteger requestedMaxKeepAliveCount,
Double requestedPublishingInterval,
Boolean publishingEnabled,
org.opcfoundation.ua.builtintypes.UnsignedByte priority)
maxNotificationsPerPublish - requestedLifetimeCount - requestedMaxKeepAliveCount - requestedPublishingInterval - publishingEnabled - priority - | Method Detail |
|---|
public void addAliveListener(SubscriptionAliveListener subscriptionAliveListener)
hasAliveListener(SubscriptionAliveListener), the listener is not added again.
subscriptionAliveListener - SubscriptionAliveListener
public org.opcfoundation.ua.core.MonitoredItemCreateResult addItem(MonitoredItem item)
throws ServiceException,
StatusException
MonitoredItem.getErrorCode() will be set accordingly and an exception is
raised from here. You can use removeItem(MonitoredItemBase) to remove it.
item -
ServiceException - if the service call fails.
StatusException - if the server returns an error for the item.MonitoredItem.getErrorCode()
public org.opcfoundation.ua.core.MonitoredItemCreateResult[] addItems(MonitoredItem... items)
throws ServiceException
MonitoredItem.getErrorCode() will be set accordingly
for each item.
items - the new item definitions
ServiceException - if the service call fails.MonitoredItem.getErrorCode()public void addNotificationListener(SubscriptionNotificationListener notificationListener)
hasNotificationListener(SubscriptionNotificationListener), the listener is not added
again.
notificationListener - SubscriptionNotificationListenerpublic SubscriptionAliveListener[] getAliveListeners()
public org.opcfoundation.ua.builtintypes.UnsignedInteger[] getAvailableSequenceNumbers()
public UaClient getClient()
public org.opcfoundation.ua.builtintypes.DiagnosticInfo getDiagnosticInfo()
getStatus()
public MonitoredItem getItem(org.opcfoundation.ua.builtintypes.NodeId nodeId,
org.opcfoundation.ua.builtintypes.UnsignedInteger attributeId)
SubscriptionBase
getItem in class SubscriptionBasenodeId - the listened nodeattributeId - the attribute
public Calendar getLastAlive()
public org.opcfoundation.ua.builtintypes.DiagnosticInfo[] getLastOperationDiagnostics()
Use setOperationDiagnosticMask to define which operation level diagnostic information you wish to receive with the service calls. If you suspect that the results contain diagnostics, check this array after the service call.
Note that if you perform parallel service calls, they must be synchronized so that you get the lastOperationDiagnostics for the previous call. Or use alternative calls, such as 'read', which return the diagnostics as part of the service result.
getLastServiceDiagnostics()public org.opcfoundation.ua.builtintypes.UnsignedInteger getLastSequenceNumber()
public org.opcfoundation.ua.builtintypes.DiagnosticInfo getLastServiceDiagnostics()
Note that if you perform parallel service calls, they must be synchronized so that you get the lastServiceDiagnostics for the previous call. Or use alternative calls, such as 'read', which return the diagnostics as part of the service result.
If a service fails due to a bad ServiceResult, you can read the diagnostics to check if the server provide is additional information about the problem.
getLastOperationDiagnostics(),
getLastServiceResult()public org.opcfoundation.ua.builtintypes.StatusCode getLastServiceResult()
getLastServiceDiagnostics()public int getMaxMonitoredItemsPerCall()
setMaxMonitoredItemsPerCall(int)public int getNotificationBufferSize()
setNotificationBufferSize(int)public SubscriptionNotificationListener[] getNotificationListeners()
public org.opcfoundation.ua.builtintypes.StatusCode getStatus()
getDiagnosticInfo()public double getTimeoutDetectionFactor()
public org.opcfoundation.ua.core.TimestampsToReturn getTimestampsToReturn()
setTimestampsToReturn(TimestampsToReturn)public boolean hasAliveListener(SubscriptionAliveListener subscriptionAliveListener)
subscriptionAliveListener - the listener to check
public boolean hasNotificationListener(SubscriptionNotificationListener notificationListener)
notificationListener - the listener to check
public boolean isConnected()
When the subscription is added to the server, it gets a SubscriptionId. When the subscription is removed from the server the subscriptionId is set to null. This method simply checks that the subscriptionId is assigned and is non-zero.
If the client loses a connection to the server, the subscriptions will stay connected. If a the client connection is reopened, and a new session is created, the client will try to transfer the subscriptions that are already connected, to the new session.
public boolean isModified()
public boolean isRetransmissionEnabled()
This enables in effect the retransmission of missing notifications, in case the subscription notices such a case.
The notifications are tracked with sequenceNumbers, which enable the client to re-request the notifications that it find missing.
public boolean isTimeout()
SubscriptionBase.getMaxKeepAliveCount()public String itemsToString()
public org.opcfoundation.ua.builtintypes.DataValue[] readAll(Double maxAge,
org.opcfoundation.ua.core.TimestampsToReturn timestamps)
throws ServiceException
Makes a UaClient#read() call to the server with the NodeIds for every MonitoredDataItem
as provided by SubscriptionBase.getItems().
This is a convenience method to provide a quick way to refresh the current values of the items
in a subscription. This may be necessary if data is missed for the subscription during a
communication problem, i.e.
SubscriptionNotificationListener.onMissingData(UnsignedInteger, long, long, StatusCode)
has been called.
Note that the server should provide the initial value for every item when the items are created in the server, so you should not need to use 'read' to get the values then.
maxAge - The maximum age of the value that is accepted. See
UaClient.read(Double, TimestampsToReturn, ReadValueId...) for detailstimestamps - Which timestamps to return
SubscriptionBase.getItems(). Only MonitoredDataItems are regarded. If there are
MonitoredEventItems, the respective DataValue in the array is a null value with
expected StatusCode Bad_NodeIdInvalid
ServiceException - If the read() service call to the server failspublic void removeAliveListener(SubscriptionAliveListener subscriptionAliveListener)
subscriptionAliveListener - SubscriptionAliveListener
public MonitoredItemBase removeItem(MonitoredItemBase item)
throws ServiceException,
StatusException
removeItem in class SubscriptionBaseitem - The monitored item to remove.
ServiceException - if the service call to delete the item from the server fails.
StatusException - if the delete response from the server is badremoveItem(UnsignedInteger),
removeItems(),
removeItems(MonitoredItemBase...)
public MonitoredItemBase removeItem(org.opcfoundation.ua.builtintypes.UnsignedInteger clientHandle)
throws ServiceException,
StatusException
removeItem in class SubscriptionBaseclientHandle - The clientHandle of the monitored item to remove.
ServiceException - if the service call to delete the item from the server fails.
StatusException - if the delete response from the server is badremoveItem(MonitoredItemBase),
removeItems(),
removeItems(MonitoredItemBase...)
public org.opcfoundation.ua.builtintypes.StatusCode[] removeItems()
throws ServiceException
Calls removeItems(MonitoredItemBase...) with null.
items - Monitored items. If null, all items in the subscription are removed.
ServiceException - if the service call fails.removeItem(MonitoredItemBase),
removeItem(UnsignedInteger),
removeItems(MonitoredItemBase...)
public org.opcfoundation.ua.builtintypes.StatusCode[] removeItems(MonitoredItemBase... items)
throws ServiceException
items - Monitored items. If null, all items in the subscription are removed.
ServiceException - if the service call fails.removeItem(MonitoredItemBase),
removeItem(UnsignedInteger),
removeItems()public void removeNotificationListener(SubscriptionNotificationListener listener)
listener - the listener to removeSubscriptionNotificationListener
public void republishAllAvailable()
throws ServiceException
ServiceExceptionpublic void setMaxMonitoredItemsPerCall(int maxMonitoredItemsPerCall)
maxMonitoredItemsPerCall - the maxMonitoredItemsPerCall to set. Use 0 to use no limit. Use
-1 to use what UaClient.getActualOperationLimits() defines (this is the
default).
public void setMonitoringMode(org.opcfoundation.ua.core.MonitoringMode monitoringMode)
throws ServiceException
Calls #setMonitoringMode(MonitoringMode, MonitoredItemBase...) with 'null' items.
monitoringMode - the mode to set to the items
ServiceException - if the service call to the server failspublic void setNotificationBufferSize(int maxNotificationDataQueueSize)
Default: 100
maxNotificationDataQueueSize - the maxNotificationDataQueueSize to set
public void setPublishingInterval(long requestedPublishingInterval,
TimeUnit unit)
throws ServiceException
The negotiated value for this parameter returned in the response is used as the default sample interval for MonitoredItems assigned to this Subscription.
The value 0 is invalid.
Converts the requestedPublishingInterval to milliseconds and calls
SubscriptionBase.setPublishingInterval(double).
setPublishingInterval in class SubscriptionBaserequestedPublishingInterval - requested value for the publishing intervalunit - the time unit of the requestedPublishingInterval argument
ServiceException - If the parameter could not be changed.SubscriptionBase.setPublishingInterval(double)public void setRetransmissionEnabled(boolean republishEnabled)
This enables in effect the retransmission of missing notifications, in case the subscription notices such a case.
The notifications are tracked with sequenceNumbers, which enable the client to re-request the notifications that it find missing. * Default: true
retransmissionEnabled - the retransmissionEnabled to setpublic void setTimeoutDetectionFactor(double timeoutDetectionFactor)
SubscriptionBase.getMaxKeepAliveCount() and SubscriptionBase.getPublishingInterval()
timeoutDetectionFactor - the timeoutDetectionFactor to set (default 1.3), must be greater
than 1
IllegalArgumentException - if timeoutDetectionFactor is <= 1public void setTimestampsToReturn(org.opcfoundation.ua.core.TimestampsToReturn timestampsToReturn)
timestampsToReturn -
public void transferTo(UaClient newClient)
throws ServiceException,
StatusException
newClient - The new client. If the subscription was defined on another client, it will be
moved to the new client session.
StatusException - If the transfer to a new client did not succeed.
ServiceException - If the service calls failed.
public void transferTo(UaClient newClient,
org.opcfoundation.ua.builtintypes.UnsignedInteger subscriptionId)
throws ServiceException,
StatusException
newClient - The new client. If the subscription was defined on another client, it will be
moved to the new client session.subscriptionId - The SubscriptionId of the subscription to move. This enables moving the
subscription from another application by communicating the SubscriptionId between them.
If the subscription is created in this application, you can use
transferTo(UaClient) to move it to a new UaClient instance.
StatusException - If the transfer to a new client did not succeed.
ServiceException - If the service calls failed.
public void updateItems()
throws ServiceException
Goes through all Items and checks every one that is marked with
MonitoredItem.isModified(). Those are included in a service call to the server for
modifymonitoredItems.
The method is automatically called whenever you modify an item or several, inside a
SubscriptionBase.beginUpdate()/SubscriptionBase.endUpdate() loop.
In case endUpdate fails, you can retry to update the pending changes by calling the modifyItems later.
ServiceException - if the service call to the server fails. You may need to retry again,
depending on the actual error.
public void updateMonitoringModes()
throws ServiceException
ServiceException
protected void applyUpdates()
throws ServiceException
SubscriptionBase
applyUpdates in class SubscriptionBaseServiceException
protected void checkOperationResult(org.opcfoundation.ua.builtintypes.StatusCode statusCode)
throws StatusException
dataValue -
StatusException
protected void checkServiceResult(org.opcfoundation.ua.builtintypes.ServiceResponse response,
org.opcfoundation.ua.builtintypes.DiagnosticInfo[] operationDiagnostics)
throws ServiceException
response - The service response to check.operationDiagnostics -
ServiceException - If the server returns a bad ServiceResult code for the service call.protected void checkTimeout()
protected void createItems()
throws ServiceException
ServiceException
protected org.opcfoundation.ua.core.CreateMonitoredItemsResponse createMonitoredItems(MonitoredItemBase... items)
throws ServiceException
ServiceException
protected org.opcfoundation.ua.core.DeleteMonitoredItemsResponse deleteMonitoredItems(MonitoredItemBase... items)
throws ServiceException
item -
ServiceException
protected void enabledChanged()
throws ServiceException,
StatusException
SubscriptionBase
enabledChanged in class SubscriptionBaseServiceException
StatusException
protected void finalize()
throws Throwable
finalize in class ObjectThrowableprotected void fireAfterCreate()
protected void fireAlive()
protected void fireBufferOverflow(org.opcfoundation.ua.builtintypes.UnsignedInteger sequenceNumber,
org.opcfoundation.ua.builtintypes.ExtensionObject[] notificationData)
sequenceNumber - notificationData -
protected void fireDataChange(MonitoredDataItem item,
org.opcfoundation.ua.builtintypes.DataValue newValue)
item - newValue -
protected void fireError(Object notification,
Exception exception)
dataChangeNotification - e -
protected void fireEvent(MonitoredEventItem item,
org.opcfoundation.ua.builtintypes.Variant[] values)
item - values -
protected long fireMissingData(org.opcfoundation.ua.builtintypes.UnsignedInteger lastSequenceNumber2,
long sequenceNumber,
long newSequenceNumber,
org.opcfoundation.ua.builtintypes.StatusCode serviceResult)
lastSequenceNumber2 - sequenceNumber - newSequenceNumber - serviceResult -
protected void fireNotification(org.opcfoundation.ua.core.NotificationData notification)
notification -
protected void fireStatusChange(org.opcfoundation.ua.builtintypes.StatusCode oldStatus,
org.opcfoundation.ua.builtintypes.StatusCode newStatus,
org.opcfoundation.ua.builtintypes.DiagnosticInfo diagnosticInfo)
oldStatus - newStatus - diagnosticInfo - protected void fireTimeout()
protected List<org.opcfoundation.ua.builtintypes.UnsignedInteger> getAvailableSequenceNumbersList()
protected org.opcfoundation.ua.core.MonitoringParameters getMonitoringParameters(MonitoredItemBase item)
item -
ServiceException
protected void handleNotificationDatas()
throws ServerConnectionException,
ServiceException
onPublishResponse(PublishResponse)
ServerConnectionException
ServiceExceptionprotected boolean hasPublishResponses()
protected boolean isAliveNotification(org.opcfoundation.ua.builtintypes.ExtensionObject[] notificationData)
notificationData -
protected void itemChanged(MonitoredItem item)
throws ServiceException
ServiceException
protected org.opcfoundation.ua.core.ModifyMonitoredItemsResponse modifyMonitoredItems(List<MonitoredItem> items)
throws ServiceException
subscription - item -
ServiceException
protected void monitoringModeChanged(MonitoredItem monitoredItem)
throws ServiceException
monitoredItem -
ServiceExceptionprotected void onPublishResponse(org.opcfoundation.ua.core.PublishResponse response)
response -
protected void paramChanged()
throws ServiceException
SubscriptionBase
paramChanged in class SubscriptionBaseServiceExceptionprotected void reset()
protected boolean serverConnected()
protected void setClient(UaClient server)
protected org.opcfoundation.ua.core.SetMonitoringModeResponse setMonitoringMode(org.opcfoundation.ua.core.MonitoringMode monitoringMode,
List<MonitoredItem> items)
throws ServiceException
monitoringMode - the mode to set to the itemsitems - the items to change. If null, all items in the subscription are changed (equals to
using setMonitoringMode(MonitoringMode))
ServiceException - if the service call to the server failsprotected void setSubscriptionId(int i)
i - protected void setSubscriptionId(org.opcfoundation.ua.builtintypes.UnsignedInteger id)
setSubscriptionId in class SubscriptionBaseprotected void setTimeout(boolean value)
value -
protected void updateSubscription()
throws ServiceException
ServiceException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||