org.joyqueue.client.internal.consumer.converter

类 MessageConvertSupport

java.lang.Object

org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

public class MessageConvertSupport
extends Object

MessageConvertSupport author: gaohaoxiang date: 2019/4/3

字段概要

字段

限定符和类型	字段和说明
protected org.slf4j.Logger	logger

构造器概要

构造器

构造器和说明
MessageConvertSupport()

方法概要

限定符和类型	方法和说明
org.joyqueue.message.BrokerMessage	convert(org.joyqueue.message.BrokerMessage message)
List<org.joyqueue.message.BrokerMessage>	convert(List<org.joyqueue.message.BrokerMessage> messages)
List<org.joyqueue.message.BrokerMessage>	convertBatch(org.joyqueue.message.BrokerMessage message)
protected Map<Byte,MessageConverter>	loadConverters()

从类继承的方法 java.lang.Object

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

字段详细资料

logger

protected final org.slf4j.Logger logger

构造器详细资料

MessageConvertSupport

public MessageConvertSupport()

方法详细资料

loadConverters

protected Map<Byte,MessageConverter> loadConverters()

convert

public List<org.joyqueue.message.BrokerMessage> convert(List<org.joyqueue.message.BrokerMessage> messages)

convert

public org.joyqueue.message.BrokerMessage convert(org.joyqueue.message.BrokerMessage message)

convertBatch

public List<org.joyqueue.message.BrokerMessage> convertBatch(org.joyqueue.message.BrokerMessage message)