com.google.cloud.pubsub.v1
A client to Cloud Pub/Sub API
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 for illustrative purposes only.
// It may require modifications to work in your environment.
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 for illustrative purposes only.
// It may require modifications to work in your environment.
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 for illustrative purposes only.
// It may require modifications to work in your environment.
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);
}