com.prosysopc.ua.stack.transport.tcp.nio

Class OpcTcpServerSecureChannel

java.lang.Object

com.prosysopc.ua.stack.utils.AbstractState<CloseableObjectState,ServiceResultException>

com.prosysopc.ua.stack.transport.endpoint.AbstractServerSecureChannel

com.prosysopc.ua.stack.transport.tcp.nio.OpcTcpServerSecureChannel

All Implemented Interfaces:

ServerSecureChannel, IStatefulObject<CloseableObjectState,ServiceResultException>

public class OpcTcpServerSecureChannel
extends AbstractServerSecureChannel

OpcTcpServerSecureChannel class.

Field Summary

Fields

Modifier and Type	Field and Description
AtomicInteger	recvSequenceNumber Sequence number counter of inbound messages.
SecurityConfiguration	securityConfiguration Security profile for this security channel.
AtomicInteger	sendSequenceNumber Sequence number counter of outbound messages.

Fields inherited from class com.prosysopc.ua.stack.transport.endpoint.AbstractServerSecureChannel

activeToken, tokens

Constructor Summary

Constructors

Constructor and Description
OpcTcpServerSecureChannel(OpcTcpServerConnection connection, int secureChannelId) Constructor for OpcTcpServerSecureChannel.

Method Summary

Modifier and Type	Method and Description
void	dispose() Close and dispose.
OpcTcpServerConnection	getConnection() Get current socket connection if applicable for the binding type.
String	getConnectURL() Return the URL of the connection.
Endpoint	getEndpoint() Get endpoint
KeyPair	getLocalCertificate() getLocalCertificate.
protected Collection<PendingRequest>	getPendingRequests2() getPendingRequests2.
void	getPendingServiceRequests(Collection<EndpointServiceRequest<?,?>> result) Get all unanswered service requests.
Cert	getRemoteCertificate() getRemoteCertificate.
Server	getServer() getServer.
protected void	handleCloseSecureChannelRequest(InputMessage mb, CloseSecureChannelRequest req) handleCloseSecureChannelRequest.
protected void	handleOpenChannel(InputMessage mb, OpenSecureChannelRequest req) handleOpenChannel.
protected void	handleRenewSecureChannelRequest(InputMessage mb, OpenSecureChannelRequest req) handleRenewSecureChannelRequest.
protected void	handleSecureMessage(InputMessage mb, IEncodeable msg) handleSecureMessage.
boolean	needsCertificate()
protected void	onStateTransition(CloseableObjectState oldState, CloseableObjectState newState) Override this.

Methods inherited from class com.prosysopc.ua.stack.transport.endpoint.AbstractServerSecureChannel

close, closeAsync, getActiveSecurityToken, getLatestNonExpiredToken, getMessageSecurityMode, getRemoteAddress, getSecureChannelId, getSecurityPolicy, getSecurityToken, isOpen, onListenerException, setActiveSecurityToken, setError, toString

Methods inherited from class com.prosysopc.ua.stack.utils.AbstractState

addStateListener, addStateNotifiable, attemptSetState, clearError, getError, getState, hasError, isStateTransitionAllowed, removeStateListener, removeStateNotifiable, setState, setState, throwIfError, waitForState, waitForState, waitForStateUninterruptibly

Methods inherited from class java.lang.Object

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

Field Detail

securityConfiguration

public SecurityConfiguration securityConfiguration

Security profile for this security channel.

sendSequenceNumber

public final AtomicInteger sendSequenceNumber

Sequence number counter of outbound messages.

recvSequenceNumber

public final AtomicInteger recvSequenceNumber

Sequence number counter of inbound messages.

Constructor Detail

OpcTcpServerSecureChannel

public OpcTcpServerSecureChannel(OpcTcpServerConnection connection,
                                 int secureChannelId)

Constructor for OpcTcpServerSecureChannel.

Parameters:

connection - a OpcTcpServerConnection object.

secureChannelId - a int.

Method Detail

dispose

public void dispose()

Description copied from interface: ServerSecureChannel

Close and dispose. The object becomes unusuable.

getConnection

public OpcTcpServerConnection getConnection()

Description copied from interface: ServerSecureChannel

Get current socket connection if applicable for the binding type.

Returns:

connection or null

getConnectURL

public String getConnectURL()

Description copied from interface: ServerSecureChannel

Return the URL of the connection. This value is only available when the channel is in Open or Closing state, if not the return value is null.

Returns:

connect URL or null

getEndpoint

public Endpoint getEndpoint()

Description copied from interface: ServerSecureChannel

Get endpoint

Returns:

Endpoint

getLocalCertificate

public KeyPair getLocalCertificate()

getLocalCertificate.

Returns:

a KeyPair object.

getPendingServiceRequests

public void getPendingServiceRequests(Collection<EndpointServiceRequest<?,?>> result)

Description copied from interface: ServerSecureChannel

Get all unanswered service requests.

Parameters:

result - container to fill with unanswered service requests

getRemoteCertificate

public Cert getRemoteCertificate()

getRemoteCertificate.

Returns:

a Cert object.

getServer

public Server getServer()

getServer.

Returns:

a Server object.

needsCertificate

public boolean needsCertificate()

getPendingRequests2

protected Collection<PendingRequest> getPendingRequests2()

getPendingRequests2.

Returns:

a Collection object.

handleCloseSecureChannelRequest

protected void handleCloseSecureChannelRequest(InputMessage mb,
                                               CloseSecureChannelRequest req)

handleCloseSecureChannelRequest.

Parameters:

mb - a InputMessage object.

req - a CloseSecureChannelRequest object.

handleOpenChannel

protected void handleOpenChannel(InputMessage mb,
                                 OpenSecureChannelRequest req)
                          throws ServiceResultException

handleOpenChannel.

Parameters:

mb - a InputMessage object.

req - a OpenSecureChannelRequest object.

Throws:

ServiceResultException - if any.

handleRenewSecureChannelRequest

protected void handleRenewSecureChannelRequest(InputMessage mb,
                                               OpenSecureChannelRequest req)
                                        throws ServiceResultException

handleRenewSecureChannelRequest.

Parameters:

mb - a InputMessage object.

req - a OpenSecureChannelRequest object.

Throws:

ServiceResultException - if any.

handleSecureMessage

protected void handleSecureMessage(InputMessage mb,
                                   IEncodeable msg)
                            throws ServiceResultException

handleSecureMessage.

Parameters:

mb - a InputMessage object.

msg - a IEncodeable object.

Throws:

ServiceResultException - if any.

onStateTransition

protected void onStateTransition(CloseableObjectState oldState,
                                 CloseableObjectState newState)

Description copied from class: AbstractState

Override this.

Overrides:

onStateTransition in class AbstractState<CloseableObjectState,ServiceResultException>

Parameters:

oldState - a StateType object.

newState - a StateType object.