| Package | Description |
|---|---|
| com.google.cloud.pubsub |
A client to Google Cloud Pub/Sub.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ReceivedMessage
A Google Cloud Pub/Sub received message.
|
| Modifier and Type | Method and Description |
|---|---|
abstract Message |
Message.Builder.build()
Creates a message object.
|
static Message |
Message.of(ByteArray payload)
Creates a
Message object given the payload as a ByteArray. |
static Message |
Message.of(String payload)
Creates a
Message object given the payload as a string. |
| Modifier and Type | Method and Description |
|---|---|
void |
PubSub.MessageProcessor.process(Message message)
Processes the received
message. |
String |
Topic.publish(Message message)
Publishes a message to this topic.
|
List<String> |
Topic.publish(Message message,
Message... messages)
Publishes a number of messages to this topic.
|
List<String> |
Topic.publish(Message message,
Message... messages)
Publishes a number of messages to this topic.
|
String |
PubSub.publish(String topic,
Message message)
Publishes a message to the provided topic.
|
List<String> |
PubSub.publish(String topic,
Message message,
Message... messages)
Publishes a number of messages to the provided topic.
|
List<String> |
PubSub.publish(String topic,
Message message,
Message... messages)
Publishes a number of messages to the provided topic.
|
Future<String> |
Topic.publishAsync(Message message)
Sends a request for publishing a message to the this topic.
|
Future<List<String>> |
Topic.publishAsync(Message message,
Message... messages)
Sends a request to publish a number of messages to this topic.
|
Future<List<String>> |
Topic.publishAsync(Message message,
Message... messages)
Sends a request to publish a number of messages to this topic.
|
Future<String> |
PubSub.publishAsync(String topic,
Message message)
Sends a request for publishing a message to the provided topic.
|
Future<List<String>> |
PubSub.publishAsync(String topic,
Message message,
Message... messages)
Sends a request to publish a number of messages to the provided topic.
|
Future<List<String>> |
PubSub.publishAsync(String topic,
Message message,
Message... messages)
Sends a request to publish a number of messages to the provided topic.
|
| Modifier and Type | Method and Description |
|---|---|
List<String> |
Topic.publish(Iterable<Message> messages)
Publishes a number of messages to this topic.
|
List<String> |
PubSub.publish(String topic,
Iterable<Message> messages)
Publishes a number of messages to the provided topic.
|
Future<List<String>> |
Topic.publishAsync(Iterable<Message> messages)
Sends a request to publish a number of messages to this topic.
|
Future<List<String>> |
PubSub.publishAsync(String topic,
Iterable<Message> messages)
Sends a request to publish a number of messages to the provided topic.
|
Copyright © 2016 Google. All rights reserved.