naftiko: 1.0.0-alpha2 info: label: Workato Event Streams Public API — Messages description: 'Workato Event Streams Public API — Messages. 3 operations. Lead operation: Workato Publish a Batch of Messages to a Topic. Self-contained Naftiko capability covering one Workato business surface.' tags: - Workato - Messages created: '2026-05-19' modified: '2026-05-19' binds: - namespace: env keys: WORKATO_API_KEY: WORKATO_API_KEY capability: consumes: - type: http namespace: event-streams-messages baseUri: https://event-streams.workato.com description: Workato Event Streams Public API — Messages business capability. Self-contained, no shared references. resources: - name: api-v1-batch-topics-topic_id-publish path: /api/v1/batch/topics/{topic_id}/publish operations: - name: publishbatchmessages method: POST description: Workato Publish a Batch of Messages to a Topic outputRawFormat: json outputParameters: - name: result type: object value: $. inputParameters: - name: body in: body type: object description: Request body (JSON). required: true - name: api-v1-topics-topic_id-consume path: /api/v1/topics/{topic_id}/consume operations: - name: consumemessages method: POST description: Workato Consume Messages from a Topic outputRawFormat: json outputParameters: - name: result type: object value: $. inputParameters: - name: body in: body type: object description: Request body (JSON). required: false - name: api-v1-topics-topic_id-publish path: /api/v1/topics/{topic_id}/publish operations: - name: publishmessage method: POST description: Workato Publish a Message to a Topic outputRawFormat: json outputParameters: - name: result type: object value: $. inputParameters: - name: body in: body type: object description: Request body (JSON). required: true authentication: type: bearer token: '{{env.WORKATO_API_KEY}}' exposes: - type: rest namespace: event-streams-messages-rest port: 8080 description: REST adapter for Workato Event Streams Public API — Messages. One Spectral-compliant resource per consumed operation, prefixed with /v1. resources: - path: /v1/api/v1/batch/topics/{topic-id}/publish name: api-v1-batch-topics-topic-id-publish description: REST surface for api-v1-batch-topics-topic_id-publish. operations: - method: POST name: publishbatchmessages description: Workato Publish a Batch of Messages to a Topic call: event-streams-messages.publishbatchmessages with: body: rest.body outputParameters: - type: object mapping: $. - path: /v1/api/v1/topics/{topic-id}/consume name: api-v1-topics-topic-id-consume description: REST surface for api-v1-topics-topic_id-consume. operations: - method: POST name: consumemessages description: Workato Consume Messages from a Topic call: event-streams-messages.consumemessages with: body: rest.body outputParameters: - type: object mapping: $. - path: /v1/api/v1/topics/{topic-id}/publish name: api-v1-topics-topic-id-publish description: REST surface for api-v1-topics-topic_id-publish. operations: - method: POST name: publishmessage description: Workato Publish a Message to a Topic call: event-streams-messages.publishmessage with: body: rest.body outputParameters: - type: object mapping: $. - type: mcp namespace: event-streams-messages-mcp port: 9090 transport: http description: MCP adapter for Workato Event Streams Public API — Messages. One tool per consumed operation, routed inline through this capability's consumes block. tools: - name: workato-publish-batch-messages-topic description: Workato Publish a Batch of Messages to a Topic hints: readOnly: false destructive: false idempotent: false call: event-streams-messages.publishbatchmessages with: body: tools.body outputParameters: - type: object mapping: $. - name: workato-consume-messages-topic description: Workato Consume Messages from a Topic hints: readOnly: false destructive: false idempotent: false call: event-streams-messages.consumemessages with: body: tools.body outputParameters: - type: object mapping: $. - name: workato-publish-message-topic description: Workato Publish a Message to a Topic hints: readOnly: false destructive: false idempotent: false call: event-streams-messages.publishmessage with: body: tools.body outputParameters: - type: object mapping: $.