public final class MessageResponse extends GeneratedMessageV3 implements MessageResponseOrBuilder
Response containing a list of messages. Upon delivering a MessageResponse to
the client, the server:
- Updates the stream's delivery cursor to one greater than the cursor of the
last message in the list.
- Subtracts the total number of bytes and messages from the tokens available
to the server.
Protobuf type google.cloud.pubsublite.v1.MessageResponse
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
MESSAGES_FIELD_NUMBER
public static final int MESSAGES_FIELD_NUMBER
Field Value |
Type |
Description |
int |
|
Static Methods
getDefaultInstance()
public static MessageResponse getDefaultInstance()
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
newBuilder()
public static MessageResponse.Builder newBuilder()
newBuilder(MessageResponse prototype)
public static MessageResponse.Builder newBuilder(MessageResponse prototype)
public static MessageResponse parseDelimitedFrom(InputStream input)
public static MessageResponse parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
parseFrom(byte[] data)
public static MessageResponse parseFrom(byte[] data)
Parameter |
Name |
Description |
data |
byte[]
|
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static MessageResponse parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
parseFrom(ByteString data)
public static MessageResponse parseFrom(ByteString data)
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static MessageResponse parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static MessageResponse parseFrom(CodedInputStream input)
public static MessageResponse parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public static MessageResponse parseFrom(InputStream input)
public static MessageResponse parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
parseFrom(ByteBuffer data)
public static MessageResponse parseFrom(ByteBuffer data)
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static MessageResponse parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
parser()
public static Parser<MessageResponse> parser()
Methods
equals(Object obj)
public boolean equals(Object obj)
Parameter |
Name |
Description |
obj |
Object
|
Overrides
getDefaultInstanceForType()
public MessageResponse getDefaultInstanceForType()
getMessages(int index)
public SequencedMessage getMessages(int index)
Messages from the topic partition.
repeated .google.cloud.pubsublite.v1.SequencedMessage messages = 1;
Parameter |
Name |
Description |
index |
int
|
getMessagesCount()
public int getMessagesCount()
Messages from the topic partition.
repeated .google.cloud.pubsublite.v1.SequencedMessage messages = 1;
Returns |
Type |
Description |
int |
|
getMessagesList()
public List<SequencedMessage> getMessagesList()
Messages from the topic partition.
repeated .google.cloud.pubsublite.v1.SequencedMessage messages = 1;
getMessagesOrBuilder(int index)
public SequencedMessageOrBuilder getMessagesOrBuilder(int index)
Messages from the topic partition.
repeated .google.cloud.pubsublite.v1.SequencedMessage messages = 1;
Parameter |
Name |
Description |
index |
int
|
getMessagesOrBuilderList()
public List<? extends SequencedMessageOrBuilder> getMessagesOrBuilderList()
Messages from the topic partition.
repeated .google.cloud.pubsublite.v1.SequencedMessage messages = 1;
Returns |
Type |
Description |
List<? extends com.google.cloud.pubsublite.proto.SequencedMessageOrBuilder> |
|
getParserForType()
public Parser<MessageResponse> getParserForType()
Overrides
getSerializedSize()
public int getSerializedSize()
Returns |
Type |
Description |
int |
|
Overrides
hashCode()
Returns |
Type |
Description |
int |
|
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Overrides
isInitialized()
public final boolean isInitialized()
Overrides
newBuilderForType()
public MessageResponse.Builder newBuilderForType()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected MessageResponse.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Returns |
Type |
Description |
Object |
|
Overrides
toBuilder()
public MessageResponse.Builder toBuilder()
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Overrides