Package io.aiven.kafka.connect.amqp.common.data

Class AmqpEnDec

java.lang.Object

io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

io.aiven.kafka.connect.amqp.common.data.AmqpEnDec

public final class AmqpEnDec
extends EncoderDecoder

Converts AMQP values.

Nested Class Summary

Nested classes/interfaces inherited from class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

EncoderDecoder.ChainedEnDec

Constructor Summary

Constructors

Constructor	Description
AmqpEnDec()	Constructor.

Method Summary

Modifier and Type	Method	Description
Optional<Object>	decode(org.apache.kafka.connect.data.SchemaAndValue schemaAndValue)	Decodes a SchemaAndValue into an object.
Optional<org.apache.kafka.connect.data.SchemaAndValue>	encode(Object value)	Encodes the value as a SchemaAndValue.

Methods inherited from class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

andThen, self, setSelf, toString

Methods inherited from class java.lang.Object

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

Constructor Details

AmqpEnDec

public AmqpEnDec()

Constructor.

Method Details

encode

public Optional<org.apache.kafka.connect.data.SchemaAndValue> encode(Object value)

Description copied from class: EncoderDecoder

Encodes the value as a SchemaAndValue. If this converter can not perform the encoding it returns an empty Optional.

Specified by:

encode in class EncoderDecoder

Parameters:

value - the value to convert.

Returns:

the Optional SchemaAndValue or an empty Optional.

decode

public Optional<Object> decode(org.apache.kafka.connect.data.SchemaAndValue schemaAndValue)

Description copied from class: EncoderDecoder

Decodes a SchemaAndValue into an object. If this converter can not perform the decoding it returns an empty Optional.

Specified by:

decode in class EncoderDecoder

Parameters:

schemaAndValue - the schema and value to decode.

Returns:

the Optional Object or an empty Optional if not decoded.