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:
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:
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:
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
);
}
