Interface | Description |
---|---|
AckReplyConsumer |
Accepts a reply, sending it to the service.
|
MessageReceiver |
This interface can be implemented by users of
Subscriber to receive messages. |
Class | Description |
---|---|
OpenCensusUtil |
Utilities for propagating OpenCensus
TagContext and SpanContext from publishers
to subscribers. |
OpenCensusUtil.OpenCensusMessageReceiver |
Wrapper class for
MessageReceiver that decodes any received trace and tag contexts and
puts them in scope. |
Publisher |
A Cloud Pub/Sub publisher, that is
associated with a specific topic at creation.
|
Publisher.Builder |
A builder of
Publisher s. |
Subscriber |
A Cloud Pub/Sub subscriber that is
associated with a specific subscription at creation.
|
Subscriber.Builder |
Builder of
Subscribers . |
SubscriptionAdminClient |
Service Description: The service that an application uses to manipulate subscriptions and to
consume messages from a subscription via the `Pull` method or by establishing a bi-directional
stream using the `StreamingPull` method.
|
SubscriptionAdminClient.ListSnapshotsFixedSizeCollection | |
SubscriptionAdminClient.ListSnapshotsPage | |
SubscriptionAdminClient.ListSnapshotsPagedResponse | |
SubscriptionAdminClient.ListSubscriptionsFixedSizeCollection | |
SubscriptionAdminClient.ListSubscriptionsPage | |
SubscriptionAdminClient.ListSubscriptionsPagedResponse | |
SubscriptionAdminSettings |
Settings class to configure an instance of
SubscriptionAdminClient . |
SubscriptionAdminSettings.Builder |
Builder for SubscriptionAdminSettings.
|
TopicAdminClient |
Service Description: The service that an application uses to manipulate topics, and to send
messages to a topic.
|
TopicAdminClient.ListTopicsFixedSizeCollection | |
TopicAdminClient.ListTopicsPage | |
TopicAdminClient.ListTopicsPagedResponse | |
TopicAdminClient.ListTopicSubscriptionsFixedSizeCollection | |
TopicAdminClient.ListTopicSubscriptionsPage | |
TopicAdminClient.ListTopicSubscriptionsPagedResponse | |
TopicAdminSettings |
Settings class to configure an instance of
TopicAdminClient . |
TopicAdminSettings.Builder |
Builder for TopicAdminSettings.
|
The interfaces provided are listed below, along with usage samples.
================ TopicAdminClient ================
Service Description: The service that an application uses to manipulate topics, and to send messages to a topic.
To publish messages to a topic, see the Publisher class.
Sample for TopicAdminClient:
try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
ProjectTopicName name = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
Topic response = topicAdminClient.createTopic(name);
}
======================= SubscriptionAdminClient =======================
Service Description: The service that an application uses to manipulate subscriptions and to consume messages from a subscription via the `Pull` method or by establishing a bi-directional stream using the `StreamingPull` method.
To retrieve messages from a subscription, see the Subscriber class.
Sample for SubscriptionAdminClient:
try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
PushConfig pushConfig = PushConfig.newBuilder().build();
int ackDeadlineSeconds = 0;
Subscription response = subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
}
Copyright © 2019 Google LLC. All rights reserved.