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

Class AmqpRawFmt

java.lang.Object

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

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

All Implemented Interfaces:

Strategy

public class AmqpRawFmt
extends AbstractAmqpStrategy

A write strategy that expects the AMQP message to be contained in the Kafka value byte stream.

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
AmqpRawFmt(org.apache.qpid.protonj2.client.Sender sender, ErrantRecordHandler errantRecordHandler)	Constructs the 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

AmqpRawFmt

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

Constructs the strategy.

Parameters:

sender - the sender to use to send AMQP messages.

errantRecordHandler - the handler for sink records with errors.