> ## Documentation Index
> Fetch the complete documentation index at: https://docs.agribackup.com/llms.txt
> Use this file to discover all available pages before exploring further.

# Bulk Replay Multiple Messages from the Webhook DLQ

> Re-enqueue a batch of permanently failed webhook payloads for redelivery by supplying a list of event IDs in a single bulk operation.

Re-queues multiple compliance event payloads from the Dead-Letter Queue (DLQ) in a single operation. Supply a list of `eventIds` in the request body to replay up to hundreds of failed messages at once — useful after a prolonged endpoint outage or after diagnosing a systematic delivery failure.

Each replayed message is re-delivered with a fresh attempt counter and signed with the webhook's current HMAC-SHA256 signing secret. Messages that fail redelivery are returned to the DLQ. To retrieve the list of available DLQ event IDs, call [Retrieve Permanently Failed Webhook Payloads](/sdks/enterprise-webhooks/retrieve-permanently-failed-webhook-payloads) first.

You may also filter the bulk replay by `startDate`, `endDate`, and `eventType` query parameters to scope reprocessing to a specific time window or event category.

<CodeGroup>
  ```python Python theme={null}
  import requests

  headers = {
      "X-API-Key": "sk_live_YOUR_API_KEY",
      "Content-Type": "application/json",
  }
  payload = {"eventIds": ["evt_123", "evt_456", "evt_789"]}

  response = requests.post(
      "https://live.agribackup.com/api/v1/enterprise/eudr/webhooks/dlq/replay-bulk",
      headers=headers,
      json=payload,
  )
  print(response.status_code)
  ```

  ```javascript Node.js theme={null}
  const response = await fetch(
    "https://live.agribackup.com/api/v1/enterprise/eudr/webhooks/dlq/replay-bulk",
    {
      method: "POST",
      headers: {
        "X-API-Key": "sk_live_YOUR_API_KEY",
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ eventIds: ["evt_123", "evt_456", "evt_789"] }),
    }
  );
  console.log(response.status);
  ```

  ```bash cURL theme={null}
  curl -X POST \
    "https://live.agribackup.com/api/v1/enterprise/eudr/webhooks/dlq/replay-bulk" \
    -H "X-API-Key: sk_live_YOUR_API_KEY" \
    -H "Content-Type: application/json" \
    -d '{"eventIds": ["evt_123", "evt_456", "evt_789"]}'
  ```
</CodeGroup>


## OpenAPI

````yaml post /api/v1/enterprise/eudr/webhooks/dlq/replay-bulk
openapi: 3.0.1
info:
  title: AgriBackup Enterprise EUDR API
  description: >-
    # Introduction


    AgriBackup is the cryptographic compliance engine for EU-bound commodity
    imports. Built on Deterministic Logic, Immutable Evidence, and
    High-Throughput Ingestion, our API provides Tier-1 enterprise routing for EU
    Deforestation Regulation (EUDR).


    ## The Integration Vector

    To integrate this Digital Trust Layer into your ERP, you must execute the
    following sequence:

    1. **Authentication:** Generate your `X-API-Key` from the client dashboard.

    2. **Telemetry:** Register your webhook URLs via `POST /webhooks`.

    3. **Ingestion:** Push your GeoJSON polygons via `POST /polygons`.

    4. **Logistics:** Lock the batch to a shipment via `POST /shipments/link`.


    ## Asynchronous Architecture

    Because satellite deforestation screening and Hedera DLT anchoring take
    time, ingestion endpoints return a `202 Accepted`. You must listen for the
    corresponding Webhook to confirm cryptographic execution.


    ## Base URLs

    * **Production:** `https://live.agribackup.com`

    * **Sandbox:** `https://sandbox.agribackup.com`
  contact:
    name: AgriBackup Architecture Team
    url: https://agribackup.com
    email: contact@agribackup.com
  license:
    name: Proprietary
    url: https://agribackup.com/terms
  version: v1.0
servers:
  - url: https://live.agribackup.com
    description: Production (Mainnet)
  - url: https://sandbox.agribackup.com
    description: Sandbox (Testnet)
security: []
tags:
  - name: Enterprise Risk Management
  - name: Enterprise Clearance Webhooks
    description: Asynchronous status receivers for TRACES NT
  - name: Enterprise Jobs
    description: Query status and metrics of asynchronous compliance jobs
  - name: Enterprise Suppliers
  - name: Enterprise Diagnostics
    description: Monitor API health, consensus ledger, and satellite systems availability
  - name: Enterprise Suppliers
    description: Map internal ERP vendor IDs to EU Operator UUIDs
  - name: Enterprise Webhooks
    description: Register endpoints for asynchronous compliance events
  - name: Enterprise Archival
    description: Endpoints for bulk compliance archiving and auditor extensibility
  - name: Enterprise Logistics
    description: Smart contract linking of batches to logistics shipments
  - name: Enterprise Declarations
    description: DDS generation with legal land tenure proofs
  - name: Enterprise Batches
  - name: Enterprise API Keys
  - name: Enterprise Diagnostics
  - name: Enterprise Logistics
  - name: Enterprise Jobs
  - name: Enterprise Evidence
    description: Cryptographic evidence ledger anchored on Hedera Hashgraph
  - name: Enterprise Declarations
  - name: Enterprise Credentials
  - name: Enterprise Evidence
  - name: Enterprise Risk Management
    description: Pre-assessment of country risk and satellite deforestation probabilities
  - name: Enterprise Batches
    description: Programmatic batch ingestion and management
  - name: Enterprise Polygons
  - name: Introduction
  - name: Enterprise Polygons
    description: Programmatic polygon ingestion and verification
  - name: Enterprise Archival
  - name: Enterprise Credentials
    description: Programmatic ingestion of vault-secured enterprise secrets
  - name: Enterprise API Keys
    description: Endpoints for managing B2B API Keys (Requires standard JWT login)
  - name: Enterprise Webhooks
paths:
  /api/v1/enterprise/eudr/webhooks/dlq/replay-bulk:
    post:
      tags:
        - Enterprise Webhooks
      summary: Replay multiple DLQ messages to the primary exchange
      operationId: replayBulkDlqMessages
      parameters:
        - name: startDate
          in: query
          required: false
          schema:
            type: string
        - name: endDate
          in: query
          required: false
          schema:
            type: string
        - name: eventType
          in: query
          required: false
          schema:
            type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/WebhookDlqBulkRequest'
      responses:
        '200':
          description: OK
          headers:
            X-RateLimit-Limit:
              description: >-
                The maximum number of requests you're permitted to make per
                hour.
              schema:
                type: integer
                format: int32
            X-RateLimit-Remaining:
              description: >-
                The number of requests remaining in the current rate limit
                window.
              schema:
                type: integer
                format: int32
            X-RateLimit-Reset:
              description: >-
                The time at which the current rate limit window resets in UTC
                epoch seconds.
              schema:
                type: integer
                format: int32
      security:
        - ApiKeyAuth: []
      x-codeSamples:
        - lang: Python
          source: >-
            import agribackup

            from agribackup.rest import ApiException


            # Initialize Client

            configuration =
            agribackup.Configuration(host="https://live.agribackup.com/api/v1")

            configuration.api_key['ApiKeyAuth'] = 'sk_live_YOUR_API_KEY'


            with agribackup.ApiClient(configuration) as api_client:
                try:
                    api_instance = agribackup.EnterpriseWebhooksApi(api_client)
                    response = api_instance.replay_bulk_dlq_messages()
                    print(response)
                except ApiException as e:
                    print("Exception when calling API: %s\n" % e)
        - lang: Node.js
          source: |-
            import { AgriBackupClient } from '@agribackup/sdk';

            // Initialize Client
            const client = new AgriBackupClient({
              apiKey: 'sk_live_YOUR_API_KEY',
              baseUrl: 'https://live.agribackup.com/api/v1'
            });

            async function execute() {
              try {
                const response = await client.webhooks.replayBulkDlqMessages();
                console.log(response);
              } catch (error) {
                console.error(error);
              }
            }
        - lang: Java
          source: |-
            import com.agribackup.client.*;
            import com.agribackup.client.api.*;
            import com.agribackup.client.model.*;

            public class Example {
                public static void main(String[] args) {
                    ApiClient defaultClient = Configuration.getDefaultApiClient();
                    defaultClient.setBasePath("https://live.agribackup.com/api/v1");
                    defaultClient.setApiKey("sk_live_YOUR_API_KEY");

                    EnterpriseWebhooksApi apiInstance = new EnterpriseWebhooksApi(defaultClient);
                    try {
                        Object result = apiInstance.replayBulkDlqMessages();
                        System.out.println(result);
                    } catch (ApiException e) {
                        System.err.println("Exception when calling API: " + e.getResponseBody());
                    }
                }
            }
        - lang: C#
          source: |-
            using System;
            using System.Threading.Tasks;
            using AgriBackup.SDK.Api;
            using AgriBackup.SDK.Client;
            using AgriBackup.SDK.Model;

            class Program {
                static async Task Main() {
                    Configuration config = new Configuration();
                    config.BasePath = "https://live.agribackup.com/api/v1";
                    config.AddApiKey("ApiKeyAuth", "sk_live_YOUR_API_KEY");

                    var apiInstance = new EnterpriseWebhooksApi(config);
                    try {
                        var result = await apiInstance.ReplayBulkDlqMessagesAsync();
                        Console.WriteLine(result);
                    } catch (ApiException e) {
                        Console.WriteLine("Exception when calling API: " + e.Message);
                    }
                }
            }
components:
  schemas:
    WebhookDlqBulkRequest:
      required:
        - eventIds
      type: object
      properties:
        eventIds:
          type: array
          description: List of event IDs to process
          example:
            - evt_123
            - evt_456
          items:
            type: string
            description: List of event IDs to process
            example: '["evt_123","evt_456"]'
      description: Request payload for bulk DLQ operations
  securitySchemes:
    ApiKeyAuth:
      type: apiKey
      description: Enterprise API Key provided via the AgriBackup developer console.
      name: X-API-Key
      in: header

````