google-cloud-pubsub overview (1.117.0)
Stay organized with collections
Save and categorize content based on your preferences.
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(TopicAdminClienttopicAdminClient=TopicAdminClient.create()){
TopicNamename=TopicName.ofProjectTopicName("[PROJECT]","[TOPIC]");
Topicresponse=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(SubscriptionAdminClientsubscriptionAdminClient=SubscriptionAdminClient.create()){
SubscriptionNamename=SubscriptionName.of("[PROJECT]","[SUBSCRIPTION]");
TopicNametopic=TopicName.ofProjectTopicName("[PROJECT]","[TOPIC]");
PushConfigpushConfig=PushConfig.newBuilder().build();
intackDeadlineSeconds=2135351438;
Subscriptionresponse=
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(SchemaServiceClientschemaServiceClient=SchemaServiceClient.create()){
ProjectNameparent=ProjectName.of("[PROJECT]");
Schemaschema=Schema.newBuilder().build();
StringschemaId="schemaId-697673060";
Schemaresponse=schemaServiceClient.createSchema(parent,schema,schemaId);
}