public class BrokerMessageConverter extends Object
| 构造器和说明 |
|---|
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) |
public static com.google.common.collect.Table<String,Short,FetchMessageData> convert(String app, com.google.common.collect.Table<String,Short,FetchPartitionMessageAckData> topicMessageTable)
public static Map<String,FetchMessageData> convert(String app, Map<String,FetchTopicMessageAckData> topicMessageMap)
public static List<ConsumeMessage> convert(String topic, String app, List<org.joyqueue.message.BrokerMessage> brokerMessages)
public static List<org.joyqueue.message.BrokerMessage> convertBatch(String topic, String app, org.joyqueue.message.BrokerMessage batchBrokerMessage)
public static ConsumeMessage convert(String topic, String app, org.joyqueue.message.BrokerMessage brokerMessage)
Copyright © 2020 Joyqueue Community. All rights reserved.