序列化表格

程序包 io.openmessaging.joyqueue.producer.message

类io.openmessaging.joyqueue.producer.message.OMSProduceMessage扩展ProduceMessage实现可序列化

序列化字段

omsMessage

io.openmessaging.message.Message omsMessage

程序包 org.joyqueue.client.internal.cluster.exception

类org.joyqueue.client.internal.cluster.exception.ClusterException扩展ClientException实现可序列化

程序包 org.joyqueue.client.internal.consumer.domain

类org.joyqueue.client.internal.consumer.domain.ConsumeMessage扩展Object实现可序列化

序列化字段

topic

org.joyqueue.domain.TopicName topic

app

String app

partition

short partition

index

long index

txId

String txId

businessId

String businessId

body

String body

bodyBytes

byte[] bodyBytes

flag

short flag

priority

byte priority

startTime

long startTime

source

byte source

attributes

Map<K,V> attributes

程序包 org.joyqueue.client.internal.consumer.exception

类org.joyqueue.client.internal.consumer.exception.ConsumerException扩展ClientException实现可序列化

类org.joyqueue.client.internal.consumer.exception.IgnoreAckException扩展ClientException实现可序列化

程序包 org.joyqueue.client.internal.exception

类org.joyqueue.client.internal.exception.ClientException扩展RuntimeException实现可序列化

序列化字段

code

int code

类org.joyqueue.client.internal.exception.SecurityException扩展RuntimeException实现可序列化

序列化字段

code

int code

程序包 org.joyqueue.client.internal.metadata.domain

类org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata扩展Object实现可序列化

序列化字段

id

int id

leader

BrokerNode leader

partitions

Map<K,V> partitions

类org.joyqueue.client.internal.metadata.domain.PartitionMetadata扩展Object实现可序列化

序列化字段

id

short id

partitionGroupId

int partitionGroupId

topic

String topic

leader

BrokerNode leader

类org.joyqueue.client.internal.metadata.domain.TopicMetadata扩展Object实现可序列化

序列化字段

topic

String topic

producerPolicy

org.joyqueue.domain.ProducerPolicy producerPolicy

consumerPolicy

org.joyqueue.domain.ConsumerPolicy consumerPolicy

type

org.joyqueue.domain.TopicType type

code

org.joyqueue.exception.JoyQueueCode code

partitionGroups

List<E> partitionGroups

partitions

List<E> partitions

partitionMap

Map<K,V> partitionMap

partitionGroupMap

Map<K,V> partitionGroupMap

brokers

List<E> brokers

nearbyBrokers

List<E> nearbyBrokers

brokerMap

Map<K,V> brokerMap

brokerPartitions

Map<K,V> brokerPartitions

brokerPartitionGroups

Map<K,V> brokerPartitionGroups

allAvailable

boolean allAvailable

unmodifiableTopicMetadata

TopicMetadata unmodifiableTopicMetadata

已过时。

类org.joyqueue.client.internal.metadata.domain.UnmodifiableTopicMetadata扩展TopicMetadata实现可序列化

程序包 org.joyqueue.client.internal.metadata.exception

类org.joyqueue.client.internal.metadata.exception.MetadataException扩展ClientException实现可序列化

程序包 org.joyqueue.client.internal.producer.domain

类org.joyqueue.client.internal.producer.domain.ProduceMessage扩展Object实现可序列化

序列化字段

topic

String topic

body

String body

bodyBytes

byte[] bodyBytes

partition

short partition

partitionKey

String partitionKey

businessId

String businessId

priority

byte priority

flag

short flag

attributes

Map<K,V> attributes

类org.joyqueue.client.internal.producer.domain.ProduceResult扩展Object实现可序列化

序列化字段

topic

String topic

partition

short partition

index

long index

startTime

long startTime

类org.joyqueue.client.internal.producer.domain.SendPrepareResult扩展Object实现可序列化

序列化字段

txId

String txId

code

org.joyqueue.exception.JoyQueueCode code

类org.joyqueue.client.internal.producer.domain.SendResult扩展Object实现可序列化

序列化字段

topic

String topic

partition

short partition

index

long index

startTime

long startTime

程序包 org.joyqueue.client.internal.producer.exception

类org.joyqueue.client.internal.producer.exception.NeedRetryException扩展ProducerException实现可序列化

类org.joyqueue.client.internal.producer.exception.ProducerException扩展ClientException实现可序列化