org.joyqueue.client.internal.consumer.converter

类 BrokerMessageConverter

java.lang.Object

org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

public class BrokerMessageConverter
extends Object

BrokerMessageConverter author: gaohaoxiang date: 2018/12/7

构造器概要

构造器

构造器和说明
BrokerMessageConverter()

方法概要

限定符和类型	方法和说明
static Map<String,FetchMessageData>	convert(String app, Map<String,FetchTopicMessageAckData> topicMessageMap)
static ConsumeMessage	convert(String topic, String app, org.joyqueue.message.BrokerMessage brokerMessage)
static List<ConsumeMessage>	convert(String topic, String app, List<org.joyqueue.message.BrokerMessage> brokerMessages)
static com.google.common.collect.Table<String,Short,FetchMessageData>	convert(String app, com.google.common.collect.Table<String,Short,FetchPartitionMessageAckData> topicMessageTable)
static List<org.joyqueue.message.BrokerMessage>	convertBatch(String topic, String app, org.joyqueue.message.BrokerMessage batchBrokerMessage)

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

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

构造器详细资料

BrokerMessageConverter

public BrokerMessageConverter()

方法详细资料

convert

public static com.google.common.collect.Table<String,Short,FetchMessageData> convert(String app,
                                                                                     com.google.common.collect.Table<String,Short,FetchPartitionMessageAckData> topicMessageTable)

convert

public static Map<String,FetchMessageData> convert(String app,
                                                   Map<String,FetchTopicMessageAckData> topicMessageMap)

convert

public static List<ConsumeMessage> convert(String topic,
                                           String app,
                                           List<org.joyqueue.message.BrokerMessage> brokerMessages)

convertBatch

public static List<org.joyqueue.message.BrokerMessage> convertBatch(String topic,
                                                                    String app,
                                                                    org.joyqueue.message.BrokerMessage batchBrokerMessage)

convert

public static ConsumeMessage convert(String topic,
                                     String app,
                                     org.joyqueue.message.BrokerMessage brokerMessage)