

Google Pub/Sub Connector Reference

The following operations allow you to work with the Google Pub/Sub Connector. Click an operation name to see parameter details and samples on how to use it.

---

To use the Google Pub/Sub connector, add the element in your configuration before any other Google Pub/Sub operation. This configuration authenticates with Google Pub/Sub via user credentials.

Google Pub/Sub uses the OAuth 2.0 protocol for authentication and authorization. All requests to the Google Cloud Pub/Sub API must be authorized by an authenticated user.

googlepubsub.init

This operation allows you to initialize the connection to Google Pub/Sub.

Parameter Name	Description	Required
apiUrl	The application URL of Google Pub/Sub.	Yes
apiVersion	The version of the Google Pub/Sub API.	Yes
accessToken	The access token that grants access to the Google Pub/Sub API on behalf of a user.	Yes
clientId	The client id provided by the Google developer console.	Yes
clientSecret	The client secret provided by the Google developer console.	Yes
refreshToken	The refresh token provided by the Google developer console, which can be used to obtain new access tokens.	Yes
blocking	Set this to true if you want the connector to perform blocking invocations to Google Pub/Sub.	Yes
tokenEndpoint	The token endpoint of the Google API. The default will be set to https://www.googleapis.com/oauth2/v4/token if not provided.	Yes

Sample configuration

<googlepubsub.init>
    <apiUrl>{$ctx:apiUrl}</apiUrl>
    <apiVersion>{$ctx:apiVersion}</apiVersion>
    <accessToken>{$ctx:accessToken}</accessToken>
    <clientId>{$ctx:clientId}</clientId>
    <clientSecret>{$ctx:clientSecret}</clientSecret>
    <refreshToken>{$ctx:refreshToken}</refreshToken>
    <blocking>{$ctx:blocking}</blocking>
    <tokenEndpoint>{$ctx:tokenEndpoint}</tokenEndpoint>
</googlepubsub.init>

---

Project Topics

createTopic

The createTopic operation creates a new topic with a name that you specify. See the related API documentation for more information.

Parameter Name	Description	Required
topicName	The name of the topic that you are creating.	Yes
projectId	The unique ID of the project within which you want to create the topic.	Yes

Sample configuration

<googlepubsub.createTopic>
    <topicName>{$ctx:topicName}</topicName>
    <projectId>{$ctx:projectId}</projectId>
</googlepubsub.createTopic>

Sample request

{
    "apiUrl":"https://pubsub.googleapis.com",
    "apiVersion":"v1",
    "accessToken": "ya29.GlwG2NhgX_NQhxjtF_0G9bzf0FEj_shNWgF_GXmjeYQF0XQXrBjjcrJukforOeyTAHoFfSQW0x-OrrZ2lj47Z6k6DAYZuUv3ZhJMl-ll4mvouAbc",
    "topicName":"topicA",
    "projectId":"rising-parser-123456"
}

publishMessage

The publishMessage operation publishes messages to a specified topic. See the related API documentation for more information.

Parameter Name	Description	Required
topicName	The unique name of the topic to which messages should be published.	Yes
projectId	The unique ID of the project within which the topic is created.	Yes
data	The message payload.	Yes
attributes	Additional attributes of the message.	Optional

Sample configuration

<googlepubsub.publishMessage>
    <topicName>{$ctx:topicName}</topicName>
    <projectId>{$ctx:projectId}</projectId>
    <data>{$ctx:data}</data>
    <attributes>{$ctx:attributes}</attributes>
</googlepubsub.publishMessage>

Sample request

{
    "apiUrl":"https://pubsub.googleapis.com",
    "apiVersion":"v1",
    "accessToken": "ya29.GlwG2NhgX_NQhxjtF_0G9bzf0FEj_shNWgF_GXmjeYQF0XQXrBjjcrJukforOeyTAHoFfSQW0x-OrrZ2lj47Z6k6DAYZuUv3ZhJMl-ll4mvouAbc",
    "topicName":"topicA",
    "projectId":"rising-parser-123456"
}

Project Subscriptions

createTopicSubscription

The createTopicSubscription operation creates a subscription to a topic that you specify. See the related API documentation for more information.

Parameter Name	Description	Required
topicName	The name of the topic that you are creating.	Yes
projectId	The unique ID of the project within which you want to create the topic.	Yes
subscriptionName	The name of the subscription.	Yes
ackDeadlineSeconds	The maximum time a subscriber can take to acknowledge a message that is received.	Optional
pushEndpoint	The URL that specifies the endpoint to which messages should be pushed.	Optional
attributes	Additional endpoint configuration attributes.	Optional

Sample configuration

<googlepubsub.createTopicSubscription>
    <topicName>{$ctx:topicName}</topicName>
    <projectId>{$ctx:projectId}</projectId>
    <subscriptionName>{$ctx:subscriptionName}</subscriptionName>
    <ackDeadlineSeconds>{$ctx:ackDeadlineSeconds}</ackDeadlineSeconds>
    <pushEndpoint>{$ctx:pushEndpoint}</pushEndpoint>
    <attributes>{$ctx:attributes}</attributes>
</googlepubsub.createTopicSubscription>

Sample request

{
    "apiUrl":"https://pubsub.googleapis.com",
    "apiVersion":"v1",
    "accessToken": "ya29.GlwAJG2NhgX_NQhxjtF_0G9bzf0FEj_shNWgF_GXmYFpwIxjeYQF0XQXukforOeyTAHoFfSQW0x-OrrZ2lj47Z6k6DAYZuUv3ZhJMl-ll4mvouAbc",
    "projectId":"rising-parser-123456",
    "topicName":"topicA",
    "subscriptionName":"mysubA",
    "ackDeadlineSeconds":"30",
    "pushEndpoint": "https://example.com/push",
    "attributes": {"key": "value1","key2":"values2"}
}

pullMessage

The pullMessage operation retrieves messages that are published to a topic. See the related API documentation for more information.

Parameter Name	Description	Required
topicName	The name of the topic to which the subscription belongs.	Yes
projectId	The unique ID of the project within which the topic is created.	Yes
subscriptionName	The name of the subscription from which messages should be retrieved.	Yes
maxMessages	The maximum number of messages to retrieve.	Optional
returnImmediately	Set this to true if you want the server to respond immediately.	Optional

Sample configuration

<googlepubsub.pullMessage>
    <topicName>{$ctx:topicName}</topicName>
    <projectId>{$ctx:projectId}</projectId>
    <subscriptionName>{$ctx:subscriptionName}</subscriptionName>
    <maxMessages>{$ctx:maxMessages}</maxMessages>
    <returnImmediately>{$ctx:returnImmediately}</returnImmediately>
</googlepubsub.pullMessage>

Sample request

{
    "apiUrl":"https://pubsub.googleapis.com",
    "apiVersion":"v1",
    "accessToken": "ya29.GlwABbJG2NhgX_NQhxjtF_0G9bzf0FEj_shNWgF_GXmYFpwIxjeYQF0XjcrJukforOeyTAHoFfSQW0x-OrrZ2lj47Z6k6DAYZuUv3ZhJMl-ll4mvouAbc",
    "topicName":"topicA",
    "projectId":"rising-parser-123456",
    "subscriptionName":"mysubA",
    "maxMessages":"2",
    "returnImmediately":"false"
}

Top