Class OpcUaClient
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionOpcUaClient(OpcUaClientConfig config, org.eclipse.milo.opcua.stack.transport.client.OpcClientTransport transport) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddFaultListener(ServiceFaultListener faultListener) org.eclipse.milo.opcua.stack.core.types.structured.AddNodesResponseAdd one or more Nodes to the AddressSpace hierarchy.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.AddNodesResponse>addNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.AddNodesItem> nodesToAdd) Add one or more Nodes to the AddressSpace hierarchy.org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesResponseaddReferences(List<org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesItem> referencesToAdd) Add one or more References to one or more Nodes.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesResponse>addReferencesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesItem> referencesToAdd) Add one or more References to one or more Nodes.voidvoidaddSessionInitializer(SessionFsm.SessionInitializer initializer) voidaddSubscription(OpcUaSubscription subscription) List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult>Browse references of one or more Nodes.org.eclipse.milo.opcua.stack.core.types.structured.BrowseResultbrowse(org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription nodeToBrowse) Browse references of a single Node.org.eclipse.milo.opcua.stack.core.types.structured.BrowseResponsebrowse(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription viewDescription, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesPerNode, List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) Browse references of one or more Nodes.CompletableFuture<List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult>>browseAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) Browse a list of nodes, with no view and no max references specified.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult>browseAsync(org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription nodeToBrowse) Browse a single node, with no view and no max references specified.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResponse>browseAsync(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription viewDescription, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesPerNode, List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) Browse references of one or more Nodes.org.eclipse.milo.opcua.stack.core.types.structured.BrowseNextResponsebrowseNext(boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.builtin.ByteString> continuationPoints) Request the next set of Browse or BrowseNext information that was too large to be sent in a single response.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.BrowseNextResponse>browseNextAsync(boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.builtin.ByteString> continuationPoints) Request the next set of Browse or BrowseNext information that was too large to be sent in a single response.org.eclipse.milo.opcua.stack.core.types.structured.CallResponseCall (invoke) one or more methods.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CallResponse>Call (invoke) one or more methods.connect()Connect the underlying transport and open a session.Connect the underlying transport and open a session.static OpcUaClientSelect the first endpoint with no security that allows anonymous connections and create anOpcUaClientwith the default configuration.static OpcUaClientcreate(String endpointUrl, Function<List<org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription>, Optional<org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription>> selectEndpoint, Consumer<org.eclipse.milo.opcua.stack.transport.client.tcp.OpcTcpClientTransportConfigBuilder> configureTransport, Consumer<OpcUaClientConfigBuilder> configureClient) Create and configure anOpcUaClientby selecting anEndpointDescriptionfrom a list of endpoints retrieved via the GetEndpoints service from the server atendpointUrland building anOpcUaClientConfigusing that endpoint.static OpcUaClientcreate(OpcUaClientConfig config) Create anOpcUaClientconfigured withconfig.static OpcUaClientcreate(OpcUaClientConfig config, Consumer<org.eclipse.milo.opcua.stack.transport.client.tcp.OpcTcpClientTransportConfigBuilder> configureTransport) Create anOpcUaClientconfigured withconfig.org.eclipse.milo.opcua.stack.core.types.structured.CreateMonitoredItemsResponsecreateMonitoredItems(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemCreateRequest> itemsToCreate) Create and add one or more Monitored Items to a Subscription.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CreateMonitoredItemsResponse>createMonitoredItemsAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemCreateRequest> itemsToCreate) Create and add one or more Monitored Items to a Subscription.org.eclipse.milo.opcua.stack.core.types.structured.CreateSubscriptionResponsecreateSubscription(double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, boolean publishingEnabled, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) Create a new Subscription belonging to this client's Session.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CreateSubscriptionResponse>createSubscriptionAsync(double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, boolean publishingEnabled, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) Create a new Subscription belonging to this client's Session.org.eclipse.milo.opcua.stack.core.types.structured.DeleteMonitoredItemsResponsedeleteMonitoredItems(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) Delete one or more Monitored Items of a Subscription.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteMonitoredItemsResponse>deleteMonitoredItemsAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) Delete one or more Monitored Items of a Subscription.org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesResponsedeleteNodes(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesItem> nodesToDelete) Delete one or more Nodes from the AddressSpace hierarchy.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesResponse>deleteNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesItem> nodesToDelete) Delete one or more Nodes from the AddressSpace hierarchy.org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesResponsedeleteReferences(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesItem> referencesToDelete) Delete one or more References from one or more Nodes.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesResponse>deleteReferencesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesItem> referencesToDelete) Delete one or more References from one or more Nodes.org.eclipse.milo.opcua.stack.core.types.structured.DeleteSubscriptionsResponsedeleteSubscriptions(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) Delete one or more Subscriptions belonging to this client's Session.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteSubscriptionsResponse>deleteSubscriptionsAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) Delete one or more Subscriptions belonging to this client's Session.Close the session, if it's open, and disconnect the underlying transport.Close the session, if it's open, and disconnect the underlying transport.org.eclipse.milo.opcua.sdk.core.typetree.DataTypeTreeGet theDataTypeTree, reading it from the server if necessary.org.eclipse.milo.opcua.stack.core.types.DataTypeManagerGet the client's "dynamic"DataTypeManager.org.eclipse.milo.opcua.stack.core.encoding.EncodingContextGet a "dynamic"EncodingContext.org.eclipse.milo.opcua.stack.core.NamespaceTableGet the local copy of the server's NamespaceTable (NamespaceArray).org.eclipse.milo.opcua.sdk.core.typetree.ObjectTypeTreeGet theObjectTypeTree, reading it from the server if necessary.Get the local copy of the server'sOperationLimits, or read them from the server if they have not been read.org.eclipse.milo.opcua.stack.core.ServerTableGet the local copy of the server's ServerTable (ServerArray).Get theOpcUaSession, if it's available.Get theOpcUaSession, if it's available.Get theSessionFsmmanaging this client's session lifecycle.org.eclipse.milo.opcua.stack.core.types.DataTypeManagerGet the client's "static"DataTypeManager.org.eclipse.milo.opcua.stack.core.encoding.EncodingContextGet a "static"EncodingContextinstance.org.eclipse.milo.opcua.stack.transport.client.OpcClientTransportorg.eclipse.milo.opcua.sdk.core.typetree.VariableTypeTreeGet theVariableTypeTree, reading it from the server if necessary.org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadResponsehistoryRead(org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadDetails historyReadDetails, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadValueId> nodesToRead) Read historical values or Events of one or more Nodes.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadResponse>historyReadAsync(org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadDetails historyReadDetails, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadValueId> nodesToRead) Read historical values or Events of one or more Nodes.org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateResponsehistoryUpdate(List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateDetails> historyUpdateDetails) Update historical values or Events of one or more Nodes.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateResponse>historyUpdateAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateDetails> historyUpdateDetails) Update historical values or Events of one or more Nodes.org.eclipse.milo.opcua.stack.core.types.structured.ModifyMonitoredItemsResponsemodifyMonitoredItems(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemModifyRequest> itemsToModify) Modify Monitored Items of a Subscription.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.ModifyMonitoredItemsResponse>modifyMonitoredItemsAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemModifyRequest> itemsToModify) Modify Monitored Items of a Subscription.org.eclipse.milo.opcua.stack.core.types.structured.ModifySubscriptionResponsemodifySubscription(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) Modify an existing Subscription belonging to this client's Session.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.ModifySubscriptionResponse>modifySubscriptionAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) Modify an existing Subscription belonging to this client's Session.org.eclipse.milo.opcua.stack.core.types.structured.RequestHeaderCreate a newRequestHeaderwith a null authentication token.org.eclipse.milo.opcua.stack.core.types.structured.RequestHeadernewRequestHeader(org.eclipse.milo.opcua.stack.core.types.builtin.NodeId authToken) Create a newRequestHeaderwithauthToken.org.eclipse.milo.opcua.stack.core.types.structured.RequestHeadernewRequestHeader(org.eclipse.milo.opcua.stack.core.types.builtin.NodeId authToken, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestTimeout) Create a newRequestHeaderwithauthTokenandrequestTimeout.org.eclipse.milo.opcua.stack.core.types.structured.PublishResponsepublish(List<org.eclipse.milo.opcua.stack.core.types.structured.SubscriptionAcknowledgement> subscriptionAcknowledgements) Send aPublishRequestto the server, acknowledging the receipt of previously-received messages and requesting the server return a NotificationMessage or keep-alive message.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.PublishResponse>publishAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.SubscriptionAcknowledgement> subscriptionAcknowledgements) Send aPublishRequestto the server, acknowledging the receipt of previously-received messages and requesting the server return a NotificationMessage or keep-alive message.org.eclipse.milo.opcua.stack.core.types.structured.QueryFirstResponsequeryFirst(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription view, List<org.eclipse.milo.opcua.stack.core.types.structured.NodeTypeDescription> nodeTypes, org.eclipse.milo.opcua.stack.core.types.structured.ContentFilter filter, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxDataSetsToReturn, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesToReturn) Issue a query request to the server.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.QueryFirstResponse>queryFirstAsync(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription view, List<org.eclipse.milo.opcua.stack.core.types.structured.NodeTypeDescription> nodeTypes, org.eclipse.milo.opcua.stack.core.types.structured.ContentFilter filter, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxDataSetsToReturn, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesToReturn) Issue a query request to the server.org.eclipse.milo.opcua.stack.core.types.structured.QueryNextResponsequeryNext(boolean releaseContinuationPoint, org.eclipse.milo.opcua.stack.core.types.builtin.ByteString continuationPoint) Request the next set of QueryFirst or QueryNext response information that was too large to be sent in a single response.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.QueryNextResponse>queryNextAsync(boolean releaseContinuationPoint, org.eclipse.milo.opcua.stack.core.types.builtin.ByteString continuationPoint) Request the next set of QueryFirst or QueryNext response information that was too large to be sent in a single response.org.eclipse.milo.opcua.stack.core.types.structured.ReadResponseread(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.ReadValueId> readValueIds) Read one or more attributes of one or more Nodes.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.ReadResponse>readAsync(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.ReadValueId> readValueIds) Read one or more attributes of one or more Nodes.org.eclipse.milo.opcua.sdk.core.typetree.DataTypeTreeRead theDataTypeTreefrom the server and update the local copy.CompletionStage<org.eclipse.milo.opcua.sdk.core.typetree.DataTypeTree>Read theDataTypeTreefrom the server and update the local copy.org.eclipse.milo.opcua.stack.core.NamespaceTableRead the server's NamespaceTable (NamespaceArray) and update the local copy.CompletableFuture<org.eclipse.milo.opcua.stack.core.NamespaceTable>Read the server's NamespaceTable (NamespaceArray) and update the local copy.org.eclipse.milo.opcua.sdk.core.typetree.ObjectTypeTreeRead theObjectTypeTreefrom the server and update the local copy.CompletionStage<org.eclipse.milo.opcua.sdk.core.typetree.ObjectTypeTree>Read theObjectTypeTreefrom the server and update the local copy.Read the server's OperationLimits and update the local copy.org.eclipse.milo.opcua.stack.core.ServerTableRead the server's ServerTable (ServerArray) and update the local copy.CompletableFuture<org.eclipse.milo.opcua.stack.core.ServerTable>Read the server's ServerTable (ServerArray) and update the local copy.org.eclipse.milo.opcua.stack.core.types.builtin.DataValuereadValue(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, org.eclipse.milo.opcua.stack.core.types.builtin.NodeId nodeId) Read the Value attribute of a Node.List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue>readValues(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds) Read the Value attribute of one or more Nodes.CompletableFuture<List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue>>readValuesAsync(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds) Read the Value attribute of one or more Nodes.org.eclipse.milo.opcua.sdk.core.typetree.VariableTypeTreeRead theVariableTypeTreefrom the server and update the local copy.CompletionStage<org.eclipse.milo.opcua.sdk.core.typetree.VariableTypeTree>Read theVariableTypeTreefrom the server and update the local copy.org.eclipse.milo.opcua.stack.core.types.structured.RegisterNodesResponseregisterNodes(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToRegister) RegisterNodeIds that the client intends to access repeatedly (e.g. read, write, call), allowing servers to set up anything needed so that the access operations are more efficient.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.RegisterNodesResponse>registerNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToRegister) Register Nodes that the client intends to access repeatedly (e.g. read, write, call), allowing servers to set up anything needed so that the access operations are more efficient.voidremoveFaultListener(ServiceFaultListener faultListener) voidvoidremoveSessionInitializer(SessionFsm.SessionInitializer initializer) voidremoveSubscription(OpcUaSubscription subscription) org.eclipse.milo.opcua.stack.core.types.structured.RepublishResponserepublish(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger retransmitSequenceNumber) Send aRepublishRequestto the server, requesting the server republish a NotificationMessage from its retransmission queue.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.RepublishResponse>republishAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger retransmitSequenceNumber) Send aRepublishRequestto the server, requesting the server republish a NotificationMessage from its retransmission queue.org.eclipse.milo.opcua.stack.core.types.UaResponseMessageTypesendRequest(org.eclipse.milo.opcua.stack.core.types.UaRequestMessageType request) Send a service request and wait for the service response.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.UaResponseMessageType>sendRequestAsync(org.eclipse.milo.opcua.stack.core.types.UaRequestMessageType request) Send a service request asynchronously.voidsetDataTypeTreeFactory(DataTypeTreeFactory dataTypeTreeFactory) Set theDataTypeTreeFactoryused to create theDataTypeTree.voidsetDynamicDataTypeManagerFactory(DataTypeManagerFactory dynamicDataTypeManagerFactory) Set theDataTypeManagerFactoryused to create the dynamicDataTypeManager.org.eclipse.milo.opcua.stack.core.types.structured.SetMonitoringModeResponsesetMonitoringMode(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) Set the Monitoring Mode for one or more Monitored Items of a Subscription.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.SetMonitoringModeResponse>setMonitoringModeAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) Set the Monitoring Mode for one or more Monitored Items of a Subscription.org.eclipse.milo.opcua.stack.core.types.structured.SetPublishingModeResponsesetPublishingMode(boolean publishingEnabled, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) Enable or disable the sending of notifications on one or more subscriptions.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.SetPublishingModeResponse>setPublishingModeAsync(boolean publishingEnabled, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) Enable or disable the sending of notifications on one or more subscriptions.org.eclipse.milo.opcua.stack.core.types.structured.SetTriggeringResponsesetTriggering(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger triggeringItemId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToAdd, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToRemove) Create and delete triggering links for a triggering item.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.SetTriggeringResponse>setTriggeringAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger triggeringItemId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToAdd, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToRemove) Create and delete triggering links for a triggering item.org.eclipse.milo.opcua.stack.core.types.structured.TransferSubscriptionsResponsetransferSubscriptions(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds, boolean sendInitialValues) Transfer a Subscription and its MonitoredItems from one Session to another (this) Session.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.TransferSubscriptionsResponse>transferSubscriptionsAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds, boolean sendInitialValues) Transfer a Subscription and its MonitoredItems from one Session to another (this) Session.org.eclipse.milo.opcua.stack.core.types.structured.TranslateBrowsePathsToNodeIdsResponsetranslateBrowsePaths(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowsePath> browsePaths) Translate one or moreBrowsePaths intoNodeIds.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.TranslateBrowsePathsToNodeIdsResponse>translateBrowsePathsAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowsePath> browsePaths) Translate one or moreBrowsePaths intoNodeIds.org.eclipse.milo.opcua.stack.core.types.structured.UnregisterNodesResponseunregisterNodes(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToUnregister) Unregister Nodes that were previously registered with a Register Nodes service call.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.UnregisterNodesResponse>unregisterNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToUnregister) Unregister Nodes that were previously registered with a Register Nodes service call.org.eclipse.milo.opcua.stack.core.types.structured.WriteResponseWrite attribute values to one or more Nodes.CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.WriteResponse>writeAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.WriteValue> writeValues) Write attribute values to one or more Nodes.List<org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode>writeValues(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds, List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> values) Write the Value attribute of one or more Nodes.CompletableFuture<List<org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode>>writeValuesAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds, List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> values) Write the Value attribute of one or more Nodes.
-
Field Details
-
SDK_VERSION
-
-
Constructor Details
-
OpcUaClient
public OpcUaClient(OpcUaClientConfig config, org.eclipse.milo.opcua.stack.transport.client.OpcClientTransport transport)
-
-
Method Details
-
create
public static OpcUaClient create(OpcUaClientConfig config) throws org.eclipse.milo.opcua.stack.core.UaException Create anOpcUaClientconfigured withconfig.- Parameters:
config- theOpcUaClientConfig.- Returns:
- a new
OpcUaClientconfigured withconfig. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if the client could not be created.
-
create
public static OpcUaClient create(OpcUaClientConfig config, Consumer<org.eclipse.milo.opcua.stack.transport.client.tcp.OpcTcpClientTransportConfigBuilder> configureTransport) throws org.eclipse.milo.opcua.stack.core.UaException Create anOpcUaClientconfigured withconfig.- Parameters:
config- theOpcUaClientConfig.configureTransport- a Consumer that receives anOpcTcpClientTransportConfigBuilderthat can be used to configure the transport.- Returns:
- a new
OpcUaClientconfigured withconfig. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if the client could not be created.
-
create
public static OpcUaClient create(String endpointUrl) throws org.eclipse.milo.opcua.stack.core.UaException Select the first endpoint with no security that allows anonymous connections and create anOpcUaClientwith the default configuration.If the server is not configured with an endpoint with no security or authentication you must use
create(String, Function, Consumer, Consumer)to select an endpoint and configure any certificates or identity provider that the selected endpoint would require.- Parameters:
endpointUrl- the endpoint URL of the server to connect to and get endpoints from.- Returns:
- an
OpcUaClientconfigured to connect to the server identified byendpointUrl. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if the endpoints could not be retrieved or the client could not be created.
-
create
public static OpcUaClient create(String endpointUrl, Function<List<org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription>, Optional<org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription>> selectEndpoint, Consumer<org.eclipse.milo.opcua.stack.transport.client.tcp.OpcTcpClientTransportConfigBuilder> configureTransport, Consumer<OpcUaClientConfigBuilder> configureClient) throws org.eclipse.milo.opcua.stack.core.UaExceptionCreate and configure anOpcUaClientby selecting anEndpointDescriptionfrom a list of endpoints retrieved via the GetEndpoints service from the server atendpointUrland building anOpcUaClientConfigusing that endpoint.- Parameters:
endpointUrl- the endpoint URL of the server to connect to and retrieve endpoints from.selectEndpoint- a function that selects theEndpointDescriptionto connect to from the list of endpoints from the server.configureTransport- a Consumer that receives anOpcTcpClientTransportConfigBuilderthat can be used to configure the transport.configureClient- a Consumer that receives anOpcUaClientConfigBuilderthat can be used to configure the client.- Returns:
- a configured
OpcUaClient. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if the endpoints could not be retrieved or the client could not be created.
-
connect
Connect the underlying transport and open a session.Regardless of the success or failure of the initial connect operation, the client is now in a state where it will strive to remain connected and keep a session open, automatically reconnecting as necessary, and creating or transferring sessions as necessary.
- Returns:
- this
OpcUaClient - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs.
-
connectAsync
Connect the underlying transport and open a session.Regardless of the success or failure of the initial connect operation, the client is now in a state where it will strive to remain connected and keep a session open, automatically reconnecting as necessary, and creating or transferring sessions as necessary.
- Returns:
- a
CompletableFuturethat completes successfully with thisOpcUaClient, or completes exceptionally if an error occurs.
-
disconnect
Close the session, if it's open, and disconnect the underlying transport.- Returns:
- this
OpcUaClient. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an unexpected error occurs. Errors closing the session or the disconnecting the transport are swallowed.
-
disconnectAsync
Close the session, if it's open, and disconnect the underlying transport.- Returns:
- a
CompletableFuturethat completes successfully with thisOpcUaClient, or completes exceptionally if an unexpected error occurs. Errors closing the session or the disconnecting the transport are swallowed.
-
getSession
Get theOpcUaSession, if it's available.- Returns:
- the
OpcUaSession. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs getting the session.
-
getSessionAsync
Get theOpcUaSession, if it's available.- Returns:
- a
CompletableFuturethat completes successfully with theOpcUaSession, or completes exceptionally if an error occurs getting the session.
-
getSessionFsm
Get theSessionFsmmanaging this client's session lifecycle.- Returns:
- the
SessionFsmfor this client.
-
getConfig
-
getTransport
public org.eclipse.milo.opcua.stack.transport.client.OpcClientTransport getTransport() -
getAddressSpace
-
getObjectTypeManager
-
getVariableTypeManager
-
addSubscription
-
removeSubscription
-
getSubscriptions
-
getPublishingManager
-
getStaticDataTypeManager
public org.eclipse.milo.opcua.stack.core.types.DataTypeManager getStaticDataTypeManager()Get the client's "static"DataTypeManager.This
DataTypeManageris for static codecs that serialize classes that exist at compile time, e.g. structures from namespace 0 and or code-generated structures.- Returns:
- the client's static
DataTypeManager.
-
getDynamicDataTypeManager
public org.eclipse.milo.opcua.stack.core.types.DataTypeManager getDynamicDataTypeManager() throws org.eclipse.milo.opcua.stack.core.UaExceptionGet the client's "dynamic"DataTypeManager.This
DataTypeManageris for dynamic codecs created by reading datatype information from the server at runtime.By default, the client uses
DataTypeManagerFactory.eager(), which creates aDefaultDataTypeManagerwith all known types eagerly registered.Use
setDynamicDataTypeManagerFactory(DataTypeManagerFactory)withDataTypeManagerFactory.lazy()to configure the client with aLazyClientDataTypeManagerthat resolves codecs on demand.- Returns:
- the client's dynamic
DataTypeManager. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- See Also:
-
getStaticEncodingContext
public org.eclipse.milo.opcua.stack.core.encoding.EncodingContext getStaticEncodingContext()Get a "static"EncodingContextinstance.This
EncodingContextinstance returns the client's staticDataTypeManager.- Returns:
- a "static"
EncodingContextinstance. - See Also:
-
getDynamicEncodingContext
public org.eclipse.milo.opcua.stack.core.encoding.EncodingContext getDynamicEncodingContext() throws org.eclipse.milo.opcua.stack.core.UaExceptionGet a "dynamic"EncodingContext.This
EncodingContextinstance returns the client's dynamicDataTypeManager.- Returns:
- a "dynamic"
EncodingContext. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- See Also:
-
getNamespaceTable
public org.eclipse.milo.opcua.stack.core.NamespaceTable getNamespaceTable()Get the local copy of the server's NamespaceTable (NamespaceArray).- Returns:
- the local copy of the server's NamespaceTable (NamespaceArray).
-
readNamespaceTable
public org.eclipse.milo.opcua.stack.core.NamespaceTable readNamespaceTable() throws org.eclipse.milo.opcua.stack.core.UaExceptionRead the server's NamespaceTable (NamespaceArray) and update the local copy.- Returns:
- the updated
NamespaceTable. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an operation- or service-level error occurs.
-
readNamespaceTableAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.NamespaceTable> readNamespaceTableAsync()Read the server's NamespaceTable (NamespaceArray) and update the local copy.This call completes asynchronously.
- Returns:
- a
CompletableFuturethat completes successfully with the updatedNamespaceTableor completes exceptionally if a service- or operation-level error occurs.
-
getServerTable
public org.eclipse.milo.opcua.stack.core.ServerTable getServerTable()Get the local copy of the server's ServerTable (ServerArray).- Returns:
- the local copy of the server's ServerTable (ServerArray).
-
readServerTable
public org.eclipse.milo.opcua.stack.core.ServerTable readServerTable() throws org.eclipse.milo.opcua.stack.core.UaExceptionRead the server's ServerTable (ServerArray) and update the local copy.- Returns:
- the updated
ServerTable. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an operation- or service-level error occurs.
-
readServerTableAsync
Read the server's ServerTable (ServerArray) and update the local copy.This call completes asynchronously.
- Returns:
- a
CompletableFuturethat completes successfully with the updatedServerTableor completes exceptionally if a service- or operation-level error occurs.
-
getDataTypeTree
public org.eclipse.milo.opcua.sdk.core.typetree.DataTypeTree getDataTypeTree() throws org.eclipse.milo.opcua.stack.core.UaExceptionGet theDataTypeTree, reading it from the server if necessary.- Returns:
- the
DataTypeTree. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs while reading the DataTypes.
-
readDataTypeTree
public org.eclipse.milo.opcua.sdk.core.typetree.DataTypeTree readDataTypeTree() throws org.eclipse.milo.opcua.stack.core.UaExceptionRead theDataTypeTreefrom the server and update the local copy.- Returns:
- the updated
DataTypeTree. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs while reading the DataTypes.
-
readDataTypeTreeAsync
public CompletionStage<org.eclipse.milo.opcua.sdk.core.typetree.DataTypeTree> readDataTypeTreeAsync()Read theDataTypeTreefrom the server and update the local copy.- Returns:
- a
CompletionStagethat completes successfully with the updatedDataTypeTree, or completes exceptionally if an error occurs while reading the DataTypes.
-
getObjectTypeTree
public org.eclipse.milo.opcua.sdk.core.typetree.ObjectTypeTree getObjectTypeTree() throws org.eclipse.milo.opcua.stack.core.UaExceptionGet theObjectTypeTree, reading it from the server if necessary.- Returns:
- the
ObjectTypeTree. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs while reading the ObjectTypes.
-
readObjectTypeTree
public org.eclipse.milo.opcua.sdk.core.typetree.ObjectTypeTree readObjectTypeTree() throws org.eclipse.milo.opcua.stack.core.UaExceptionRead theObjectTypeTreefrom the server and update the local copy.- Returns:
- the updated
ObjectTypeTree. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs while reading the ObjectTypes.
-
readObjectTypeTreeAsync
public CompletionStage<org.eclipse.milo.opcua.sdk.core.typetree.ObjectTypeTree> readObjectTypeTreeAsync()Read theObjectTypeTreefrom the server and update the local copy.- Returns:
- a
CompletionStagethat completes successfully with the updatedObjectTypeTree, or completes exceptionally if an error occurs while reading the ObjectTypes.
-
getVariableTypeTree
public org.eclipse.milo.opcua.sdk.core.typetree.VariableTypeTree getVariableTypeTree() throws org.eclipse.milo.opcua.stack.core.UaExceptionGet theVariableTypeTree, reading it from the server if necessary.- Returns:
- the
VariableTypeTree. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs while reading the VariableTypes.
-
readVariableTypeTree
public org.eclipse.milo.opcua.sdk.core.typetree.VariableTypeTree readVariableTypeTree() throws org.eclipse.milo.opcua.stack.core.UaExceptionRead theVariableTypeTreefrom the server and update the local copy.- Returns:
- the updated
VariableTypeTree. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs while reading the VariableTypes.
-
readVariableTypeTreeAsync
public CompletionStage<org.eclipse.milo.opcua.sdk.core.typetree.VariableTypeTree> readVariableTypeTreeAsync()Read theVariableTypeTreefrom the server and update the local copy.- Returns:
- a
CompletionStagethat completes successfully with the updatedVariableTypeTree, or completes exceptionally if an error occurs while reading the VariableTypes.
-
getOperationLimits
Get the local copy of the server'sOperationLimits, or read them from the server if they have not been read.- Returns:
- the server's
OperationLimits. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs reading the operation limits.
-
readOperationLimits
Read the server's OperationLimits and update the local copy.- Returns:
- the server's
OperationLimits. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs reading the operation limits.
-
newRequestHeader
public org.eclipse.milo.opcua.stack.core.types.structured.RequestHeader newRequestHeader()Create a newRequestHeaderwith a null authentication token.A unique request handle will be automatically assigned to the header.
- Returns:
- a new
RequestHeaderwith a null authentication token.
-
newRequestHeader
public org.eclipse.milo.opcua.stack.core.types.structured.RequestHeader newRequestHeader(org.eclipse.milo.opcua.stack.core.types.builtin.NodeId authToken) Create a newRequestHeaderwithauthToken.A unique request handle will be automatically assigned to the header.
- Parameters:
authToken- the authentication token to create the header with.- Returns:
- a new
RequestHeadercreated withauthToken.
-
newRequestHeader
public org.eclipse.milo.opcua.stack.core.types.structured.RequestHeader newRequestHeader(org.eclipse.milo.opcua.stack.core.types.builtin.NodeId authToken, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestTimeout) Create a newRequestHeaderwithauthTokenandrequestTimeout.A unique request handle will be automatically assigned to the header.
- Parameters:
authToken- the authentication token to create the header with.requestTimeout- the timeout hint to create the header with.- Returns:
- a new
RequestHeadercreated withauthTokenandrequestTimeout.
-
setDataTypeTreeFactory
Set theDataTypeTreeFactoryused to create theDataTypeTree.By default, the client uses
DataTypeTreeFactory.eager(), which eagerly builds the complete DataTypeTree usingDataTypeTreeBuilder.build(OpcUaClient).Use
DataTypeTreeFactory.lazy()to configure the client with a lazy-loading tree that resolves types on demand. This can be more efficient when only a subset of types is needed or when the server doesn't support recursive forward browsing of the DataType hierarchy.This resets the client's cached
DataTypeTree. It will be built or rebuilt the next time it is accessed.- Parameters:
dataTypeTreeFactory- theDataTypeTreeFactoryto set.- See Also:
-
setDynamicDataTypeManagerFactory
Set theDataTypeManagerFactoryused to create the dynamicDataTypeManager.By default, the client uses
DataTypeManagerFactory.eager(), which creates aDefaultDataTypeManagerwith all known types eagerly registered.Use
DataTypeManagerFactory.lazy()to configure the client with aLazyClientDataTypeManagerthat resolves codecs on demand. This pairs well withDataTypeTreeFactory.lazy()for a fully lazy type resolution system.This resets the client's cached
DataTypeManager. It will be created again the next time it is accessed.- Parameters:
dynamicDataTypeManagerFactory- theDataTypeManagerFactoryto set.- See Also:
-
read
public org.eclipse.milo.opcua.stack.core.types.structured.ReadResponse read(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.ReadValueId> readValueIds) throws org.eclipse.milo.opcua.stack.core.UaException Read one or more attributes of one or more Nodes.- Parameters:
maxAge- the requested max age of the value, in milliseconds. If maxAge is set to 0, the Server shall attempt to read a new value from the data source. If maxAge is set to the max Int32 value or greater, the Server shall attempt to get a cached value. Negative values are invalid for maxAge.timestampsToReturn- the requestedTimestampsToReturn.readValueIds- theReadValueIds identifying the nodes and attributes to read.- Returns:
- the
ReadResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs.- See Also:
-
readValue
public org.eclipse.milo.opcua.stack.core.types.builtin.DataValue readValue(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, org.eclipse.milo.opcua.stack.core.types.builtin.NodeId nodeId) throws org.eclipse.milo.opcua.stack.core.UaException Read the Value attribute of a Node.- Parameters:
maxAge- the requested max age of the value, in milliseconds. If maxAge is set to 0, the Server shall attempt to read a new value from the data source. If maxAge is set to the max Int32 value or greater, the Server shall attempt to get a cached value. Negative values are invalid for maxAge.timestampsToReturn- the requestedTimestampsToReturn.nodeId- theNodeIds identifying the Node to read.- Returns:
- the
DataValue. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs.- See Also:
-
readValues
public List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> readValues(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds) throws org.eclipse.milo.opcua.stack.core.UaException Read the Value attribute of one or more Nodes.- Parameters:
maxAge- the requested max age of the value, in milliseconds. If maxAge is set to 0, the Server shall attempt to read a new value from the data source. If maxAge is set to the max Int32 value or greater, the Server shall attempt to get a cached value. Negative values are invalid for maxAge.timestampsToReturn- the requestedTimestampsToReturn.nodeIds- theNodeIds identifying the Nodes to read.- Returns:
- a List of
DataValues. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs.- See Also:
-
readAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.ReadResponse> readAsync(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.ReadValueId> readValueIds) Read one or more attributes of one or more Nodes.- Parameters:
maxAge- the requested max age of the value, in milliseconds. If maxAge is set to 0, the Server shall attempt to read a new value from the data source. If maxAge is set to the max Int32 value or greater, the Server shall attempt to get a cached value. Negative values are invalid for maxAge.timestampsToReturn- the requestedTimestampsToReturn.readValueIds- theReadValueIds identifying the nodes and attributes to read.- Returns:
- a
CompletableFuturethat completes successfully with theReadResponse, or completes exceptionally if an error occurs. - See Also:
-
readValuesAsync
public CompletableFuture<List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue>> readValuesAsync(double maxAge, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds) Read the Value attribute of one or more Nodes.- Parameters:
maxAge- the requested max age of the value, in milliseconds. If maxAge is set to 0, the Server shall attempt to read a new value from the data source. If maxAge is set to the max Int32 value or greater, the Server shall attempt to get a cached value. Negative values are invalid for maxAge.timestampsToReturn- the requestedTimestampsToReturn.nodeIds- theNodeIds identifying the Nodes to read.- Returns:
- a
CompletableFuturethat completes successfully with a list ofDataValues, or completes exceptionally if an error occurs. - See Also:
-
write
public org.eclipse.milo.opcua.stack.core.types.structured.WriteResponse write(List<org.eclipse.milo.opcua.stack.core.types.structured.WriteValue> writeValues) throws org.eclipse.milo.opcua.stack.core.UaException Write attribute values to one or more Nodes.- Parameters:
writeValues- a List ofWriteValues describing the Nodes and attribute values to write.- Returns:
- the
WriteResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
writeValues
public List<org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode> writeValues(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds, List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> values) throws org.eclipse.milo.opcua.stack.core.UaException Write the Value attribute of one or more Nodes.- Parameters:
nodeIds- theNodeIds identifying the Nodes to write.values- theDataValues to write.- Returns:
- a List of
StatusCodes describing the result of each write operation. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
writeAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.WriteResponse> writeAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.WriteValue> writeValues) Write attribute values to one or more Nodes.- Parameters:
writeValues- a List ofWriteValues describing the Nodes and attribute values to write- Returns:
- a
CompletableFuturethat completes successfully with theWriteResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
writeValuesAsync
public CompletableFuture<List<org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode>> writeValuesAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodeIds, List<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> values) Write the Value attribute of one or more Nodes.- Parameters:
nodeIds- theNodeIds identifying the Nodes to write.values- theDataValues to write.- Returns:
- a
CompletableFuturethat completes successfully with a List ofStatusCodes describing the result of each write operation, or completes exceptionally if there is an error invoking the service. - See Also:
-
historyRead
public org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadResponse historyRead(org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadDetails historyReadDetails, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadValueId> nodesToRead) throws org.eclipse.milo.opcua.stack.core.UaException Read historical values or Events of one or more Nodes.- Parameters:
historyReadDetails- defines the types of history read to be performed.timestampsToReturn- specifies the timestamps to be returned for each requested value attribute.releaseContinuationPoints- iftrue, passed continuationPoints shall be reset to free resources in the Server. iffalse, passed continuationPoints shall be used to get the next set of historical information.nodesToRead- the list of items upon which the historical retrieval is to be performed.- Returns:
- the
HistoryReadResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
historyReadAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadResponse> historyReadAsync(org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadDetails historyReadDetails, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryReadValueId> nodesToRead) Read historical values or Events of one or more Nodes.- Parameters:
historyReadDetails- defines the types of history read to be performed.timestampsToReturn- specifies the timestamps to be returned for each requested value attribute.releaseContinuationPoints- iftrue, passed continuationPoints shall be reset to free resources in the Server. iffalse, passed continuationPoints shall be used to get the next set of historical information.nodesToRead- the list of items upon which the historical retrieval is to be performed.- Returns:
- a
CompletableFuturethat completes successfully with theHistoryReadResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
historyUpdate
public org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateResponse historyUpdate(List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateDetails> historyUpdateDetails) throws org.eclipse.milo.opcua.stack.core.UaException Update historical values or Events of one or more Nodes.- Parameters:
historyUpdateDetails- theHistoryUpdateDetailsfor this update.- Returns:
- the
HistoryUpdateResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
historyUpdateAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateResponse> historyUpdateAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.HistoryUpdateDetails> historyUpdateDetails) Update historical values or Events of one or more Nodes.- Parameters:
historyUpdateDetails- theHistoryUpdateDetailsfor this update.- Returns:
- a
CompletableFuturethat completes successfully with theHistoryUpdateResponse, or completes exceptionally if there is an error invoking the service.
-
call
public org.eclipse.milo.opcua.stack.core.types.structured.CallResponse call(List<org.eclipse.milo.opcua.stack.core.types.structured.CallMethodRequest> requests) throws org.eclipse.milo.opcua.stack.core.UaException Call (invoke) one or more methods.- Parameters:
requests- theCallMethodRequests identifying the object/method to call and the input arguments.- Returns:
- the
CallResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if an error occurs.- See Also:
-
callAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CallResponse> callAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.CallMethodRequest> requests) Call (invoke) one or more methods.- Parameters:
requests- theCallMethodRequests identifying the object/method to call and the input arguments.- Returns:
- a
CompletableFuturethat completes successfully with theCallResponse, or completes exceptionally if an error occurs. - See Also:
-
createMonitoredItems
public org.eclipse.milo.opcua.stack.core.types.structured.CreateMonitoredItemsResponse createMonitoredItems(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemCreateRequest> itemsToCreate) throws org.eclipse.milo.opcua.stack.core.UaException Create and add one or more Monitored Items to a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that will report notifications for the Monitored Items.timestampsToReturn- theTimestampsToReturn.itemsToCreate- a List ofMonitoredItemCreateRequestthat describe the Monitored Items to be created and assigned to the specified subscription.- Returns:
- the
CreateMonitoredItemsResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
createMonitoredItemsAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CreateMonitoredItemsResponse> createMonitoredItemsAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemCreateRequest> itemsToCreate) Create and add one or more Monitored Items to a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that will report notifications for the Monitored Items.timestampsToReturn- theTimestampsToReturn.itemsToCreate- a List ofMonitoredItemCreateRequestthat describe the Monitored Items to be created and assigned to the specified subscription.- Returns:
- a
CompletableFuturethat completes successfully with theCreateMonitoredItemsResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
modifyMonitoredItems
public org.eclipse.milo.opcua.stack.core.types.structured.ModifyMonitoredItemsResponse modifyMonitoredItems(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemModifyRequest> itemsToModify) throws org.eclipse.milo.opcua.stack.core.UaException Modify Monitored Items of a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the items to modify.timestampsToReturn- theTimestampsToReturn.itemsToModify- a List ofMonitoredItemModifyRequestthat describe Monitored Items to modify.- Returns:
- the
ModifyMonitoredItemsResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
modifyMonitoredItemsAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.ModifyMonitoredItemsResponse> modifyMonitoredItemsAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn timestampsToReturn, List<org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemModifyRequest> itemsToModify) Modify Monitored Items of a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the items to modify.timestampsToReturn- theTimestampsToReturn.itemsToModify- a List ofMonitoredItemModifyRequestthat describe Monitored Items to modify.- Returns:
- a
CompletableFuturethat completes successfully with theModifyMonitoredItemsResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
deleteMonitoredItems
public org.eclipse.milo.opcua.stack.core.types.structured.DeleteMonitoredItemsResponse deleteMonitoredItems(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) throws org.eclipse.milo.opcua.stack.core.UaException Delete one or more Monitored Items of a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the Monitored Items to delete.monitoredItemIds- a List of server-assigned identifiers for the Monitored Items to delete.- Returns:
- the
DeleteMonitoredItemsResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
deleteMonitoredItemsAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteMonitoredItemsResponse> deleteMonitoredItemsAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) Delete one or more Monitored Items of a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the Monitored Items to delete.monitoredItemIds- a List of server-assigned identifiers for the Monitored Items to delete.- Returns:
- a
CompletableFuturethat completes successfully with theDeleteMonitoredItemsResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
setMonitoringMode
public org.eclipse.milo.opcua.stack.core.types.structured.SetMonitoringModeResponse setMonitoringMode(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) throws org.eclipse.milo.opcua.stack.core.UaException Set the Monitoring Mode for one or more Monitored Items of a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the Monitored Items.monitoringMode- theMonitoringModeto be set for the Monitored Items.monitoredItemIds- a List of server-assigned identifiers for the Monitored Items that will have theirMonitoringModeset.- Returns:
- the
SetMonitoringModeResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
setMonitoringModeAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.SetMonitoringModeResponse> setMonitoringModeAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.enumerated.MonitoringMode monitoringMode, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> monitoredItemIds) Set the Monitoring Mode for one or more Monitored Items of a Subscription.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the Monitored Items.monitoringMode- theMonitoringModeto be set for the Monitored Items.monitoredItemIds- a List of server-assigned identifiers for the Monitored Items that will have theirMonitoringModeset.- Returns:
- a
CompletableFuturethat completes successfully with theSetMonitoringModeResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
setTriggering
public org.eclipse.milo.opcua.stack.core.types.structured.SetTriggeringResponse setTriggering(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger triggeringItemId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToAdd, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToRemove) throws org.eclipse.milo.opcua.stack.core.UaException Create and delete triggering links for a triggering item.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the triggering item and items to report.triggeringItemId- the server-assigned identifier for the Monitored Item to use as the triggering item.linksToAdd- a List of server-assigned identifiers for the Monitored Items that are to be added as triggering links.linksToRemove- a List of server-assigned identifiers for the Monitored Items that are to be removed as triggering links.- Returns:
- the
SetTriggeringResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
setTriggeringAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.SetTriggeringResponse> setTriggeringAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger triggeringItemId, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToAdd, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> linksToRemove) Create and delete triggering links for a triggering item.- Parameters:
subscriptionId- the server-assigned identifier for the subscription that owns the triggering item and items to report.triggeringItemId- the server-assigned identifier for the Monitored Item to use as the triggering item.linksToAdd- a List of server-assigned identifiers for the Monitored Items that are to be added as triggering links.linksToRemove- a List of server-assigned identifiers for the Monitored Items that are to be removed as triggering links.- Returns:
- a
CompletableFuturethat completes successfully with theSetTriggeringResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
addNodes
public org.eclipse.milo.opcua.stack.core.types.structured.AddNodesResponse addNodes(List<org.eclipse.milo.opcua.stack.core.types.structured.AddNodesItem> nodesToAdd) throws org.eclipse.milo.opcua.stack.core.UaException Add one or more Nodes to the AddressSpace hierarchy.- Parameters:
nodesToAdd- a List ofAddNodesItemdescribing the Nodes to be added.- Returns:
- the
AddNodesResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
addNodesAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.AddNodesResponse> addNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.AddNodesItem> nodesToAdd) Add one or more Nodes to the AddressSpace hierarchy.- Parameters:
nodesToAdd- a List ofAddNodesItemdescribing the Nodes to be added.- Returns:
- a
CompletableFuturethat completes successfully with theAddNodesResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
addReferences
public org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesResponse addReferences(List<org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesItem> referencesToAdd) throws org.eclipse.milo.opcua.stack.core.UaException Add one or more References to one or more Nodes.- Parameters:
referencesToAdd- a List ofAddReferencesItems describing the References to add.- Returns:
- the
AddReferencesResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
addReferencesAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesResponse> addReferencesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.AddReferencesItem> referencesToAdd) Add one or more References to one or more Nodes.- Parameters:
referencesToAdd- a List ofAddReferencesItems describing the References to add.- Returns:
- a
CompletableFuturethat completes successfully with theAddReferencesResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
deleteNodes
public org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesResponse deleteNodes(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesItem> nodesToDelete) throws org.eclipse.milo.opcua.stack.core.UaException Delete one or more Nodes from the AddressSpace hierarchy.- Parameters:
nodesToDelete- a List ofDeleteNodesItems describing the Nodes to delete.- Returns:
- the
DeleteNodesResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
deleteNodesAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesResponse> deleteNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteNodesItem> nodesToDelete) Delete one or more Nodes from the AddressSpace hierarchy.- Parameters:
nodesToDelete- a List ofDeleteNodesItems describing the Nodes to delete.- Returns:
- a
CompletableFuturethat completes successfully with theDeleteNodesResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
deleteReferences
public org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesResponse deleteReferences(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesItem> referencesToDelete) throws org.eclipse.milo.opcua.stack.core.UaException Delete one or more References from one or more Nodes.- Parameters:
referencesToDelete- a List ofDeleteReferencesItemdescribing the References to delete.- Returns:
- the
DeleteReferencesResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
deleteReferencesAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesResponse> deleteReferencesAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.DeleteReferencesItem> referencesToDelete) Delete one or more References from one or more Nodes.- Parameters:
referencesToDelete- a List ofDeleteReferencesItemdescribing the References to delete.- Returns:
- a
CompletableFuturethat completes successfully with theDeleteReferencesResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
queryFirst
public org.eclipse.milo.opcua.stack.core.types.structured.QueryFirstResponse queryFirst(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription view, List<org.eclipse.milo.opcua.stack.core.types.structured.NodeTypeDescription> nodeTypes, org.eclipse.milo.opcua.stack.core.types.structured.ContentFilter filter, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxDataSetsToReturn, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesToReturn) throws org.eclipse.milo.opcua.stack.core.UaException Issue a query request to the server.- Parameters:
view- specifies a View and temporal context to a server.nodeTypes- a List ofNodeTypeDescriptionthat describe that type of Nodes to search for.filter- aContentFilterthat limits the resulting Nodes to those matching the filter criteria.maxDataSetsToReturn- the maximum number ofQueryDataSets to return.maxReferencesToReturn- the maximum number of References to return for eachQueryDataSet.- Returns:
- the
QueryFirstResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
queryFirstAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.QueryFirstResponse> queryFirstAsync(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription view, List<org.eclipse.milo.opcua.stack.core.types.structured.NodeTypeDescription> nodeTypes, org.eclipse.milo.opcua.stack.core.types.structured.ContentFilter filter, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxDataSetsToReturn, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesToReturn) Issue a query request to the server.- Parameters:
view- specifies a View and temporal context to a server.nodeTypes- a List ofNodeTypeDescriptionthat describe that type of Nodes to search for.filter- aContentFilterthat limits the resulting Nodes to those matching the filter criteria.maxDataSetsToReturn- the maximum number ofQueryDataSets to return.maxReferencesToReturn- the maximum number of References to return for eachQueryDataSet.- Returns:
- a
CompletableFuturethat completes successfully with theQueryFirstResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
queryNext
public org.eclipse.milo.opcua.stack.core.types.structured.QueryNextResponse queryNext(boolean releaseContinuationPoint, org.eclipse.milo.opcua.stack.core.types.builtin.ByteString continuationPoint) throws org.eclipse.milo.opcua.stack.core.UaException Request the next set of QueryFirst or QueryNext response information that was too large to be sent in a single response.- Parameters:
releaseContinuationPoint- iftrue, passed continuation points shall be reset to free resources in the server. Iffalse, passed continuation Points shall be used to get the next set of browse information.continuationPoint- a server-defined opaque value that represents the continuation point.- Returns:
- the
QueryNextResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
queryNextAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.QueryNextResponse> queryNextAsync(boolean releaseContinuationPoint, org.eclipse.milo.opcua.stack.core.types.builtin.ByteString continuationPoint) Request the next set of QueryFirst or QueryNext response information that was too large to be sent in a single response.- Parameters:
releaseContinuationPoint- iftrue, passed continuation points shall be reset to free resources in the server. Iffalse, passed continuation Points shall be used to get the next set of browse information.continuationPoint- a server-defined opaque value that represents the continuation point.- Returns:
- a
CompletableFuturethat completes successfully with theQueryNextResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
createSubscription
public org.eclipse.milo.opcua.stack.core.types.structured.CreateSubscriptionResponse createSubscription(double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, boolean publishingEnabled, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) throws org.eclipse.milo.opcua.stack.core.UaException Create a new Subscription belonging to this client's Session.- Parameters:
requestedPublishingInterval- this interval defines the cyclic rate that the subscription is being requested to return notifications to the client. This interval is expressed in milliseconds.requestedLifetimeCount- the requested lifetime count. The lifetime count shall be a minimum of three times the keep keep-alive count.requestedMaxKeepAliveCount- the requested maximum keep-alive count. When the publishing timer has expired this number of times without requiring any notification to be sent, the subscription sends a keep-alive message to the client.maxNotificationsPerPublish- the maximum number of notifications that the client wishes to receive in a single publish response. A value of zero indicates that there is no limit.publishingEnabled- iftrue, publishing is enabled for this subscription.priority- indicates the relative priority of the subscription.- Returns:
- the
CreateSubscriptionResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
createSubscriptionAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CreateSubscriptionResponse> createSubscriptionAsync(double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, boolean publishingEnabled, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) Create a new Subscription belonging to this client's Session.- Parameters:
requestedPublishingInterval- this interval defines the cyclic rate that the subscription is being requested to return notifications to the client. This interval is expressed in milliseconds.requestedLifetimeCount- the requested lifetime count. The lifetime count shall be a minimum of three times the keep keep-alive count.requestedMaxKeepAliveCount- the requested maximum keep-alive count. When the publishing timer has expired this number of times without requiring any notification to be sent, the subscription sends a keep-alive message to the client.maxNotificationsPerPublish- the maximum number of notifications that the client wishes to receive in a single publish response. A value of zero indicates that there is no limit.publishingEnabled- iftrue, publishing is enabled for this subscription.priority- indicates the relative priority of the subscription.- Returns:
- a
CompletableFuturethat completes successfully with theCreateSubscriptionResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
modifySubscription
public org.eclipse.milo.opcua.stack.core.types.structured.ModifySubscriptionResponse modifySubscription(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) throws org.eclipse.milo.opcua.stack.core.UaException Modify an existing Subscription belonging to this client's Session.- Parameters:
subscriptionId- the server-assigned identifier for the Subscription.requestedPublishingInterval- this interval defines the cyclic rate that the subscription is being requested to return notifications to the client. This interval is expressed in milliseconds.requestedLifetimeCount- the requested lifetime count. The lifetime count shall be a minimum of three times the keep keep-alive count.requestedMaxKeepAliveCount- the requested maximum keep-alive count. When the publishing timer has expired this number of times without requiring any notification to be sent, the subscription sends a keep-alive message to the client.maxNotificationsPerPublish- the maximum number of notifications that the client wishes to receive in a single publish response. A value of zero indicates that there is no limit.priority- indicates the relative priority of the subscription.- Returns:
- the
ModifySubscriptionResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
modifySubscriptionAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.ModifySubscriptionResponse> modifySubscriptionAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, double requestedPublishingInterval, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedLifetimeCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger requestedMaxKeepAliveCount, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxNotificationsPerPublish, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UByte priority) Modify an existing Subscription belonging to this client's Session.- Parameters:
subscriptionId- the server-assigned identifier for the Subscription.requestedPublishingInterval- this interval defines the cyclic rate that the subscription is being requested to return notifications to the client. This interval is expressed in milliseconds.requestedLifetimeCount- the requested lifetime count. The lifetime count shall be a minimum of three times the keep keep-alive count.requestedMaxKeepAliveCount- the requested maximum keep-alive count. When the publishing timer has expired this number of times without requiring any notification to be sent, the subscription sends a keep-alive message to the client.maxNotificationsPerPublish- the maximum number of notifications that the client wishes to receive in a single publish response. A value of zero indicates that there is no limit.priority- indicates the relative priority of the subscription.- Returns:
- a
CompletableFuturethat completes successfully with theModifySubscriptionResponse, or completes exceptionally if there is an error invoking the service.
-
deleteSubscriptions
public org.eclipse.milo.opcua.stack.core.types.structured.DeleteSubscriptionsResponse deleteSubscriptions(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) throws org.eclipse.milo.opcua.stack.core.UaException Delete one or more Subscriptions belonging to this client's Session.- Parameters:
subscriptionIds- the server-assigned identifiers of the Subscriptions to delete.- Returns:
- the
DeleteSubscriptionsResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
deleteSubscriptionsAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.DeleteSubscriptionsResponse> deleteSubscriptionsAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) Delete one or more Subscriptions belonging to this client's Session.- Parameters:
subscriptionIds- the server-assigned identifiers of the Subscriptions to delete.- Returns:
- a
CompletableFuturethat completes successfully with theDeleteSubscriptionsResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
transferSubscriptions
public org.eclipse.milo.opcua.stack.core.types.structured.TransferSubscriptionsResponse transferSubscriptions(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds, boolean sendInitialValues) throws org.eclipse.milo.opcua.stack.core.UaException Transfer a Subscription and its MonitoredItems from one Session to another (this) Session.- Parameters:
subscriptionIds- a List of server-assigned identifiers to be transferred to this Session.sendInitialValues-trueif the first Publish response(s) after the transfer shall contain the current values of all MonitoredItems in the Subscription where the Monitoring Mode is set toMonitoringMode.Reporting.- Returns:
- the
TransferSubscriptionsResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
transferSubscriptionsAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.TransferSubscriptionsResponse> transferSubscriptionsAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds, boolean sendInitialValues) Transfer a Subscription and its MonitoredItems from one Session to another (this) Session.- Parameters:
subscriptionIds- a List of server-assigned identifiers to be transferred to this Session.sendInitialValues-trueif the first Publish response(s) after the transfer shall contain the current values of all MonitoredItems in the Subscription where the Monitoring Mode is set toMonitoringMode.Reporting.- Returns:
- a
CompletableFuturethat completes successfully with theTransferSubscriptionsResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
setPublishingMode
public org.eclipse.milo.opcua.stack.core.types.structured.SetPublishingModeResponse setPublishingMode(boolean publishingEnabled, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) throws org.eclipse.milo.opcua.stack.core.UaException Enable or disable the sending of notifications on one or more subscriptions.- Parameters:
publishingEnabled-trueif publishing is enabled.subscriptionIds- a List of server-assigned identifiers for subscriptions.- Returns:
- the
SetPublishingModeResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
setPublishingModeAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.SetPublishingModeResponse> setPublishingModeAsync(boolean publishingEnabled, List<org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger> subscriptionIds) Enable or disable the sending of notifications on one or more subscriptions.- Parameters:
publishingEnabled-trueif publishing is enabled.subscriptionIds- a List of server-assigned identifiers for subscriptions.- Returns:
- a
CompletableFuturethat completes successfully with theSetPublishingModeResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
publish
public org.eclipse.milo.opcua.stack.core.types.structured.PublishResponse publish(List<org.eclipse.milo.opcua.stack.core.types.structured.SubscriptionAcknowledgement> subscriptionAcknowledgements) throws org.eclipse.milo.opcua.stack.core.UaException Send aPublishRequestto the server, acknowledging the receipt of previously-received messages and requesting the server return a NotificationMessage or keep-alive message.- Parameters:
subscriptionAcknowledgements- a List ofSubscriptionAcknowledgements for one or more subscriptions.- Returns:
- the
PublishResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
publishAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.PublishResponse> publishAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.SubscriptionAcknowledgement> subscriptionAcknowledgements) Send aPublishRequestto the server, acknowledging the receipt of previously-received messages and requesting the server return a NotificationMessage or keep-alive message.- Parameters:
subscriptionAcknowledgements- a List ofSubscriptionAcknowledgements for one or more subscriptions.- Returns:
- a
CompletableFuturethat completes successfully with thePublishResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
republish
public org.eclipse.milo.opcua.stack.core.types.structured.RepublishResponse republish(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger retransmitSequenceNumber) throws org.eclipse.milo.opcua.stack.core.UaException Send aRepublishRequestto the server, requesting the server republish a NotificationMessage from its retransmission queue.- Parameters:
subscriptionId- the server-assigned identifier for the Subscription.retransmitSequenceNumber- the sequence number of the NotificationMessage to be republished.- Returns:
- the
RepublishResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
republishAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.RepublishResponse> republishAsync(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger subscriptionId, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger retransmitSequenceNumber) Send aRepublishRequestto the server, requesting the server republish a NotificationMessage from its retransmission queue.- Parameters:
subscriptionId- the server-assigned identifier for the Subscription.retransmitSequenceNumber- the sequence number of the NotificationMessage to be republished.- Returns:
- a
CompletableFuturethat completes successfully with theRepublishResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
browse
public org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult browse(org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription nodeToBrowse) throws org.eclipse.milo.opcua.stack.core.UaException Browse references of a single Node.- Parameters:
nodeToBrowse- the Node to browse.- Returns:
- the
BrowseResult. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
browse
public List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult> browse(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) throws org.eclipse.milo.opcua.stack.core.UaException Browse references of one or more Nodes.- Parameters:
nodesToBrowse- the Nodes to browse.- Returns:
- the
BrowseResults. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
browse
public org.eclipse.milo.opcua.stack.core.types.structured.BrowseResponse browse(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription viewDescription, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesPerNode, List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) throws org.eclipse.milo.opcua.stack.core.UaException Browse references of one or more Nodes.- Parameters:
viewDescription- a description of the view to browse. An emptyViewDescriptionindicates a view of the entire address space.maxReferencesPerNode- the maximum number of references to return for each starting Node specified in the request.nodesToBrowse- a List of Nodes to browse.- Returns:
- the
BrowseResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
browseAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResponse> browseAsync(org.eclipse.milo.opcua.stack.core.types.structured.ViewDescription viewDescription, org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger maxReferencesPerNode, List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) Browse references of one or more Nodes.- Parameters:
viewDescription- a description of the view to browse. An emptyViewDescriptionindicates a view of the entire address space.maxReferencesPerNode- the maximum number of references to return for each starting Node specified in the request.nodesToBrowse- a List of Nodes to browse.- Returns:
- a
CompletableFuturethat completes successfully with theBrowseResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
browseAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult> browseAsync(org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription nodeToBrowse) Browse a single node, with no view and no max references specified.- Parameters:
nodeToBrowse- the node to browse.- Returns:
- a
CompletableFuturecontaining theBrowseResult. - See Also:
-
browseAsync
public CompletableFuture<List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseResult>> browseAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowseDescription> nodesToBrowse) Browse a list of nodes, with no view and no max references specified.- Parameters:
nodesToBrowse- the nodes to browse.- Returns:
- a
CompletableFuturecontaining theBrowseResults. - See Also:
-
browseNext
public org.eclipse.milo.opcua.stack.core.types.structured.BrowseNextResponse browseNext(boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.builtin.ByteString> continuationPoints) throws org.eclipse.milo.opcua.stack.core.UaException Request the next set of Browse or BrowseNext information that was too large to be sent in a single response.- Parameters:
releaseContinuationPoints- iftrue, the continuation points are released to free resources in the server. Iffalse, they are used to get the next set of browse information.continuationPoints- server-defined opaque values that represent continuation points.- Returns:
- the
BrowseNextResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
browseNextAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.BrowseNextResponse> browseNextAsync(boolean releaseContinuationPoints, List<org.eclipse.milo.opcua.stack.core.types.builtin.ByteString> continuationPoints) Request the next set of Browse or BrowseNext information that was too large to be sent in a single response.- Parameters:
releaseContinuationPoints- iftrue, the continuation points are released to free resources in the server. Iffalse, they are used to get the next set of browse information.continuationPoints- server-defined opaque values that represent continuation points.- Returns:
- a
CompletableFuturethat completes successfully with theBrowseNextResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
translateBrowsePaths
public org.eclipse.milo.opcua.stack.core.types.structured.TranslateBrowsePathsToNodeIdsResponse translateBrowsePaths(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowsePath> browsePaths) throws org.eclipse.milo.opcua.stack.core.UaException Translate one or moreBrowsePaths intoNodeIds.- Parameters:
browsePaths- a List ofBrowsePaths to translate.- Returns:
- the
TranslateBrowsePathsToNodeIdsResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
translateBrowsePathsAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.TranslateBrowsePathsToNodeIdsResponse> translateBrowsePathsAsync(List<org.eclipse.milo.opcua.stack.core.types.structured.BrowsePath> browsePaths) Translate one or moreBrowsePaths intoNodeIds.- Parameters:
browsePaths- a List ofBrowsePaths to translate.- Returns:
- a
CompletableFuturethat completes successfully with theTranslateBrowsePathsToNodeIdsResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
registerNodes
public org.eclipse.milo.opcua.stack.core.types.structured.RegisterNodesResponse registerNodes(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToRegister) throws org.eclipse.milo.opcua.stack.core.UaException RegisterNodeIds that the client intends to access repeatedly (e.g. read, write, call), allowing servers to set up anything needed so that the access operations are more efficient.- Parameters:
nodesToRegister- theNodeIds of the Nodes to register.- Returns:
- the
RegisterNodesResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
registerNodesAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.RegisterNodesResponse> registerNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToRegister) Register Nodes that the client intends to access repeatedly (e.g. read, write, call), allowing servers to set up anything needed so that the access operations are more efficient.- Parameters:
nodesToRegister- theNodeIds of the Nodes to register.- Returns:
- a
CompletableFuturethat completes successfully with theRegisterNodesResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
unregisterNodes
public org.eclipse.milo.opcua.stack.core.types.structured.UnregisterNodesResponse unregisterNodes(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToUnregister) throws org.eclipse.milo.opcua.stack.core.UaException Unregister Nodes that were previously registered with a Register Nodes service call.- Parameters:
nodesToUnregister- theNodeIds returned by the previous Register Nodes service call.- Returns:
- the
UnregisterNodesResponse. - Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.- See Also:
-
unregisterNodesAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.UnregisterNodesResponse> unregisterNodesAsync(List<org.eclipse.milo.opcua.stack.core.types.builtin.NodeId> nodesToUnregister) Unregister Nodes that were previously registered with a Register Nodes service call.- Parameters:
nodesToUnregister- theNodeIds returned by the previous Register Nodes service call.- Returns:
- a
CompletableFuturethat completes successfully with theUnregisterNodesResponse, or completes exceptionally if there is an error invoking the service. - See Also:
-
sendRequest
public org.eclipse.milo.opcua.stack.core.types.UaResponseMessageType sendRequest(org.eclipse.milo.opcua.stack.core.types.UaRequestMessageType request) throws org.eclipse.milo.opcua.stack.core.UaException Send a service request and wait for the service response.- Parameters:
request- the service request to send.- Returns:
- the service response.
- Throws:
org.eclipse.milo.opcua.stack.core.UaException- if there is an error invoking the service.
-
sendRequestAsync
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.UaResponseMessageType> sendRequestAsync(org.eclipse.milo.opcua.stack.core.types.UaRequestMessageType request) Send a service request asynchronously.- Parameters:
request- the service request to send.- Returns:
- a
CompletableFuturethat completes successfully with the service response, or completes exceptionally if there is an error invoking the service.
-
addFaultListener
-
removeFaultListener
-
addSessionActivityListener
-
removeSessionActivityListener
-
addSessionInitializer
-
removeSessionInitializer
-