Get Message

Retrieve a message by its id

GET /v2/messages/{messageId}

curl

curl https://qstash.upstash.io/v2/messages/msg_123 \
  -H "Authorization: Bearer <token>"

const response = await fetch("https://qstash.upstash.io/v2/messages/msg_123", {
  headers: {
    Authorization: "Bearer <token>",
  },
});

import requests

headers = {
    'Authorization': 'Bearer <token>',
}

response = requests.get(
  'https://qstash.upstash.io/v2/messages/msg_123',
  headers=headers
)

req, err := http.NewRequest("GET", "https://qstash.upstash.io/v2/messages/msg_123", nil)
if err != nil {
  log.Fatal(err)
}
req.Header.Set("Authorization", "Bearer <token>")
resp, err := http.DefaultClient.Do(req)
if err != nil {
  log.Fatal(err)
}
defer resp.Body.Close()

200 OK

{
  "messageId": "msg_123",
  "topicId": "tpc_123",
  "url":"https://example.com",
  "method": "POST",
  "header": {
    "My-Header": ["my-value"]
  },
  "body": "{\"foo\":\"bar\"}",
  "createdAt": 1620000000000
}

Request

messageId · string · required

The id of the message to retrieve.

Response

messageId · string · required

A unique identifier for this message.

topicName · string

The topic name if this message was sent to a topic.

endpointName · string

The endpoint name of the message if the endpoint is given a name within the topic.

url · string · required

The URL to which the message should be delivered.

method · string

The HTTP method to use for the message.

header · Record<string, string[]>

The HTTP headers sent to your API.

body · string

The body of the message if it is composed of utf8 chars only, empty otherwise.

bodyBase64 · string

The base64 encoded body if the body contains a non-utf8 char only, empty otherwise.

maxRetries · int

The number of retries that should be attempted in case of delivery failure.

notBefore · int

The unix timestamp in milliseconds before which the message should not be delivered.

createdAt · int · required

The unix timestamp in milliseconds when the message was created.

callback · string

The url where we send a callback each time the message is attempted to be delivered.

failureCallback · string

The url where we send a callback to after the message is failed

curl

curl https://qstash.upstash.io/v2/messages/msg_123 \
  -H "Authorization: Bearer <token>"

const response = await fetch("https://qstash.upstash.io/v2/messages/msg_123", {
  headers: {
    Authorization: "Bearer <token>",
  },
});

import requests

headers = {
    'Authorization': 'Bearer <token>',
}

response = requests.get(
  'https://qstash.upstash.io/v2/messages/msg_123',
  headers=headers
)

req, err := http.NewRequest("GET", "https://qstash.upstash.io/v2/messages/msg_123", nil)
if err != nil {
  log.Fatal(err)
}
req.Header.Set("Authorization", "Bearer <token>")
resp, err := http.DefaultClient.Do(req)
if err != nil {
  log.Fatal(err)
}
defer resp.Body.Close()

200 OK

{
  "messageId": "msg_123",
  "topicId": "tpc_123",
  "url":"https://example.com",
  "method": "POST",
  "header": {
    "My-Header": ["my-value"]
  },
  "body": "{\"foo\":\"bar\"}",
  "createdAt": 1620000000000
}