Acknowledge messages
Acknowledge receipt and processing of pulled messages.
curl -X POST "https://api.mythic-analytics.com/api/v1/admin/pubsub/subscriptions/example_string/acknowledge" \
-H "Content-Type: application/json" \
-H "Authorization: Bearer YOUR_API_TOKEN" \
-d '{
"ack_ids": [
"ack_3xL7nBcD",
"ack_9mK4pLrT"
]
}'
import requests
import json
url = "https://api.mythic-analytics.com/api/v1/admin/pubsub/subscriptions/example_string/acknowledge"
headers = {
"Content-Type": "application/json",
"Authorization": "Bearer YOUR_API_TOKEN"
}
data = {
"ack_ids": [
"ack_3xL7nBcD",
"ack_9mK4pLrT"
]
}
response = requests.post(url, headers=headers, json=data)
print(response.json())
const response = await fetch("https://api.mythic-analytics.com/api/v1/admin/pubsub/subscriptions/example_string/acknowledge", {
method: "POST",
headers: {
"Content-Type": "application/json",
"Authorization": "Bearer YOUR_API_TOKEN"
},
body: JSON.stringify({
"ack_ids": [
"ack_3xL7nBcD",
"ack_9mK4pLrT"
]
})
});
const data = await response.json();
console.log(data);
package main
import (
"fmt"
"net/http"
"bytes"
"encoding/json"
)
func main() {
data := []byte(`{
"ack_ids": [
"ack_3xL7nBcD",
"ack_9mK4pLrT"
]
}`)
req, err := http.NewRequest("POST", "https://api.mythic-analytics.com/api/v1/admin/pubsub/subscriptions/example_string/acknowledge", bytes.NewBuffer(data))
if err != nil {
panic(err)
}
req.Header.Set("Content-Type", "application/json")
req.Header.Set("Authorization", "Bearer YOUR_API_TOKEN")
client := &http.Client{}
resp, err := client.Do(req)
if err != nil {
panic(err)
}
defer resp.Body.Close()
fmt.Println("Response Status:", resp.Status)
}
require 'net/http'
require 'json'
uri = URI('https://api.mythic-analytics.com/api/v1/admin/pubsub/subscriptions/example_string/acknowledge')
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = true
request = Net::HTTP::Post.new(uri)
request['Content-Type'] = 'application/json'
request['Authorization'] = 'Bearer YOUR_API_TOKEN'
request.body = '{
"ack_ids": [
"ack_3xL7nBcD",
"ack_9mK4pLrT"
]
}'
response = http.request(request)
puts response.body
{
"success": true
}
{
"error": "Bad Request",
"message": "The request contains invalid parameters or malformed data",
"code": 400,
"details": [
{
"field": "email",
"message": "Invalid email format"
}
]
}
{
"error": "Unauthorized",
"message": "Authentication required. Please provide a valid API token",
"code": 401
}
{
"error": "Not Found",
"message": "The requested resource was not found",
"code": 404
}
POST
/admin/pubsub/subscriptions/{id}/acknowledgePOST
Bearer Token
Bearer Tokenstring
RequiredAdmin API key as bearer token. Format: Bearer YOUR_ADMIN_KEY
Admin API key as bearer token. Format:
Bearer YOUR_ADMIN_KEYAPI Key (query: admin_key)
admin_keystring
RequiredAlternative to the Authorization header for server-to-server scenarios.
Alternative to the Authorization header for server-to-server scenarios.
path
idstring
RequiredSubscription identifier.
Content-Typestring
RequiredThe media type of the request body
Options: application/json
ack_idsarray
RequiredAcknowledgment IDs from pulled messages.
Request Preview
Response
Response will appear here after sending the request
Authentication
header
Authorizationstring
RequiredBearer token. Admin API key as bearer token. Format: Bearer YOUR_ADMIN_KEY
query
admin_keystring
RequiredAPI Key for authentication. Alternative to the Authorization header for server-to-server scenarios.
Path Parameters
idstring
RequiredSubscription identifier.
Body
application/json
ack_idsarray
RequiredAcknowledgment IDs from pulled messages.
Responses
successboolean
successboolean
datastring
errorstring
countinteger
successboolean
datastring
errorstring
countinteger
successboolean
datastring
errorstring
countinteger
Was this page helpful?
Last updated Feb 26, 2026
Built with Documentation.AI