Uses of Class
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData

Packages that use PulsarApi.MessageIdData

Package	Description
org.apache.pulsar.common.api
org.apache.pulsar.common.api.proto

Uses of PulsarApi.MessageIdData in org.apache.pulsar.common.api

Methods in org.apache.pulsar.common.api with parameters of type PulsarApi.MessageIdData

Modifier and Type	Method and Description
static io.netty.buffer.ByteBuf	Commands.newGetLastMessageIdResponse(long requestId, PulsarApi.MessageIdData messageIdData)
static ByteBufPair	Commands.newMessage(long consumerId, PulsarApi.MessageIdData messageId, int redeliveryCount, io.netty.buffer.ByteBuf metadataAndPayload)
static io.netty.buffer.ByteBuf	Commands.newSubscribe(String topic, String subscription, long consumerId, long requestId, PulsarApi.CommandSubscribe.SubType subType, int priorityLevel, String consumerName, boolean isDurable, PulsarApi.MessageIdData startMessageId, Map<String,String> metadata, boolean readCompacted, PulsarApi.CommandSubscribe.InitialPosition subscriptionInitialPosition, SchemaInfo schemaInfo)

Method parameters in org.apache.pulsar.common.api with type arguments of type PulsarApi.MessageIdData

Modifier and Type	Method and Description
static io.netty.buffer.ByteBuf	Commands.newRedeliverUnacknowledgedMessages(long consumerId, List<PulsarApi.MessageIdData> messageIds)

Uses of PulsarApi.MessageIdData in org.apache.pulsar.common.api.proto

Methods in org.apache.pulsar.common.api.proto that return PulsarApi.MessageIdData

Modifier and Type	Method and Description
PulsarApi.MessageIdData	PulsarApi.MessageIdData.Builder.build()
PulsarApi.MessageIdData	PulsarApi.MessageIdData.Builder.buildPartial()
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.getDefaultInstance()
PulsarApi.MessageIdData	PulsarApi.MessageIdData.getDefaultInstanceForType()
PulsarApi.MessageIdData	PulsarApi.MessageIdData.Builder.getDefaultInstanceForType()
PulsarApi.MessageIdData	PulsarApi.CommandGetLastMessageIdResponseOrBuilder.getLastMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandGetLastMessageIdResponse.getLastMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandGetLastMessageIdResponse.Builder.getLastMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSendReceiptOrBuilder.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSendReceipt.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSendReceipt.Builder.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandMessageOrBuilder.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandMessage.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandMessage.Builder.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSeekOrBuilder.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSeek.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSeek.Builder.getMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandAckOrBuilder.getMessageId(int index)
PulsarApi.MessageIdData	PulsarApi.CommandAck.getMessageId(int index)
PulsarApi.MessageIdData	PulsarApi.CommandAck.Builder.getMessageId(int index)
PulsarApi.MessageIdData	PulsarApi.CommandRedeliverUnacknowledgedMessagesOrBuilder.getMessageIds(int index)
PulsarApi.MessageIdData	PulsarApi.CommandRedeliverUnacknowledgedMessages.getMessageIds(int index)
PulsarApi.MessageIdData	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.getMessageIds(int index)
PulsarApi.MessageIdData	PulsarApi.CommandSubscribeOrBuilder.getStartMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSubscribe.getStartMessageId()
PulsarApi.MessageIdData	PulsarApi.CommandSubscribe.Builder.getStartMessageId()
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseDelimitedFrom(InputStream input)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseDelimitedFrom(InputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(byte[] data)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(byte[] data, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(InputStream input)
static PulsarApi.MessageIdData	PulsarApi.MessageIdData.parseFrom(InputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)

Methods in org.apache.pulsar.common.api.proto that return types with arguments of type PulsarApi.MessageIdData

Modifier and Type	Method and Description
List<PulsarApi.MessageIdData>	PulsarApi.CommandAckOrBuilder.getMessageIdList()
List<PulsarApi.MessageIdData>	PulsarApi.CommandAck.getMessageIdList()
List<PulsarApi.MessageIdData>	PulsarApi.CommandAck.Builder.getMessageIdList()
List<PulsarApi.MessageIdData>	PulsarApi.CommandRedeliverUnacknowledgedMessagesOrBuilder.getMessageIdsList()
List<PulsarApi.MessageIdData>	PulsarApi.CommandRedeliverUnacknowledgedMessages.getMessageIdsList()
List<PulsarApi.MessageIdData>	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.getMessageIdsList()

Methods in org.apache.pulsar.common.api.proto with parameters of type PulsarApi.MessageIdData

Modifier and Type	Method and Description
PulsarApi.CommandAck.Builder	PulsarApi.CommandAck.Builder.addMessageId(int index, PulsarApi.MessageIdData value)
PulsarApi.CommandAck.Builder	PulsarApi.CommandAck.Builder.addMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.addMessageIds(int index, PulsarApi.MessageIdData value)
PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.addMessageIds(PulsarApi.MessageIdData value)
PulsarApi.MessageIdData.Builder	PulsarApi.MessageIdData.Builder.mergeFrom(PulsarApi.MessageIdData other)
PulsarApi.CommandGetLastMessageIdResponse.Builder	PulsarApi.CommandGetLastMessageIdResponse.Builder.mergeLastMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandSendReceipt.Builder	PulsarApi.CommandSendReceipt.Builder.mergeMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandMessage.Builder	PulsarApi.CommandMessage.Builder.mergeMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandSeek.Builder	PulsarApi.CommandSeek.Builder.mergeMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandSubscribe.Builder	PulsarApi.CommandSubscribe.Builder.mergeStartMessageId(PulsarApi.MessageIdData value)
static PulsarApi.MessageIdData.Builder	PulsarApi.MessageIdData.newBuilder(PulsarApi.MessageIdData prototype)
PulsarApi.CommandGetLastMessageIdResponse.Builder	PulsarApi.CommandGetLastMessageIdResponse.Builder.setLastMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandAck.Builder	PulsarApi.CommandAck.Builder.setMessageId(int index, PulsarApi.MessageIdData value)
PulsarApi.CommandSendReceipt.Builder	PulsarApi.CommandSendReceipt.Builder.setMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandMessage.Builder	PulsarApi.CommandMessage.Builder.setMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandSeek.Builder	PulsarApi.CommandSeek.Builder.setMessageId(PulsarApi.MessageIdData value)
PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.setMessageIds(int index, PulsarApi.MessageIdData value)
PulsarApi.CommandSubscribe.Builder	PulsarApi.CommandSubscribe.Builder.setStartMessageId(PulsarApi.MessageIdData value)

Method parameters in org.apache.pulsar.common.api.proto with type arguments of type PulsarApi.MessageIdData

Modifier and Type	Method and Description
PulsarApi.CommandAck.Builder	PulsarApi.CommandAck.Builder.addAllMessageId(Iterable<? extends PulsarApi.MessageIdData> values)
PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.addAllMessageIds(Iterable<? extends PulsarApi.MessageIdData> values)