Package org.springframework.pulsar.support.converter

Interface PulsarBatchMessageConverter<T>

Type Parameters:

T - message type.

All Superinterfaces:

MessageConverter

All Known Implementing Classes:

PulsarBatchMessagingMessageConverter

public interface PulsarBatchMessageConverter<T>
extends MessageConverter

Pulsar batch message converter strategy.

Author:

Soby Chacko

Method Summary

Modifier and Type	Method	Description
T	fromMessage(org.apache.pulsar.client.api.Messages<T> message, String defaultTopic)
default PulsarRecordMessageConverter<T>	getRecordMessageConverter()
Message<?>	toMessage(List<org.apache.pulsar.client.api.Message<T>> msg, org.apache.pulsar.client.api.Consumer<T> consumer, Type payloadType)

Method Details

toMessage

Message<?> toMessage(List<org.apache.pulsar.client.api.Message<T>> msg,
 org.apache.pulsar.client.api.Consumer<T> consumer,
 Type payloadType)

fromMessage

T fromMessage(org.apache.pulsar.client.api.Messages<T> message,
 String defaultTopic)

getRecordMessageConverter

default PulsarRecordMessageConverter<T> getRecordMessageConverter()