Class PubSubMessage
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.cloud.pubsublite.proto.PubSubMessage
-
- All Implemented Interfaces:
PubSubMessageOrBuilder,com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable
public final class PubSubMessage extends com.google.protobuf.GeneratedMessageV3 implements PubSubMessageOrBuilder
A message that is published by publishers and delivered to subscribers.
Protobuf typegoogle.cloud.pubsublite.v1.PubSubMessage- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classPubSubMessage.BuilderA message that is published by publishers and delivered to subscribers.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intATTRIBUTES_FIELD_NUMBERstatic intDATA_FIELD_NUMBERstatic intEVENT_TIME_FIELD_NUMBERstatic intKEY_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description booleancontainsAttributes(String key)Optional attributes that can be used for message metadata/headers.booleanequals(Object obj)Map<String,AttributeValues>getAttributes()Deprecated.intgetAttributesCount()Optional attributes that can be used for message metadata/headers.Map<String,AttributeValues>getAttributesMap()Optional attributes that can be used for message metadata/headers.AttributeValuesgetAttributesOrDefault(String key, AttributeValues defaultValue)Optional attributes that can be used for message metadata/headers.AttributeValuesgetAttributesOrThrow(String key)Optional attributes that can be used for message metadata/headers.com.google.protobuf.ByteStringgetData()The payload of the message.static PubSubMessagegetDefaultInstance()PubSubMessagegetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.TimestampgetEventTime()An optional, user-specified event time.com.google.protobuf.TimestampOrBuildergetEventTimeOrBuilder()An optional, user-specified event time.com.google.protobuf.ByteStringgetKey()The key used for routing messages to partitions or for compaction (e.g., keep the last N messages per key).com.google.protobuf.Parser<PubSubMessage>getParserForType()intgetSerializedSize()booleanhasEventTime()An optional, user-specified event time.inthashCode()protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()protected com.google.protobuf.MapFieldinternalGetMapField(int number)booleanisInitialized()static PubSubMessage.BuildernewBuilder()static PubSubMessage.BuildernewBuilder(PubSubMessage prototype)PubSubMessage.BuildernewBuilderForType()protected PubSubMessage.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static PubSubMessageparseDelimitedFrom(InputStream input)static PubSubMessageparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessageparseFrom(byte[] data)static PubSubMessageparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessageparseFrom(com.google.protobuf.ByteString data)static PubSubMessageparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessageparseFrom(com.google.protobuf.CodedInputStream input)static PubSubMessageparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessageparseFrom(InputStream input)static PubSubMessageparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessageparseFrom(ByteBuffer data)static PubSubMessageparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<PubSubMessage>parser()PubSubMessage.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
KEY_FIELD_NUMBER
public static final int KEY_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DATA_FIELD_NUMBER
public static final int DATA_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ATTRIBUTES_FIELD_NUMBER
public static final int ATTRIBUTES_FIELD_NUMBER
- See Also:
- Constant Field Values
-
EVENT_TIME_FIELD_NUMBER
public static final int EVENT_TIME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetMapField
protected com.google.protobuf.MapField internalGetMapField(int number)
- Overrides:
internalGetMapFieldin classcom.google.protobuf.GeneratedMessageV3
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3
-
getKey
public com.google.protobuf.ByteString getKey()
The key used for routing messages to partitions or for compaction (e.g., keep the last N messages per key). If the key is empty, the message is routed to an arbitrary partition.
bytes key = 1;- Specified by:
getKeyin interfacePubSubMessageOrBuilder- Returns:
- The key.
-
getData
public com.google.protobuf.ByteString getData()
The payload of the message.
bytes data = 2;- Specified by:
getDatain interfacePubSubMessageOrBuilder- Returns:
- The data.
-
getAttributesCount
public int getAttributesCount()
Description copied from interface:PubSubMessageOrBuilderOptional attributes that can be used for message metadata/headers.
map<string, .google.cloud.pubsublite.v1.AttributeValues> attributes = 3;- Specified by:
getAttributesCountin interfacePubSubMessageOrBuilder
-
containsAttributes
public boolean containsAttributes(String key)
Optional attributes that can be used for message metadata/headers.
map<string, .google.cloud.pubsublite.v1.AttributeValues> attributes = 3;- Specified by:
containsAttributesin interfacePubSubMessageOrBuilder
-
getAttributes
@Deprecated public Map<String,AttributeValues> getAttributes()
Deprecated.UsegetAttributesMap()instead.- Specified by:
getAttributesin interfacePubSubMessageOrBuilder
-
getAttributesMap
public Map<String,AttributeValues> getAttributesMap()
Optional attributes that can be used for message metadata/headers.
map<string, .google.cloud.pubsublite.v1.AttributeValues> attributes = 3;- Specified by:
getAttributesMapin interfacePubSubMessageOrBuilder
-
getAttributesOrDefault
public AttributeValues getAttributesOrDefault(String key, AttributeValues defaultValue)
Optional attributes that can be used for message metadata/headers.
map<string, .google.cloud.pubsublite.v1.AttributeValues> attributes = 3;- Specified by:
getAttributesOrDefaultin interfacePubSubMessageOrBuilder
-
getAttributesOrThrow
public AttributeValues getAttributesOrThrow(String key)
Optional attributes that can be used for message metadata/headers.
map<string, .google.cloud.pubsublite.v1.AttributeValues> attributes = 3;- Specified by:
getAttributesOrThrowin interfacePubSubMessageOrBuilder
-
hasEventTime
public boolean hasEventTime()
An optional, user-specified event time.
.google.protobuf.Timestamp event_time = 4;- Specified by:
hasEventTimein interfacePubSubMessageOrBuilder- Returns:
- Whether the eventTime field is set.
-
getEventTime
public com.google.protobuf.Timestamp getEventTime()
An optional, user-specified event time.
.google.protobuf.Timestamp event_time = 4;- Specified by:
getEventTimein interfacePubSubMessageOrBuilder- Returns:
- The eventTime.
-
getEventTimeOrBuilder
public com.google.protobuf.TimestampOrBuilder getEventTimeOrBuilder()
An optional, user-specified event time.
.google.protobuf.Timestamp event_time = 4;- Specified by:
getEventTimeOrBuilderin interfacePubSubMessageOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static PubSubMessage parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static PubSubMessage parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static PubSubMessage parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static PubSubMessage parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static PubSubMessage parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static PubSubMessage parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static PubSubMessage parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static PubSubMessage parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static PubSubMessage parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static PubSubMessage parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static PubSubMessage parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static PubSubMessage parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public PubSubMessage.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static PubSubMessage.Builder newBuilder()
-
newBuilder
public static PubSubMessage.Builder newBuilder(PubSubMessage prototype)
-
toBuilder
public PubSubMessage.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected PubSubMessage.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static PubSubMessage getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<PubSubMessage> parser()
-
getParserForType
public com.google.protobuf.Parser<PubSubMessage> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public PubSubMessage getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-