| Package | Description |
|---|---|
| com.prosysopc.ua |
Common classes for client and server side.
|
| com.prosysopc.ua.client |
Main client side classes of the SDK.
|
| com.prosysopc.ua.pubsub |
PubSub (Part 14 of the OPC UA Specification) related implementations.
|
| com.prosysopc.ua.server |
Main server side classes of the SDK.
|
| com.prosysopc.ua.stack.application |
The code in this package is for application developer.
|
| com.prosysopc.ua.stack.common |
This package contains common and shared classes
|
| com.prosysopc.ua.stack.encoding |
This folder contains serialization interfaces and serialization implementations
|
| com.prosysopc.ua.stack.transport |
This package contains SecureChannel and related interfaces
|
| com.prosysopc.ua.stack.transport.endpoint |
Endpoint related classes
|
| com.prosysopc.ua.stack.transport.https |
Code for creating a HTTPS based secure channel
|
| com.prosysopc.ua.stack.transport.impl |
This package contains SecureChannel related implementations
|
| com.prosysopc.ua.stack.transport.security |
This folder contains common security related classes
|
| com.prosysopc.ua.stack.transport.tcp.impl | |
| com.prosysopc.ua.stack.transport.tcp.io | |
| com.prosysopc.ua.stack.transport.tcp.nio | |
| com.prosysopc.ua.stack.utils |
Utility classes
|
| Constructor and Description |
|---|
ServiceException(ServiceResultException cause)
Creates a new ServiceException from a ServiceResultException.
|
ServiceException(String msg,
ServiceResultException cause)
Creates a new ServiceException from a ServiceResultException overriding the message with the
given one.
|
SessionActivationException(String message,
UserIdentity userIdentity,
ServiceResultException ex)
Creates a SessionActivationException.
|
StatusException(ServiceResultException ex)
Creates a new StatusException from an ServiceResultException.
|
StatusException(String msg,
ServiceResultException ex)
Creates a new StatusException with a custom message and exception.
|
| Modifier and Type | Method and Description |
|---|---|
List<ReferenceDescription> |
AddressSpace.browseUp(ExpandedNodeId nodeId)
Browse up in the address space hierarchy.
|
List<ReferenceDescription> |
AddressSpace.browseUp(UaNodeId nodeId)
Browse up in the address space hierarchy.
|
UaMethod |
AddressSpace.getMethod(ExpandedNodeId methodId)
Get an UA method definition from the server.
|
UaMethod |
AddressSpace.getMethod(UaNodeId methodId)
Get an UA method definition from the server.
|
UaMethod |
AddressSpace.getMethodByName(NodeId nodeId,
QualifiedName methodName)
Get a method with methodName of a node.
|
protected NodeId |
GlobalServerList.getNodeId(BrowsePathResult[] results,
int i) |
QueryDataSet[] |
AddressSpace.query(NodeTypeDescription[] nodeTypes,
ContentFilter filter) |
QueryDataSet[] |
AddressSpace.query(NodeTypeDescription[] nodeTypes,
ContentFilter filter,
UnsignedInteger maxDataSetsToReturn,
UnsignedInteger maxReferencesToReturn) |
protected QueryDataSet[] |
AddressSpace.query(ViewDescription view,
NodeTypeDescription[] nodeTypes,
ContentFilter filter,
UnsignedInteger maxDataSetsToReturn,
UnsignedInteger maxReferencesToReturn)
Makes the Query for the parameters.
|
QueryFirstResponse |
AddressSpace.queryFirst(NodeTypeDescription[] nodeTypes,
ContentFilter filter) |
QueryFirstResponse |
AddressSpace.queryFirst(QueryFirstRequest request) |
QueryNextResponse |
AddressSpace.queryNext(boolean releaseContinuationPoints,
byte[] continuationPoint) |
QueryNextResponse |
AddressSpace.queryNext(boolean releaseContinuationPoints,
ByteString continuationPoint) |
protected <T extends ServiceResponse> |
UaClient.validateServiceRequest(ServiceRequest<T> request)
This method is called before any
ServiceRequest is sent to the server (during a
Session). |
| Constructor and Description |
|---|
ConnectException(String message,
String uri,
SecurityMode securityMode,
ServiceResultException cause)
Create a new exception with a message text and reference to the original exception.
|
InvalidServerCertificateException(String message,
String uri,
SecurityMode securityMode,
ServiceResultException cause) |
InvalidServerEndpointException(String message,
String uri,
SecurityMode securityMode,
ServiceResultException cause) |
| Constructor and Description |
|---|
PubSubException(ServiceResultException ex) |
PubSubException(String msg,
ServiceResultException ex) |
| Modifier and Type | Method and Description |
|---|---|
ServiceResultException |
ReverseConnectionStatus.getCloseError()
If
ReverseConnectionStatus.isConnected is false, returns why the connection is closed (or failed to be
formed), otherwise returns null. |
ServiceResultException |
ReverseConnectionStatus.Builder.getCloseError() |
| Modifier and Type | Method and Description |
|---|---|
void |
ReverseConnectionStatus.Builder.setCloseError(ServiceResultException closeError) |
| Modifier and Type | Method and Description |
|---|---|
void |
IoManagerUaNode.addTypeListener(Class<? extends BaseInstanceType> clazz,
UaTypeIoListener listener)
Add
UaTypeIoListener to the TypeIoManagerListener. |
protected UaNode |
NodeManager.findNode(ExpandedNodeId nodeId)
Find the UaNode corresponding to the nodeId, if the Node Manager
NodeManager.supportsUaNode(). |
HttpsServer |
UaServer.DiscoveryServer.getOrCreateHttpsServer() |
OpcTcpServer |
UaServer.DiscoveryServer.getOrCreateOpcTcpServer() |
| Modifier and Type | Method and Description |
|---|---|
ActivateSessionResponse |
SessionChannel.activate()
Activate session using anonymous access.
|
ActivateSessionResponse |
SessionChannel.activate(byte[] issuedIdentityToken)
Activate session using identity token.
|
ActivateSessionResponse |
SessionChannel.activate(String username,
String password)
Activate session using user name and password.
|
ActivateSessionResponse |
SessionChannel.activate(UserIdentityToken identity,
SignatureData identitySignature,
boolean validateNonceLength,
boolean serverSupportsSecureUserTokenPolicy)
Activate session.
|
List<EndpointServer.EndpointHandle> |
Server.bind(String bindAddress,
Endpoint endpointAddress)
Bind an endpoint to the server.
|
List<EndpointServer.EndpointHandle> |
Server.bind(String bindAddress,
String endpointUri,
Collection<SecurityMode> modes) |
List<EndpointServer.EndpointHandle> |
Server.bind(String bindAddress,
String endpointUri,
SecurityMode... modes)
bind.
|
EndpointServer.ReverseEndpointHandle |
Server.bindReverse(ReverseConnectionParameters parameters,
ScheduledExecutorService retryScheduledExecutorService)
Binds a "ReverseHello" pseudo-endpoint to the server.
|
void |
SessionChannel.close()
Close the session and the secure channel.
|
SecureChannel |
Client.createReverseSecureChannel(String localEndpointUrl,
ReverseTransportChannelSettings settings)
Open a local connection accepting a ReverseHello messages sent by the server.
|
SecureChannel |
Client.createSecureChannel(ApplicationDescription applicationDescription)
Create a secure channel to a UA application
|
SecureChannel |
Client.createSecureChannel(EndpointDescription endpoint)
Create a secure channel to an endpoint
|
SecureChannel |
Client.createSecureChannel(String endpointUrl)
Create a secure channel to a UA Server This method first queries endpoints, chooses the most
suitable and connects to it.
|
SecureChannel |
Client.createSecureChannel(String connectUrl,
EndpointDescription endpoint)
Create a secure channel to an endpoint.
|
SecureChannel |
Client.createSecureChannel(String connectUrl,
String endpointUri)
Create a secure channel to a UA Server This method first queries endpoints, chooses the most
suitable and connects to it.
|
SecureChannel |
Client.createSecureChannel(String connectUrl,
String endpointUri,
SecurityMode mode,
Cert remoteCertificate)
Create and open a secure channel.
|
SecureChannel |
Client.createSecureChannel(String connectUrl,
TransportChannelSettings settings)
Create and open a secure channel.
|
SecureChannel |
Client.createSecureChannel(TransportChannelSettings settings)
Create and open a secure channel.
|
ServiceChannel |
Client.createServiceChannel(ApplicationDescription applicationDescription)
Create a service channel
|
ServiceChannel |
Client.createServiceChannel(EndpointDescription endpoint)
Create a service channel to an endpoint.
|
ServiceChannel |
Client.createServiceChannel(String endpointUrl)
Create a service channel to a UA Server This method first queries endpoints, chooses the most
suitable and connects to it.
|
ServiceChannel |
Client.createServiceChannel(String connectUrl,
EndpointDescription endpoint)
Create a service channel to an endpoint
|
ServiceChannel |
Client.createServiceChannel(String connectUrl,
String endpointUri)
Create a service channel to a UA Server This method first queries endpoints, chooses the most
suitable and connects to it.
|
ServiceChannel |
Client.createServiceChannel(String connectUrl,
String endpointUri,
SecurityMode mode,
Cert remoteCertificate)
Create and open a service channel.
|
ServiceChannel |
Client.createServiceChannel(TransportChannelSettings settings)
Create and open a secure channel and adapt to service channel.
|
Session |
Client.createSession(SecureChannel channel)
Create a new session on a server.
|
Session |
Client.createSession(SecureChannel channel,
UnsignedInteger maxResponseMessageSize,
Double requestedSessionTimeout,
String sessionName)
Create a new session on a server
|
Session |
Client.createSession(SecureChannel channel,
UnsignedInteger maxResponseMessageSize,
Double requestedSessionTimeout,
String sessionName,
EndpointDescription[] discoveredEndpoints)
Create a new session on a server
|
SessionChannel |
Client.createSessionChannel(ApplicationDescription applicationDescription)
Creates a secure channel and an unactivated session channel.
|
SessionChannel |
Client.createSessionChannel(EndpointDescription endpoint)
Creates a secure channel and an unactivated session channel.
|
SessionChannel |
Client.createSessionChannel(String endpointUrl)
Creates a secure channel and an unactivated session channel.
|
SessionChannel |
Client.createSessionChannel(String connectUrl,
EndpointDescription endpoint)
Creates a secure channel and an unactivated session channel.
|
SessionChannel |
Client.createSessionChannel(String connectUrl,
String endpointUri)
Creates a secure channel and an unactivated session channel.
|
ApplicationDescription[] |
Client.discoverApplications(String discoverServerEndpointUrl)
Discover applications
|
ApplicationDescription[] |
Client.discoverApplications(String connectUrl,
String discoverServerEndpointUri)
Discover applications
|
EndpointDescription[] |
Client.discoverEndpoints(String discoveryEndpointUrl)
Discover endpoints
|
EndpointDescription[] |
Client.discoverEndpoints(String connectUrl,
String discoveryEndpointUri)
Discover endpoints.
|
ServerOnNetwork[] |
Client.discoverServersOnNetwork(String discoverServerEndpointUrl)
Discover ServerOnNetwork records from LDS
|
ServerOnNetwork[] |
Client.discoverServersOnNetwork(String connectUrl,
String discoverServerEndpointUri)
Discover ServerOnNetwork records from LDS
|
ServerOnNetwork[] |
Client.discoverServersOnNetwork(String connectUrl,
String discoverServerEndpointUri,
String[] serverCapabilities)
Discover ServerOnNetwork records from LDS
|
FindServersOnNetworkResponse |
Client.discoverServersOnNetwork(String connectUrl,
String discoverServerEndpointUri,
UnsignedInteger startingRecordId,
UnsignedInteger maxRecordsToReturn,
String[] serverCapabilities)
Get FindServersOnNetworkResponse to retrieve ServerOnNetwork records and lastCounterResetTime
associated with them
|
EndpointServer |
Server.getOrCreateEndpointServer(String scheme)
getOrCreateEndpointServer.
|
HttpsServer |
Server.getOrCreateHttpsServer()
getOrCreateHttpsServer.
|
OpcTcpServer |
Server.getOrCreateOpcTcpServer()
getOrCreateOpcTcpServer.
|
void |
ServiceHandler.serve(EndpointServiceRequest<?,?> request)
Serve a service request.
|
<T extends ServiceResponse> |
SessionChannel.serviceRequest(ServiceRequest<T> serviceRequest)
Invokes session service request.
|
<T extends ServiceResponse> |
SessionChannel.RequestValidator.validateServiceRequest(SessionChannel channel,
ServiceRequest<T> request)
If attached to a
SessionChannel, this method is called before the request is
delegated to underlying secure channel and allows modification of the request or prevention
it's delegation (by throwing the ServiceResultException). |
| Modifier and Type | Class and Description |
|---|---|
class |
ServiceFaultException
ServiceFaultException is an error that occurs in execution an operation.
|
| Modifier and Type | Method and Description |
|---|---|
ServiceResultException |
RuntimeServiceResultException.getCause() |
| Modifier and Type | Method and Description |
|---|---|
static int |
InternalNamespaceUtils.getIndexFromPotentialInvalidPattern(String namespaceUri,
NamespaceTable namespaceTable)
Returns the NamespaceIndex of the given NamespaceUri using the given
NamespaceTable
with if not found, but recognizes special patterns returned by
InternalNamespaceUtils.getUriOrUseInvalidPattern(int, NamespaceTable). |
static int |
InternalNamespaceUtils.getIndexFromPotentialInvalidPattern(UaNamespace namespace,
NamespaceTable namespaceTable)
Returns the NamespaceIndex of the given
UaNamespace using the given
NamespaceTable with if not found, but recognizes special patterns returned by
InternalNamespaceUtils.getUriOrUseInvalidPattern(int, NamespaceTable). |
NodeId |
NamespaceTable.toNodeId(ExpandedNodeId expandedNodeId)
Convert the expandedNodeId to a NodeId using the name space indexes of the table.
|
| Constructor and Description |
|---|
RuntimeServiceResultException(ServiceResultException cause)
Constructor for RuntimeServiceResultException.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DecodingException
DecodingException class.
|
class |
EncodingException
EncodingException class.
|
| Modifier and Type | Method and Description |
|---|---|
ServiceResultException |
AsyncResult.getError()
getError.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AsyncWrite.attemptSetError(ServiceResultException ex)
attemptSetError.
|
void |
AsyncRead.attemptSetError(ServiceResultException e)
attemptSetError.
|
void |
IConnectionListener.onClosed(ServiceResultException closeError)
The connection has been closed
|
void |
ResultListener.onError(ServiceResultException error)
There was an error in processing the request
|
void |
AsyncWrite.setError(ServiceResultException ex)
setError.
|
void |
AsyncRead.setError(ServiceResultException e)
setError.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractServerSecureChannel.setError(ServiceResultException e)
setError.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HttpsServerSecureChannel.setError(ServiceResultException e)
setError.
|
| Modifier and Type | Method and Description |
|---|---|
EndpointServer.EndpointHandle |
HttpsServer.bind(SocketAddress socketAddress,
EndpointBinding endpointBinding)
Bind an endpoint to a handle.
|
void |
HttpsClientSecureChannel.initialize(String url,
TransportChannelSettings tcs,
EncoderContext ctx)
Initialize a secure channel with endpoint identified by the URL.
|
void |
HttpsClient.initialize(String connectUrl,
TransportChannelSettings tcs,
EncoderContext ctx) |
void |
HttpsClientSecureChannel.initialize(TransportChannelSettings tcs,
EncoderContext ctx)
Initialize a secure channel with endpoint identified by the URL.
|
protected void |
HttpsServer.initReactor()
initReactor.
|
void |
HttpsClientSecureChannel.open()
Open the secure channel with the endpoint identified by the URL.
|
<T extends ServiceResponse> |
HttpsClientSecureChannel.serviceRequest(ServiceRequest<T> request) |
<T extends ServiceResponse> |
HttpsClient.serviceRequest(ServiceRequest<T> request)
Send a service request over the secure channel.
|
<T extends ServiceResponse> |
HttpsClient.serviceRequest(ServiceRequest<T> request,
long operationTimeout)
Send a service request over the secure channel.
|
void |
HttpsSettings.setKeyManager(X509KeyManager keyManager)
Set keymanager for a https application.
|
void |
HttpsSettings.setKeyStore(KeyStore keystore,
String password)
Set keystore as the key manager for a https application.
|
void |
HttpsSettings.setTrustManager(TrustManager trustManager)
Set the trust manager for a https application.
|
| Constructor and Description |
|---|
HttpsServer(Application application)
Constructor for HttpsServer.
|
| Modifier and Type | Method and Description |
|---|---|
ServiceResultException |
AsyncResultImpl.getError()
getError.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> AsyncResultImpl<T> |
AsyncResultImpl.failed(ServiceResultException failure)
Returns new
AsyncResultImpl that has already failed with the given error. |
void |
AsyncResultImpl.setError(ServiceResultException error)
Set error, invokes any listener in executor thread.
|
void |
AsyncResultImpl.setErrorSync(ServiceResultException error)
Set error, invokes any listener here and now.
|
| Modifier and Type | Method and Description |
|---|---|
T |
AsyncResultImpl.waitForResult()
Wait for result until result is available.
|
T |
AsyncResultImpl.waitForResult(long timeout,
TimeUnit unit)
Wait for result or time out.
|
| Modifier and Type | Method and Description |
|---|---|
Mac |
JceCryptoProvider.createMac(SecurityAlgorithm algorithm,
byte[] secret) |
Mac |
CryptoProvider.createMac(SecurityAlgorithm algorithm,
byte[] secret) |
Mac |
BcCryptoProvider.createMac(SecurityAlgorithm algorithm,
byte[] secret) |
int |
JceCryptoProvider.decryptAsymm(PrivateKey decryptingKey,
SecurityAlgorithm algorithm,
byte[] dataToDecrypt,
byte[] output,
int outputOffset) |
int |
CryptoProvider.decryptAsymm(PrivateKey decryptingKey,
SecurityAlgorithm algorithm,
byte[] dataToDecrypt,
byte[] output,
int outputOffset) |
int |
BcCryptoProvider.decryptAsymm(PrivateKey decryptingKey,
SecurityAlgorithm algorithm,
byte[] dataToDecrypt,
byte[] output,
int outputOffset) |
int |
JceCryptoProvider.decryptSymm(SecurityPolicy policy,
byte[] encryptingKey,
byte[] iv,
byte[] dataToDecrypt,
int inputOffset,
int inputLength,
byte[] output,
int outputOffset) |
int |
CryptoProvider.decryptSymm(SecurityPolicy policy,
byte[] encryptingKey,
byte[] initializationVector,
byte[] dataToDecrypt,
int inputOffset,
int inputLength,
byte[] output,
int outputOffset) |
int |
BcCryptoProvider.decryptSymm(SecurityPolicy policy,
byte[] encryptingKey,
byte[] iv,
byte[] dataToDecrypt,
int inputOffset,
int inputLength,
byte[] output,
int outputOffset) |
void |
JceCryptoProvider.encryptAsymm(PublicKey remotePublicKey,
SecurityAlgorithm algorithm,
byte[] dataToEncrypt,
byte[] output,
int outputOffset) |
void |
CryptoProvider.encryptAsymm(PublicKey encryptingCertificate,
SecurityAlgorithm algorithm,
byte[] dataToEncrypt,
byte[] output,
int outputOffset) |
void |
BcCryptoProvider.encryptAsymm(PublicKey encryptingCertificate,
SecurityAlgorithm algorithm,
byte[] dataToEncrypt,
byte[] output,
int outputOffset) |
int |
JceCryptoProvider.encryptSymm(SecurityPolicy policy,
byte[] encryptingKey,
byte[] iv,
byte[] dataToEncrypt,
int inputOffset,
int inputLength,
byte[] output,
int outputOffset) |
int |
CryptoProvider.encryptSymm(SecurityPolicy policy,
byte[] encryptingKey,
byte[] initializationVector,
byte[] dataToEncrypt,
int inputOffset,
int inputLength,
byte[] output,
int outputOffset) |
int |
BcCryptoProvider.encryptSymm(SecurityPolicy policy,
byte[] encryptingKey,
byte[] iv,
byte[] dataToEncrypt,
int inputOffset,
int inputLength,
byte[] output,
int outputOffset) |
static Cert |
Cert.fromEncoded(byte[] encodedCertChain)
Create
Cert from encoded data. |
static Cert |
Cert.fromx509Certificates(X509Certificate... certChain)
Create
Cert from given one ore more X509Certificate certificates. |
static SecurityPolicy |
SecurityPolicy.getSecurityPolicy(String securityPolicyUri)
Get security policy by policy uri.
|
byte[] |
JceCryptoProvider.signAsymm(PrivateKey senderPrivate,
SecurityAlgorithm algorithm,
byte[] dataToSign) |
byte[] |
CryptoProvider.signAsymm(PrivateKey senderPrivate,
SecurityAlgorithm algorithm,
byte[] dataToSign) |
byte[] |
BcCryptoProvider.signAsymm(PrivateKey senderPrivate,
SecurityAlgorithm algorithm,
byte[] dataToSign) |
void |
JceCryptoProvider.signSymm(SecurityPolicy policy,
byte[] key,
byte[] input,
int inputOffset,
int verifyLen,
byte[] output,
int outputOffset) |
void |
CryptoProvider.signSymm(SecurityPolicy policy,
byte[] key,
byte[] input,
int inputOffset,
int verifyLen,
byte[] output,
int outputOffset) |
void |
BcCryptoProvider.signSymm(SecurityPolicy policy,
byte[] key,
byte[] input,
int inputOffset,
int verifyLen,
byte[] output,
int outputOffset) |
boolean |
JceCryptoProvider.verifyAsymm(PublicKey signingCertificate,
SecurityAlgorithm algorithm,
byte[] dataToVerify,
byte[] signature) |
boolean |
CryptoProvider.verifyAsymm(PublicKey signingCertificate,
SecurityAlgorithm algorithm,
byte[] dataToVerify,
byte[] signature) |
boolean |
BcCryptoProvider.verifyAsymm(PublicKey signingCertificate,
SecurityAlgorithm algorithm,
byte[] dataToVerify,
byte[] signature) |
void |
JceCryptoProvider.verifySymm(SecurityPolicy policy,
byte[] key,
byte[] dataToVerify,
int inputOffset,
int verifyLen,
byte[] signature) |
void |
CryptoProvider.verifySymm(SecurityPolicy policy,
byte[] key,
byte[] dataToVerify,
int inputOffset,
int verifyLen,
byte[] signature) |
void |
BcCryptoProvider.verifySymm(SecurityPolicy policy,
byte[] key,
byte[] dataToVerify,
int inputOffset,
int verifyLen,
byte[] signature) |
| Constructor and Description |
|---|
Cert(byte[] data)
Create Certificate from encoded data, if the data contains more than one certificate, only the
first one is read.
|
| Modifier and Type | Method and Description |
|---|---|
protected Mac |
SecurityToken.createHmac(byte[] secret)
createHmac.
|
Mac |
SecurityToken.createLocalHmac()
Create new localHmac.
|
Mac |
SecurityToken.createRemoteHmac()
Crate new remoteHmac.
|
static byte[] |
ChunkUtils.getByteString(ByteBuffer chunk)
Returns ByteString from the chunk.
|
static String |
ChunkUtils.getSecurityPolicyUri(ByteBuffer chunk)
getSecurityPolicyUri.
|
static String |
ChunkUtils.getString(ByteBuffer chunk)
Returns String (read as UTF-8 ByteString) from the chunk.
|
| Constructor and Description |
|---|
AsymmMsgChunkFactory(int maxChunkSize,
SecurityConfiguration profile) |
SecurityToken(SecurityConfiguration securityProfile,
int secureChannelId,
int tokenId,
long creationTime,
long lifetime,
ByteString serverNonce,
ByteString clientNonce)
Create new security token.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SecureChannelTcp.onClosed(ServiceResultException closeError)
The connection has been closed
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpConnection.initialize(InetSocketAddress addr,
TransportChannelSettings settings,
EncoderContext ctx)
Set connection configuration parameters.
|
void |
SecureChannelTcp.initialize(InetSocketAddress addr,
TransportChannelSettings settings,
EncoderContext ctx)
Configure the secure channel.
|
void |
IConnection.initialize(InetSocketAddress addr,
TransportChannelSettings settings,
EncoderContext ctx)
Set connection configuration parameters.
|
void |
TcpConnection.initialize(String url,
TransportChannelSettings settings,
EncoderContext ctx) |
void |
SecureChannelTcp.initialize(String url,
TransportChannelSettings settings,
EncoderContext ctx)
Configure the secure channel.
|
void |
ITransportChannel.initialize(String url,
TransportChannelSettings settings,
EncoderContext ctx)
Initialize a secure channel with endpoint identified by the URL.
|
void |
TcpConnection.initialize(TransportChannelSettings settings,
EncoderContext ctx)
initialize.
|
void |
SecureChannelTcp.initialize(TransportChannelSettings settings,
EncoderContext ctx)
Configure the secure channel.
|
void |
TcpConnection.open()
open.
|
void |
SecureChannelTcp.open()
Opens a secure channel.
|
void |
IConnection.open()
Attempt to open the connection.
|
void |
TcpConnection.reconnect()
reconnect.
|
void |
IConnection.reconnect()
Open if the connection is not open.
|
void |
TcpConnection.sendRequest(ServiceRequest request,
int secureChannelId,
int requestId)
Send request to the connection.
|
void |
IConnection.sendRequest(ServiceRequest request,
int secureChannelId,
int requestId)
Send request to the connection.
|
<T extends ServiceResponse> |
SecureChannelTcp.serviceRequest(ServiceRequest<T> request)
Send a service request over the secure channel.
|
<T extends ServiceResponse> |
ITransportChannel.serviceRequest(ServiceRequest<T> request)
Send a service request over the secure channel.
|
<T extends ServiceResponse> |
SecureChannelTcp.serviceRequest(ServiceRequest<T> request,
long operationTimeout)
Send a service request over the secure channel.
|
<T extends ServiceResponse> |
ITransportChannel.serviceRequest(ServiceRequest<T> request,
long operationTimeout)
Send a service request over the secure channel.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
OpcTcpServerConnection.setError(ServiceResultException e) |
protected void |
AbstractServerConnection.setError(ServiceResultException e)
setError.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SecureInputMessageBuilder.addChunk(ByteBuffer chunk)
addChunk.
|
EndpointServer.EndpointHandle |
OpcTcpServer.bind(SocketAddress socketAddress,
EndpointBinding endpointBinding)
Bind an endpoint to a handle.
|
protected void |
OpcTcpServerConnection.handleAcknowledgeMessage(Acknowledge a)
handleAcknowledgeMessage.
|
protected void |
OpcTcpServerConnection.handleAsymmChunk(ByteBuffer chunk)
handleAsymmChunk.
|
protected void |
OpcTcpServerConnection.handleChunk(ByteBuffer chunk)
handleChunk.
|
protected void |
OpcTcpServerConnection.handleCloseChunk(ByteBuffer chunk)
handleCloseChunk.
|
protected void |
OpcTcpServerConnection.handleCloseSecureChannelRequest(InputMessage mb)
handleCloseSecureChannelRequest.
|
protected void |
OpcTcpServerConnection.handleHelloMessage(Hello h)
handleHelloMessage.
|
protected void |
OpcTcpServerSecureChannel.handleOpenChannel(InputMessage mb,
OpenSecureChannelRequest req)
handleOpenChannel.
|
protected void |
OpcTcpServerConnection.handleOpenSecureChannelRequest(InputMessage mb)
handleOpenSecureChannelRequest.
|
protected void |
OpcTcpServerSecureChannel.handleRenewSecureChannelRequest(InputMessage mb,
OpenSecureChannelRequest req)
handleRenewSecureChannelRequest.
|
protected void |
OpcTcpServerConnection.handleSecureMessage(InputMessage mb)
handleSecureMessage.
|
protected void |
OpcTcpServerSecureChannel.handleSecureMessage(InputMessage mb,
IEncodeable msg)
handleSecureMessage.
|
protected void |
OpcTcpServerConnection.handleSymmChunk(ByteBuffer chunk)
handleSymmChunk.
|
protected void |
OpcTcpServerConnection.sendAcknowledge(Acknowledge a)
sendAcknowledge.
|
protected int |
OpcTcpServerConnection.sendAsymmSecureMessage(AsyncWrite msg,
SecurityConfiguration securityConfiguration,
int secureChannelId,
int requestNumber,
AtomicInteger sendSequenceNumber)
sendAsymmSecureMessage.
|
protected abstract int |
AbstractServerConnection.sendAsymmSecureMessage(AsyncWrite msg,
SecurityConfiguration securityConfiguration,
int secureChannelId,
int requestNumber,
AtomicInteger sendSequenceNumber)
sendAsymmSecureMessage.
|
protected void |
OpcTcpServerConnection.sendError(ErrorMessage e)
sendError.
|
void |
OpcTcpServer.setReceiveBufferSize(int receiveBufferSize)
Define the receiveBufferSize to use for the connection socket of the server.
|
protected OpcTcpServerSecureChannel |
OpcTcpServerConnection.validateSecureChannelId(int reqSecureChannelId)
Throws Bad_SecureChannelIdInvalid if the securechannel is null or doesn't have the given id.
|
| Constructor and Description |
|---|
OpcTcpServer(Application application)
Constructor for OpcTcpServer.
|
| Modifier and Type | Method and Description |
|---|---|
static ServiceResultException |
StackUtils.toServiceResultException(Exception e)
toServiceResultException.
|
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
CryptoUtil.asymmEncrypt(byte[] input,
Key key,
SecurityAlgorithm algorithm)
Deprecated.
|
static UserIdentityToken |
EndpointUtil.createAnonymousIdentityToken(EndpointDescription ep)
Create anonymous user identity token
|
static UserIdentityToken |
EndpointUtil.createIssuedIdentityToken(EndpointDescription ep,
ByteString senderNonce,
byte[] issuedIdentityToken)
Create user identity token based on an issued token.
|
static Mac |
CryptoUtil.createMac(SecurityAlgorithm algorithm,
byte[] secret)
Create Message Authentication Code (MAC).
|
static ByteString |
CryptoUtil.createNonce(SecurityAlgorithm algorithm)
Deprecated.
use
CryptoUtil.createNonce(int) and get the size from
SecurityPolicy.getSecureChannelNonceLength() directly |
static UserIdentityToken |
EndpointUtil.createUserNameIdentityToken(EndpointDescription ep,
ByteString senderNonce,
String username,
String password)
Create user identity token based on username and password
|
static X509IdentityToken |
EndpointUtil.createX509IdentityToken(EndpointDescription ep,
ByteString serverNonce,
Cert certificate,
PrivateKey key,
SignatureData signatureData)
createX509IdentityToken.
|
static void |
CryptoUtil.decryptAsymm(PrivateKey decryptingKey,
SecurityConfiguration profile,
byte[] dataToDecrypt,
byte[] output,
int outputOffset)
Convenience method for
CryptoProvider.decryptAsymm(PrivateKey, SecurityAlgorithm, byte[], byte[], int)
Possible to use only SecurityConfiguration instead of specifying SecurityAlgorithm explicitly. |
static byte[] |
CryptoUtil.encryptAsymm(byte[] input,
PublicKey key,
SecurityAlgorithm algorithm)
|
static void |
CryptoUtil.encryptAsymm(Certificate encryptingCertificate,
SecurityConfiguration profile,
byte[] dataToEncrypt,
byte[] output,
int outputOffset)
Convenience method for
CryptoProvider.encryptAsymm(PublicKey, SecurityAlgorithm, byte[], byte[], int) Possible
to use only Certificate and SecurityConfiguration instead of specifying PublicKey and
SecurityAlgorithm explicitly. |
static Cipher |
CryptoUtil.getAsymmetricCipher(SecurityAlgorithm algorithm)
Create signer instance using an algorithm uri.
|
static int |
CryptoUtil.getAsymmInputBlockSize(SecurityAlgorithm algorithm)
getAsymmInputBlockSize.
|
static int |
CryptoUtil.getCipherBlockSize(SecurityAlgorithm algorithm,
Key key)
Get cipher block (=output) size in bytes.
|
static int |
CryptoUtil.getNonceLength(SecurityAlgorithm algorithm)
Deprecated.
use
SecurityPolicy.getSecureChannelNonceLength() directly instead |
static int |
CryptoUtil.getPlainTextBlockSize(SecurityAlgorithm securityAlgorithm,
Key key)
Get plain text block (=input) size in bytes.
|
static int |
CryptoUtil.getSignatureSize(SecurityAlgorithm signatureAlgorithm,
Key key)
Get signature size in bytes.
|
static NumericRange |
NumericRange.parse(String textToParse)
Parses a string representing a numeric range.
|
static EndpointDescription |
EndpointUtil.select(EndpointDescription[] endpoints)
Select an endpoint that is supported by the stack and has the highest security level.
|
static EndpointDescription |
EndpointUtil.select(EndpointDescription[] endpoints,
String url)
select.
|
static SignatureData |
CryptoUtil.signAsymm(PrivateKey signerKey,
SecurityAlgorithm algorithm,
byte[] dataToSign)
signAsymm.
|
static boolean |
CryptoUtil.verifyAsymm(X509Certificate certificate,
SecurityAlgorithm algorithm,
byte[] data,
byte[] signature)
Verify a signature.
|
Copyright © 2026. All rights reserved.