Clear direct-send async queue
curl --request DELETE \
--url https://api.wppfy.com/message/async \
--header 'token: <api-key>'import requests
url = "https://api.wppfy.com/message/async"
headers = {"token": "<api-key>"}
response = requests.delete(url, headers=headers)
print(response.text)const options = {method: 'DELETE', headers: {token: '<api-key>'}};
fetch('https://api.wppfy.com/message/async', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.wppfy.com/message/async",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "DELETE",
CURLOPT_HTTPHEADER => [
"token: <api-key>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.wppfy.com/message/async"
req, _ := http.NewRequest("DELETE", url, nil)
req.Header.Add("token", "<api-key>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.delete("https://api.wppfy.com/message/async")
.header("token", "<api-key>")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.wppfy.com/message/async")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Delete.new(url)
request["token"] = '<api-key>'
response = http.request(request)
puts response.read_body{
"response": "Async queue cleared",
"instanceId": "<string>",
"stats": {
"trackedJobsCleared": 3,
"bufferedJobsMarkedCanceled": 2,
"drainedChannelJobs": 1,
"clearedOverflowJobs": 1,
"persistedQueuedCanceled": 5
}
}{
"error": "async queue did not drain before reset",
"instanceId": "<string>",
"stats": {}
}{
"error": "<string>",
"instanceId": "<string>",
"stats": {}
}Async Message
Clear direct-send async queue
Cancels the instance’s entire async=true send queue and marks pending messages as Canceled.
This endpoint only acts on direct sends with async=true. It does not affect:
- messages already sent successfully
Use it when there is an accumulated queue or when you need to cancel all
asynchronous sends not yet completed. After the cleanup, the instance
accepts new sends with async=true again.
DELETE
/
message
/
async
Clear direct-send async queue
curl --request DELETE \
--url https://api.wppfy.com/message/async \
--header 'token: <api-key>'import requests
url = "https://api.wppfy.com/message/async"
headers = {"token": "<api-key>"}
response = requests.delete(url, headers=headers)
print(response.text)const options = {method: 'DELETE', headers: {token: '<api-key>'}};
fetch('https://api.wppfy.com/message/async', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.wppfy.com/message/async",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "DELETE",
CURLOPT_HTTPHEADER => [
"token: <api-key>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.wppfy.com/message/async"
req, _ := http.NewRequest("DELETE", url, nil)
req.Header.Add("token", "<api-key>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.delete("https://api.wppfy.com/message/async")
.header("token", "<api-key>")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.wppfy.com/message/async")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Delete.new(url)
request["token"] = '<api-key>'
response = http.request(request)
puts response.read_body{
"response": "Async queue cleared",
"instanceId": "<string>",
"stats": {
"trackedJobsCleared": 3,
"bufferedJobsMarkedCanceled": 2,
"drainedChannelJobs": 1,
"clearedOverflowJobs": 1,
"persistedQueuedCanceled": 5
}
}{
"error": "async queue did not drain before reset",
"instanceId": "<string>",
"stats": {}
}{
"error": "<string>",
"instanceId": "<string>",
"stats": {}
}