org.joyqueue.client.internal.producer.converter

类 ProduceMessageConverter

java.lang.Object

org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

public class ProduceMessageConverter
extends Object

ProduceMessageConverter author: gaohaoxiang date: 2018/12/20

字段概要

字段

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

构造器概要

构造器

构造器和说明
ProduceMessageConverter()

方法概要

限定符和类型	方法和说明
protected static void	compress(org.joyqueue.message.BrokerMessage brokerMessage, boolean compress, int compressThreshold, String compressType)
static org.joyqueue.message.BrokerMessage	convertToBatchBrokerMessage(String topic, String app, List<ProduceMessage> produceMessages, boolean compress, int compressThreshold, String compressType)
static org.joyqueue.message.BrokerMessage	convertToBrokerMessage(String topic, String app, ProduceMessage produceMessage)
static org.joyqueue.message.BrokerMessage	convertToBrokerMessage(String topic, String app, ProduceMessage produceMessage, boolean compress, int compressThreshold, String compressType)
static List<org.joyqueue.message.BrokerMessage>	convertToBrokerMessages(String topic, String app, List<ProduceMessage> produceMessages, boolean compress, int compressThreshold, String compressType)
static List<org.joyqueue.message.BrokerMessage>	convertToBrokerMessages(String topic, String app, List<ProduceMessage> produceMessages, boolean compress, int compressThreshold, String compressType, boolean batch)
protected static byte[]	serializeBody(ProduceMessage produceMessage)

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

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

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

ProduceMessageConverter

public ProduceMessageConverter()

方法详细资料

convertToBrokerMessages

public static List<org.joyqueue.message.BrokerMessage> convertToBrokerMessages(String topic,
                                                                               String app,
                                                                               List<ProduceMessage> produceMessages,
                                                                               boolean compress,
                                                                               int compressThreshold,
                                                                               String compressType,
                                                                               boolean batch)

convertToBrokerMessages

public static List<org.joyqueue.message.BrokerMessage> convertToBrokerMessages(String topic,
                                                                               String app,
                                                                               List<ProduceMessage> produceMessages,
                                                                               boolean compress,
                                                                               int compressThreshold,
                                                                               String compressType)

convertToBrokerMessage

public static org.joyqueue.message.BrokerMessage convertToBrokerMessage(String topic,
                                                                        String app,
                                                                        ProduceMessage produceMessage,
                                                                        boolean compress,
                                                                        int compressThreshold,
                                                                        String compressType)

convertToBatchBrokerMessage

public static org.joyqueue.message.BrokerMessage convertToBatchBrokerMessage(String topic,
                                                                             String app,
                                                                             List<ProduceMessage> produceMessages,
                                                                             boolean compress,
                                                                             int compressThreshold,
                                                                             String compressType)

convertToBrokerMessage

public static org.joyqueue.message.BrokerMessage convertToBrokerMessage(String topic,
                                                                        String app,
                                                                        ProduceMessage produceMessage)

compress

protected static void compress(org.joyqueue.message.BrokerMessage brokerMessage,
                               boolean compress,
                               int compressThreshold,
                               String compressType)

serializeBody

protected static byte[] serializeBody(ProduceMessage produceMessage)