Package | Description |
---|---|
com.google.cloud.pubsub.v1 |
A client to Cloud Pub/Sub API
|
com.google.pubsub.v1 |
Modifier and Type | Field and 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 the
PubsubMessage . |
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 the
PubsubMessage . |
Modifier and Type | Method and Description |
---|---|
static Integer |
Subscriber.getDeliveryAttempt(PubsubMessage message)
Returns the delivery attempt count for a received
PubsubMessage |
com.google.api.core.ApiFuture<String> |
PublisherInterface.publish(PubsubMessage message)
Schedules the publishing of a message.
|
com.google.api.core.ApiFuture<String> |
Publisher.publish(PubsubMessage message)
Schedules the publishing of a message.
|
void |
OpenCensusUtil.OpenCensusMessageReceiver.receiveMessage(PubsubMessage message,
AckReplyConsumer consumer) |
void |
MessageReceiver.receiveMessage(PubsubMessage message,
AckReplyConsumer consumer)
Called when a message is received by the subscriber.
|
void |
MessageReceiverWithAckResponse.receiveMessage(PubsubMessage message,
AckReplyConsumerWithResponse consumer) |
Modifier and Type | Method and Description |
---|---|
PublishResponse |
TopicAdminClient.publish(String topic,
List<PubsubMessage> messages)
Adds one or more messages to the topic.
|
PublishResponse |
TopicAdminClient.publish(TopicName 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 an
ApiFunction that will transform the PubsubMessage
before it is sent |
Publisher.Builder |
Publisher.Builder.setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform)
Gives the ability to set an
ApiFunction that will transform the PubsubMessage
before it is sent |
Modifier and Type | Method and Description |
---|---|
PubsubMessage |
PubsubMessage.Builder.build() |
PubsubMessage |
PubsubMessage.Builder.buildPartial() |
static PubsubMessage |
PubsubMessage.getDefaultInstance() |
PubsubMessage |
PubsubMessage.getDefaultInstanceForType() |
PubsubMessage |
PubsubMessage.Builder.getDefaultInstanceForType() |
PubsubMessage |
ReceivedMessage.getMessage()
The message.
|
PubsubMessage |
ReceivedMessage.Builder.getMessage()
The message.
|
PubsubMessage |
ReceivedMessageOrBuilder.getMessage()
The message.
|
PubsubMessage |
PublishRequest.getMessages(int index)
Required.
|
PubsubMessage |
PublishRequest.Builder.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(ByteBuffer data) |
static PubsubMessage |
PubsubMessage.parseFrom(ByteBuffer 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) |
Modifier and Type | Method and Description |
---|---|
List<PubsubMessage> |
PublishRequest.getMessagesList()
Required.
|
List<PubsubMessage> |
PublishRequest.Builder.getMessagesList()
Required.
|
List<PubsubMessage> |
PublishRequestOrBuilder.getMessagesList()
Required.
|
com.google.protobuf.Parser<PubsubMessage> |
PubsubMessage.getParserForType() |
static com.google.protobuf.Parser<PubsubMessage> |
PubsubMessage.parser() |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
PublishRequest.Builder |
PublishRequest.Builder.addAllMessages(Iterable<? extends PubsubMessage> values)
Required.
|
Copyright © 2023 Google LLC. All rights reserved.