com.digitalpetri.opcua.stack.server.tcp

Class UaTcpStackServer

java.lang.Object

com.digitalpetri.opcua.stack.server.tcp.UaTcpStackServer

All Implemented Interfaces:

UaStackServer

public class UaTcpStackServer
extends Object
implements UaStackServer

Field Summary

Fields

Modifier and Type	Field and Description
static io.netty.util.AttributeKey<io.netty.channel.Channel>	BoundChannelKey The AttributeKey that maps to the Channel bound to a ServerSecureChannel.

Constructor Summary

Constructors

Constructor and Description
UaTcpStackServer(UaTcpStackServerConfig config)

Method Summary

Modifier and Type	Method and Description
UaTcpStackServer	addEndpoint(String endpointUri, String bindAddress, X509Certificate certificate, SecurityPolicy securityPolicy, MessageSecurityMode messageSecurity)
<T extends UaRequestMessage,U extends UaResponseMessage> void	addRequestHandler(Class<T> requestClass, ServiceRequestHandler<T,U> requestHandler)
void	closeSecureChannel(ServerSecureChannel secureChannel)
ApplicationDescription	getApplicationDescription()
CertificateManager	getCertificateManager()
CertificateValidator	getCertificateValidator()
ChannelConfig	getChannelConfig()
UaTcpStackServerConfig	getConfig()
Set<String>	getDiscoveryUrls()
EndpointDescription[]	getEndpointDescriptions()
List<Endpoint>	getEndpoints()
List<String>	getEndpointUrls()
ExecutorService	getExecutorService()
ServerSecureChannel	getSecureChannel(long channelId)
SignedSoftwareCertificate[]	getSoftwareCertificates()
List<UserTokenPolicy>	getUserTokenPolicies()
long	nextTokenId()
ServerSecureChannel	openSecureChannel()
void	receiveRequest(ServiceRequest<UaRequestMessage,UaResponseMessage> serviceRequest)
void	secureChannelIssuedOrRenewed(ServerSecureChannel secureChannel, long lifetimeMillis)
void	shutdown()
void	startup()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.digitalpetri.opcua.stack.core.application.UaStackServer

addEndpoint, addServiceSet, addServiceSet, addServiceSet, addServiceSet, addServiceSet, addServiceSet, addServiceSet, addServiceSet, addServiceSet, addServiceSet

Field Detail

BoundChannelKey

public static final io.netty.util.AttributeKey<io.netty.channel.Channel> BoundChannelKey

The AttributeKey that maps to the Channel bound to a ServerSecureChannel.

Constructor Detail

UaTcpStackServer

public UaTcpStackServer(UaTcpStackServerConfig config)

Method Detail

getConfig

public UaTcpStackServerConfig getConfig()

startup

public void startup()

Specified by:

startup in interface UaStackServer

shutdown

public void shutdown()

Specified by:

shutdown in interface UaStackServer

receiveRequest

public void receiveRequest(ServiceRequest<UaRequestMessage,UaResponseMessage> serviceRequest)

getApplicationDescription

public ApplicationDescription getApplicationDescription()

Specified by:

getApplicationDescription in interface UaStackServer

getEndpoints

public List<Endpoint> getEndpoints()

getEndpointDescriptions

public EndpointDescription[] getEndpointDescriptions()

Specified by:

getEndpointDescriptions in interface UaStackServer

getSoftwareCertificates

public SignedSoftwareCertificate[] getSoftwareCertificates()

Specified by:

getSoftwareCertificates in interface UaStackServer

getUserTokenPolicies

public List<UserTokenPolicy> getUserTokenPolicies()

Specified by:

getUserTokenPolicies in interface UaStackServer

getEndpointUrls

public List<String> getEndpointUrls()

getDiscoveryUrls

public Set<String> getDiscoveryUrls()

getCertificateManager

public CertificateManager getCertificateManager()

Specified by:

getCertificateManager in interface UaStackServer

getCertificateValidator

public CertificateValidator getCertificateValidator()

Specified by:

getCertificateValidator in interface UaStackServer

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in interface UaStackServer

getChannelConfig

public ChannelConfig getChannelConfig()

Specified by:

getChannelConfig in interface UaStackServer

nextTokenId

public long nextTokenId()

openSecureChannel

public ServerSecureChannel openSecureChannel()

Specified by:

openSecureChannel in interface UaStackServer

closeSecureChannel

public void closeSecureChannel(ServerSecureChannel secureChannel)

Specified by:

closeSecureChannel in interface UaStackServer

secureChannelIssuedOrRenewed

public void secureChannelIssuedOrRenewed(ServerSecureChannel secureChannel,
                                         long lifetimeMillis)

getSecureChannel

public ServerSecureChannel getSecureChannel(long channelId)

addRequestHandler

public <T extends UaRequestMessage,U extends UaResponseMessage> void addRequestHandler(Class<T> requestClass,
                                                                                       ServiceRequestHandler<T,U> requestHandler)

Specified by:

addRequestHandler in interface UaStackServer

addEndpoint

public UaTcpStackServer addEndpoint(String endpointUri,
                                    String bindAddress,
                                    X509Certificate certificate,
                                    SecurityPolicy securityPolicy,
                                    MessageSecurityMode messageSecurity)

Specified by:

addEndpoint in interface UaStackServer