For Agents
Publish messages, manage topics and subscriptions, and pull or acknowledge messages on Google Cloud Pub/Sub for event-driven and streaming workloads.
Get started with Cloud Pub/Sub API in minutes using your preferred integration method.
# Add to your MCP client config (Claude Desktop, Cursor, Windsurf)
{
"jentic": {
"url": "https://api.jentic.com/mcp",
"auth": "oauth"
}
}
# Then ask your agent:
"publish a message to a google pubsub topic"
# → Jentic returns the GET /events tool with parameter schema, agent executes.What an agent can do with Cloud Pub/Sub API API.
Create topics and configure message retention, schema, and ordering settings
Create push or pull subscriptions on a topic with custom ack deadlines and dead-letter policies
Publish batches of messages to a topic with attribute-based filtering metadata
Pull messages from a subscription and acknowledge them after processing
GET STARTED
Use for: I need to publish a message to a Pub/Sub topic, Pull pending messages from a subscription and acknowledge the ones we processed, Create a new topic with a 7-day message retention policy, Set up a push subscription that delivers messages to a Cloud Run service
Not supported: Does not handle long-running task scheduling, durable workflow orchestration, or stream processing transformations — use for asynchronous topic and subscription messaging only.
Google Cloud Pub/Sub is a globally distributed, fully managed messaging service for asynchronous service-to-service communication, event ingestion, and streaming analytics pipelines. The REST API exposes topics, subscriptions, snapshots, schemas, and IAM controls so producers can publish messages, subscribers can pull or acknowledge them, and operators can manage retention, ordering, and dead-letter behavior. Pub/Sub backs many Google Cloud event flows, including Cloud Storage notifications, Dataflow pipelines, and Cloud Run event triggers.
Manage Pub/Sub schemas and validate messages against Avro or Protocol Buffer definitions
Create snapshots of subscription state and seek subscriptions to a prior point in time
Patterns agents use Cloud Pub/Sub API API for, with concrete tasks.
★ Event-Driven Microservices
Decouple producers and consumers across services using Pub/Sub as the asynchronous transport. Producers publish events to topics; consumers attach pull or push subscriptions, process messages, and acknowledge them. Pub/Sub handles delivery, retry, ordering, and dead-letter routing automatically across regions.
Create topic order-events with 7-day retention, create push subscription order-events-fulfillment to https://fulfillment.example.com/events, and publish a JSON message with attribute event_type=order.created.
Streaming Analytics Ingestion
Ingest high-volume application or device telemetry into Pub/Sub topics so downstream Dataflow or BigQuery pipelines can consume them in near real time. Schema validation can be enforced at the topic level so malformed events are rejected before they enter the pipeline.
Create a Pub/Sub schema in Avro, attach it to topic telemetry, then publish a batch of validated telemetry events from edge devices.
Disaster Recovery and Replay
Use Pub/Sub snapshots and seek-to-time to replay a subscription after a downstream consumer fails or after a bad deploy. Snapshots capture the unacked-message state, and seek operations rewind a subscription to a snapshot or wall-clock timestamp without affecting other subscriptions on the same topic.
Create a snapshot of subscription orders-fulfillment-sub, deploy the fix, then call seek with the snapshot name to redeliver messages from before the bad deploy.
Agent-Driven Event Publishing
An AI agent integrating with Google Cloud uses Jentic to publish events to Pub/Sub topics in response to user requests or upstream signals, so other workloads (workflows, analytics jobs, alerting) can react asynchronously without point-to-point integration.
Search Jentic for publish a message to a pubsub topic, load the schema for projects.topics.publish, and execute it with the topic and a base64-encoded message body.
33 endpoints — google cloud pub/sub is a globally distributed, fully managed messaging service for asynchronous service-to-service communication, event ingestion, and streaming analytics pipelines.
METHOD
PATH
DESCRIPTION
/v1/{+project}/topics
List topics in a project
/v1/{+project}/subscriptions
List subscriptions in a project
/v1/{+project}/snapshots
List snapshots in a project
/v1/{+name}:commit
Commit a schema revision
/v1/{+name}:rollback
Rollback a schema to a prior revision
/v1/{+parent}/schemas:validate
Validate a schema definition
/v1/{+parent}/schemas:validateMessage
Validate a message against a schema
/v1/{+project}/topics
List topics in a project
/v1/{+project}/subscriptions
List subscriptions in a project
/v1/{+project}/snapshots
List snapshots in a project
/v1/{+name}:commit
Commit a schema revision
/v1/{+name}:rollback
Rollback a schema to a prior revision
Three things that make agents converge on Jentic-routed access.
Credential isolation
Google OAuth 2.0 credentials are stored encrypted in the Jentic vault. Scoped access tokens (cloud-platform or pubsub) are issued at call time so the underlying refresh token never enters the agent, and IAM bindings determine what operations the agent can perform.
Intent-based discovery
Agents search Jentic by intent (publish a message, pull messages, create a subscription) and Jentic returns the matching Pub/Sub operation with its input schema, so the agent can build a correct request without reading Google's discovery doc.
Time to first call
Direct integration with Pub/Sub takes 1-2 days for auth, IAM, and message encoding patterns. Through Jentic: under 1 hour — search, load schema, execute.
Alternatives and complements available in the Jentic catalogue.
Pub/Sub Lite API
Lower-cost zonal messaging for partitioned, high-throughput workloads
Choose Pub/Sub Lite when you need predictable per-partition throughput at lower cost; choose Pub/Sub when you need global delivery, push subscriptions, or schemas.
Cloud Tasks API
Distributed task queue for guaranteed task execution rather than fan-out messaging
Choose Cloud Tasks when each message represents a unit of work that must run exactly once with retry semantics; choose Pub/Sub when many subscribers need the same event.
Cloud Dataflow API
Stream processing engine that consumes Pub/Sub topics into BigQuery and other sinks
Use Dataflow when Pub/Sub messages need to be transformed and written to BigQuery, GCS, or other sinks at scale.
Cloud Scheduler API
Cron-style scheduler that can publish Pub/Sub messages on a schedule
Use Cloud Scheduler to fire Pub/Sub messages on a recurring cron schedule for periodic workflows.
Specific to using Cloud Pub/Sub API API through Jentic.
What authentication does the Cloud Pub/Sub API use?
The API uses Google OAuth 2.0 with the cloud-platform or pubsub scopes, sent as a Bearer token in the Authorization header. Through Jentic the OAuth credentials are stored in the vault and short-lived access tokens are minted per call so the refresh token never enters the agent.
Can I publish messages with attributes for filtering?
Yes, every message body can include a map of string attributes. Subscriptions can declare a filter expression that matches on those attributes, so the same topic can fan out to multiple consumers each receiving only the events relevant to them.
What are the rate limits for the Cloud Pub/Sub API?
Pub/Sub publisher and subscriber quotas are large by default and are documented on Google Cloud's Pub/Sub quotas page in MB/s and ops/s. For very high-throughput workloads consider using the gRPC client libraries instead of REST and request quota increases up front.
How do I publish a message through Jentic?
Search Jentic for publish a message to a pubsub topic, load the schema for the projects.topics.publish operation which maps to POST /v1/{+topic}:publish, then execute it with messages encoded as base64 in the request body.
Is the Cloud Pub/Sub API free?
Pub/Sub has a free tier of 10 GB of message data per month; beyond that, throughput is billed per GB ingested, delivered, and stored. Snapshots and seek operations also incur storage charges. Pricing is identical whether the API is called directly or through Jentic.
How do I replay messages after a bad deploy?
Take a snapshot of the subscription before the deploy with POST /v1/{+name}:createSnapshot semantics on snapshots, then call POST /v1/{+subscription}:seek with the snapshot name after the fix is deployed to redeliver messages that were acked during the broken window.
/v1/{+parent}/schemas:validate
Validate a schema definition
/v1/{+parent}/schemas:validateMessage
Validate a message against a schema