Package io.aiven.kafka.connect.amqp.sink.strategy

Class AmqpBodyFmt

java.lang.Object

io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

io.aiven.kafka.connect.amqp.sink.strategy.AmqpBodyFmt

All Implemented Interfaces:

Strategy

public class AmqpBodyFmt
extends AbstractAmqpStrategy

Standard AMQP message strategy. This message assumes that:

• The Kafka message value is the same as the AMQP message body. Different encoding, same data.
• The Kafka headers contains entries that start with "amqp" that are to be used to populate the AMQP message properties, footers, and attributes.

Nested Class Summary

Nested classes/interfaces inherited from class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

AbstractAmqpStrategy.TrackerSinkRecord

Field Summary

Fields inherited from class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

encoderDecoder, errantRecordHandler, sender

Constructor Summary

Constructors

Constructor	Description
AmqpBodyFmt(org.apache.qpid.protonj2.client.Sender sender, ErrantRecordHandler errantRecordHandler)	Constructs a body format strategy.

Method Summary

Methods inherited from class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

flush, preCommit, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.aiven.kafka.connect.amqp.sink.strategy.Strategy

write

Constructor Details

AmqpBodyFmt

public AmqpBodyFmt(org.apache.qpid.protonj2.client.Sender sender,
 ErrantRecordHandler errantRecordHandler)

Constructs a body format strategy.

Parameters:

sender - the sender to send the AMQP messages with.

errantRecordHandler - the handler for bad records.