Uses of Class
com.google.pubsub.v1.PubsubMessage
-
Packages that use PubsubMessage Package Description com.google.cloud.pubsub.v1 A client to Cloud Pub/Sub APIcom.google.pubsub.v1 -
-
Uses of PubsubMessage in com.google.cloud.pubsub.v1
Fields in com.google.cloud.pubsub.v1 with type parameters of type PubsubMessage Modifier and Type Field Description static com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage>
OpenCensusUtil. OPEN_CENSUS_MESSAGE_TRANSFORM
Propagates active OpenCensus trace and tag contexts from the Publisher by adding them as attributes to thePubsubMessage
.static com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage>
OpenCensusUtil. OPEN_CENSUS_MESSAGE_TRANSFORM
Propagates active OpenCensus trace and tag contexts from the Publisher by adding them as attributes to thePubsubMessage
.Methods in com.google.cloud.pubsub.v1 with parameters of type PubsubMessage Modifier and Type Method Description static Integer
Subscriber. getDeliveryAttempt(PubsubMessage message)
Returns the delivery attempt count for a receivedPubsubMessage
com.google.api.core.ApiFuture<String>
Publisher. publish(PubsubMessage message)
Schedules the publishing of a message.com.google.api.core.ApiFuture<String>
PublisherInterface. publish(PubsubMessage message)
Schedules the publishing of a message.void
MessageReceiver. receiveMessage(PubsubMessage message, AckReplyConsumer consumer)
Called when a message is received by the subscriber.void
MessageReceiverWithAckResponse. receiveMessage(PubsubMessage message, AckReplyConsumerWithResponse consumer)
void
OpenCensusUtil.OpenCensusMessageReceiver. receiveMessage(PubsubMessage message, AckReplyConsumer consumer)
Method parameters in com.google.cloud.pubsub.v1 with type arguments of type PubsubMessage Modifier and Type Method Description PublishResponse
TopicAdminClient. publish(TopicName topic, List<PubsubMessage> messages)
Adds one or more messages to the topic.PublishResponse
TopicAdminClient. publish(String topic, List<PubsubMessage> messages)
Adds one or more messages to the topic.Publisher.Builder
Publisher.Builder. setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform)
Gives the ability to set anApiFunction
that will transform thePubsubMessage
before it is sentPublisher.Builder
Publisher.Builder. setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform)
Gives the ability to set anApiFunction
that will transform thePubsubMessage
before it is sent -
Uses of PubsubMessage in com.google.pubsub.v1
Methods in com.google.pubsub.v1 that return PubsubMessage Modifier and Type Method Description PubsubMessage
PubsubMessage.Builder. build()
PubsubMessage
PubsubMessage.Builder. buildPartial()
static PubsubMessage
PubsubMessage. getDefaultInstance()
PubsubMessage
PubsubMessage.Builder. getDefaultInstanceForType()
PubsubMessage
PubsubMessage. getDefaultInstanceForType()
PubsubMessage
ReceivedMessage.Builder. getMessage()
The message.PubsubMessage
ReceivedMessage. getMessage()
The message.PubsubMessage
ReceivedMessageOrBuilder. getMessage()
The message.PubsubMessage
PublishRequest.Builder. getMessages(int index)
Required.PubsubMessage
PublishRequest. getMessages(int index)
Required.PubsubMessage
PublishRequestOrBuilder. getMessages(int index)
Required.static PubsubMessage
PubsubMessage. parseDelimitedFrom(InputStream input)
static PubsubMessage
PubsubMessage. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubsubMessage
PubsubMessage. parseFrom(byte[] data)
static PubsubMessage
PubsubMessage. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubsubMessage
PubsubMessage. parseFrom(com.google.protobuf.ByteString data)
static PubsubMessage
PubsubMessage. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubsubMessage
PubsubMessage. parseFrom(com.google.protobuf.CodedInputStream input)
static PubsubMessage
PubsubMessage. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubsubMessage
PubsubMessage. parseFrom(InputStream input)
static PubsubMessage
PubsubMessage. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubsubMessage
PubsubMessage. parseFrom(ByteBuffer data)
static PubsubMessage
PubsubMessage. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Methods in com.google.pubsub.v1 that return types with arguments of type PubsubMessage Modifier and Type Method Description List<PubsubMessage>
PublishRequest.Builder. getMessagesList()
Required.List<PubsubMessage>
PublishRequest. getMessagesList()
Required.List<PubsubMessage>
PublishRequestOrBuilder. getMessagesList()
Required.com.google.protobuf.Parser<PubsubMessage>
PubsubMessage. getParserForType()
static com.google.protobuf.Parser<PubsubMessage>
PubsubMessage. parser()
Methods in com.google.pubsub.v1 with parameters of type PubsubMessage Modifier and Type Method Description PublishRequest.Builder
PublishRequest.Builder. addMessages(int index, PubsubMessage value)
Required.PublishRequest.Builder
PublishRequest.Builder. addMessages(PubsubMessage value)
Required.PubsubMessage.Builder
PubsubMessage.Builder. mergeFrom(PubsubMessage other)
ReceivedMessage.Builder
ReceivedMessage.Builder. mergeMessage(PubsubMessage value)
The message.static PubsubMessage.Builder
PubsubMessage. newBuilder(PubsubMessage prototype)
ReceivedMessage.Builder
ReceivedMessage.Builder. setMessage(PubsubMessage value)
The message.PublishRequest.Builder
PublishRequest.Builder. setMessages(int index, PubsubMessage value)
Required.Method parameters in com.google.pubsub.v1 with type arguments of type PubsubMessage Modifier and Type Method Description PublishRequest.Builder
PublishRequest.Builder. addAllMessages(Iterable<? extends PubsubMessage> values)
Required.
-