@Generated(value="by gapic-generator-java")
See: Description
| Interface | Description |
|---|---|
| AckReplyConsumer |
Accepts a reply, sending it to the service.
|
| AckReplyConsumerWithResponse |
Acknowledging a message in Pub/Sub means that you are done with it, and it will not be delivered
to this subscription again.
|
| MessageReceiver |
This interface can be implemented by users of
Subscriber to receive messages. |
| MessageReceiverWithAckResponse | |
| PublisherInterface |
An interface for a Cloud Pub/Sub publisher.
|
| SubscriberInterface |
The core interface for a Cloud Pub/Sub subscriber, consisting only of
ApiService methods.
|
| Enum | Description |
|---|---|
| AckResponse |
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.
Sample for TopicAdminClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
TopicName name = TopicName.ofProjectTopicName("[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.
Sample for SubscriptionAdminClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
PushConfig pushConfig = PushConfig.newBuilder().build();
int ackDeadlineSeconds = 2135351438;
Subscription response =
subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
}
======================= SchemaServiceClient =======================
Service Description: Service for doing schema-related operations.
Sample for SchemaServiceClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try (SchemaServiceClient schemaServiceClient = SchemaServiceClient.create()) {
ProjectName parent = ProjectName.of("[PROJECT]");
Schema schema = Schema.newBuilder().build();
String schemaId = "schemaId-697673060";
Schema response = schemaServiceClient.createSchema(parent, schema, schemaId);
}
Copyright © 2023 Google LLC. All rights reserved.