|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.opcfoundation.ua.transport.tcp.nio.SecureInputMessageBuilder
public class SecureInputMessageBuilder
SecureInputMessageBuilder deciphers and decodes chunks into messages.
Message is decoded and chunks are deciphered and validated in background threads. Deciphering is executed in StackUtils.getNonBlockerExecutor() which has one thread for each CPU core. Decoding is executed in StackUtils.getBlockerExecutor() which creates new threads as needed.
| Nested Class Summary | |
|---|---|
static interface |
SecureInputMessageBuilder.MessageListener
|
| Constructor Summary | |
|---|---|
SecureInputMessageBuilder(Object token,
SecureInputMessageBuilder.MessageListener listener,
TcpConnectionParameters ctx,
EncoderContext encoderCtx,
AtomicInteger expectedSequenceNumber)
Create message builder. |
|
| Method Summary | |
|---|---|
void |
addChunk(ByteBuffer chunk)
addChunk. |
void |
close()
close. |
protected void |
fireComplete()
fireComplete. |
Exception |
getError()
Getter for the field error. |
IEncodeable |
getMessage()
getMessage. |
int |
getMessageType()
Getter for the field messageType. |
byte[] |
getReceiverCertificateThumbprint()
getReceiverCertificateThumbprint. |
int |
getRequestId()
Getter for the field requestId. |
int |
getSecureChannelId()
getSecureChannelId. |
String |
getSecurityPolicyUri()
Getter for the field securityPolicyUri. |
byte[] |
getSenderCertificate()
Getter for the field senderCertificate. |
List<Integer> |
getSequenceNumbers()
Return sequence number of each chunk |
Object |
getToken()
Get security token |
protected boolean |
hasError()
hasError. |
boolean |
isDone()
isDone. |
boolean |
moreChunksRequired()
moreChunksRequired. |
protected void |
setError(Exception e)
Setter for the field error. |
protected void |
setMessage(IEncodeable msg)
setMessage. |
String |
toString()
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
|---|
public SecureInputMessageBuilder(Object token,
SecureInputMessageBuilder.MessageListener listener,
TcpConnectionParameters ctx,
EncoderContext encoderCtx,
AtomicInteger expectedSequenceNumber)
token - SecurityToken (symm) or SecurityConfiguration (asymm)listener - a SecureInputMessageBuilder.MessageListener object.ctx - a TcpConnectionParameters object.expectedSequenceNumber - a AtomicInteger object.encoderCtx - a EncoderContext object.| Method Detail |
|---|
public String toString()
toString in class Object
public void addChunk(ByteBuffer chunk)
throws ServiceResultException
addChunk.
chunk - a ByteBuffer object.
ServiceResultException - if any.protected void fireComplete()
fireComplete.
protected void setError(Exception e)
Setter for the field error.
e - a Exception object.protected void setMessage(IEncodeable msg)
setMessage.
msg - a IEncodeable object.public int getRequestId()
Getter for the field requestId.
getRequestId in interface InputMessagepublic boolean isDone()
isDone.
public boolean moreChunksRequired()
moreChunksRequired.
public void close()
close.
public IEncodeable getMessage()
getMessage.
getMessage in interface InputMessageIEncodeable object.public Exception getError()
Getter for the field error.
getError in interface InputMessageException object.public int getMessageType()
Getter for the field messageType.
getMessageType in interface InputMessagepublic int getSecureChannelId()
getSecureChannelId.
getSecureChannelId in interface InputMessagepublic String getSecurityPolicyUri()
Getter for the field securityPolicyUri.
String object.public byte[] getSenderCertificate()
Getter for the field senderCertificate.
public byte[] getReceiverCertificateThumbprint()
getReceiverCertificateThumbprint.
public List<Integer> getSequenceNumbers()
getSequenceNumbers in interface InputMessagepublic Object getToken()
getToken in interface InputMessageSecurityConfiguration if async message, SecurityToken is sync messageprotected boolean hasError()
hasError.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||