Serialized Form

Package io.aiven.kafka.connect.amqp.source.extractor

Class io.aiven.kafka.connect.amqp.source.extractor.AmqpBinarySerializer

class AmqpBinarySerializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.types.Binary> implements Serializable

Class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal128Serializer

class AmqpDecimal128Serializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.types.Decimal128> implements Serializable

Class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal32Serializer

class AmqpDecimal32Serializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.types.Decimal32> implements Serializable

Class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal64Serializer

class AmqpDecimal64Serializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.types.Decimal64> implements Serializable

Class io.aiven.kafka.connect.amqp.source.extractor.AmqpSectionSerializer

class AmqpSectionSerializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.types.messaging.Section> implements Serializable

Class io.aiven.kafka.connect.amqp.source.extractor.AmqpSymbolSerializer

class AmqpSymbolSerializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.types.Symbol> implements Serializable

Class io.aiven.kafka.connect.amqp.source.extractor.MessageSerializer

class MessageSerializer extends com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.qpid.protonj2.client.Message> implements Serializable

Serialization Methods

writeObject

private void writeObject(com.fasterxml.jackson.core.JsonGenerator jgen,
 String name,
 Object object)
                  throws IOException

Write the object if the object is not null.

Parameters:

jgen - the JSON generator.

name - the name of the map.

object - the object to write.

Throws:

IOException - on IO error.