Package org.springframework.pulsar.support.converter

Class PulsarBatchMessagingMessageConverter<T>

java.lang.Object

org.springframework.pulsar.support.converter.PulsarBatchMessagingMessageConverter<T>

Type Parameters:

T - message type.

All Implemented Interfaces:

PulsarBatchMessageConverter<T>, MessageConverter

public class PulsarBatchMessagingMessageConverter<T>
extends Object
implements PulsarBatchMessageConverter<T>

Batch records message converter.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
PulsarBatchMessagingMessageConverter()
PulsarBatchMessagingMessageConverter(PulsarRecordMessageConverter<T> recordConverter)

Method Summary

Modifier and Type	Method	Description
protected Object	convert(org.apache.pulsar.client.api.Message<T> record, Type type, List<Exception> conversionFailures)
protected Object	extractAndConvertValue(org.apache.pulsar.client.api.Message<T> record, Type type)
T	fromMessage(org.apache.pulsar.client.api.Messages<T> message, String defaultTopic)
Message<?>	toMessage(List<org.apache.pulsar.client.api.Message<T>> records, org.apache.pulsar.client.api.Consumer<T> consumer, Type type)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.pulsar.support.converter.PulsarBatchMessageConverter

getRecordMessageConverter

Constructor Details

PulsarBatchMessagingMessageConverter

public PulsarBatchMessagingMessageConverter()

PulsarBatchMessagingMessageConverter

public PulsarBatchMessagingMessageConverter(PulsarRecordMessageConverter<T> recordConverter)

Method Details

toMessage

public Message<?> toMessage(List<org.apache.pulsar.client.api.Message<T>> records,
 org.apache.pulsar.client.api.Consumer<T> consumer,
 Type type)

Specified by:

toMessage in interface PulsarBatchMessageConverter<T>

extractAndConvertValue

protected Object extractAndConvertValue(org.apache.pulsar.client.api.Message<T> record,
 Type type)

convert

protected Object convert(org.apache.pulsar.client.api.Message<T> record,
 Type type,
 List<Exception> conversionFailures)

fromMessage

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

Specified by:

fromMessage in interface PulsarBatchMessageConverter<T>