public abstract class DecryptingReader extends IntegrationProxyReader
DataEndpoint.State
Modifier and Type | Field and Description |
---|---|
protected Cipher |
cipher |
protected BinaryDeserializer |
deserializer |
protected FieldList |
fields |
fieldLineage, recordLineage
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE
id, log, name, TIMESTAMP_FORMAT
Constructor and Description |
---|
DecryptingReader(DataReader nestedDataReader) |
Modifier and Type | Method and Description |
---|---|
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException . |
DecryptingReader |
addFields(Collection<String> fieldNames) |
DecryptingReader |
addFields(String... fieldNames) |
protected void |
decryptField(Field field) |
protected abstract void |
decryptFieldImpl(Field field) |
FieldList |
getFields() |
protected abstract void |
initCipher() |
protected Record |
interceptRecord(Record record) |
void |
open()
Makes this endpoint ready for reading or writing.
|
available, close, getNestedReader, map, map, readImpl, setNestedDataReader, setNestedDataReader
addLineage, getBufferSize, getNestedEndpoint, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
protected final FieldList fields
protected BinaryDeserializer deserializer
protected Cipher cipher
public DecryptingReader(DataReader nestedDataReader)
public FieldList getFields()
public DecryptingReader addFields(Collection<String> fieldNames)
public DecryptingReader addFields(String... fieldNames)
public void open() throws DataException
DataEndpoint
open
in class IntegrationProxyReader
DataException
protected abstract void initCipher()
protected final Record interceptRecord(Record record) throws Throwable
interceptRecord
in class ProxyReader
Throwable
protected abstract void decryptFieldImpl(Field field) throws Throwable
Throwable
public DataException addExceptionProperties(DataException exception)
Endpoint
DataException
. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties
in class ProxyReader
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.