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_TRANSFORMPropagates 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_TRANSFORMPropagates 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 IntegerSubscriber. getDeliveryAttempt(PubsubMessage message)Returns the delivery attempt count for a receivedPubsubMessagecom.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.voidMessageReceiver. receiveMessage(PubsubMessage message, AckReplyConsumer consumer)Called when a message is received by the subscriber.voidMessageReceiverWithAckResponse. receiveMessage(PubsubMessage message, AckReplyConsumerWithResponse consumer)voidOpenCensusUtil.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 PublishResponseTopicAdminClient. publish(TopicName topic, List<PubsubMessage> messages)Adds one or more messages to the topic.PublishResponseTopicAdminClient. publish(String topic, List<PubsubMessage> messages)Adds one or more messages to the topic.Publisher.BuilderPublisher.Builder. setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform)Gives the ability to set anApiFunctionthat will transform thePubsubMessagebefore it is sentPublisher.BuilderPublisher.Builder. setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform)Gives the ability to set anApiFunctionthat will transform thePubsubMessagebefore 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 PubsubMessagePubsubMessage.Builder. build()PubsubMessagePubsubMessage.Builder. buildPartial()static PubsubMessagePubsubMessage. getDefaultInstance()PubsubMessagePubsubMessage.Builder. getDefaultInstanceForType()PubsubMessagePubsubMessage. getDefaultInstanceForType()PubsubMessageReceivedMessage.Builder. getMessage()The message.PubsubMessageReceivedMessage. getMessage()The message.PubsubMessageReceivedMessageOrBuilder. getMessage()The message.PubsubMessagePublishRequest.Builder. getMessages(int index)Required.PubsubMessagePublishRequest. getMessages(int index)Required.PubsubMessagePublishRequestOrBuilder. getMessages(int index)Required.static PubsubMessagePubsubMessage. parseDelimitedFrom(InputStream input)static PubsubMessagePubsubMessage. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubsubMessagePubsubMessage. parseFrom(byte[] data)static PubsubMessagePubsubMessage. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubsubMessagePubsubMessage. parseFrom(com.google.protobuf.ByteString data)static PubsubMessagePubsubMessage. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubsubMessagePubsubMessage. parseFrom(com.google.protobuf.CodedInputStream input)static PubsubMessagePubsubMessage. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubsubMessagePubsubMessage. parseFrom(InputStream input)static PubsubMessagePubsubMessage. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubsubMessagePubsubMessage. parseFrom(ByteBuffer data)static PubsubMessagePubsubMessage. 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.BuilderPublishRequest.Builder. addMessages(int index, PubsubMessage value)Required.PublishRequest.BuilderPublishRequest.Builder. addMessages(PubsubMessage value)Required.PubsubMessage.BuilderPubsubMessage.Builder. mergeFrom(PubsubMessage other)ReceivedMessage.BuilderReceivedMessage.Builder. mergeMessage(PubsubMessage value)The message.static PubsubMessage.BuilderPubsubMessage. newBuilder(PubsubMessage prototype)ReceivedMessage.BuilderReceivedMessage.Builder. setMessage(PubsubMessage value)The message.PublishRequest.BuilderPublishRequest.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.BuilderPublishRequest.Builder. addAllMessages(Iterable<? extends PubsubMessage> values)Required.
-