bulk-cdk-core-load/io.airbyte.cdk.load.message/ProtocolMessageDeserializer

ProtocolMessageDeserializer

@Singleton

class ProtocolMessageDeserializer(destinationMessageFactory: DestinationMessageFactory)

Converts the internal @AirbyteMessage to the internal @DestinationMessage Ideally, this would not use protocol messages at all, but rather a specialized deserializer for routing.

Constructors

constructor(destinationMessageFactory: DestinationMessageFactory)

Functions

deserialize

fun deserialize(serialized: String): DestinationMessage