Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

AMQP Trigger randomly stops processing Service Bus Queue (critical bug) #13452

Open
erictmnz opened this issue Feb 23, 2025 · 1 comment
Open
Labels
in linear Issue or PR has been created in Linear for internal review

Comments

@erictmnz
Copy link

Describe the problem/error/question

We currently have an AMQP Trigger that is subscribed to our system Azure Service Bus queue for n8n to pick up events to process.
We recently encountered a number of other issues with AMQP nodes but this is the most critical:

For no apparent reason the trigger will stop to process events. (ie n8n or database or service bus services are not interrupted according to logs and there are no errors being logged)
This is critical since it stops critical event-based workflows to be executed.

When the workflow is de-activated and re-activated the events (thousands of them) get processed again immediately.
This might not be version dependent but the first time this was observed was on 1.78+

What is the error message (if any)?

None - checked all logs available including log stream and console / system logs.

Please share your workflow/screenshots/recording

{
  "nodes": [
    {
      "parameters": {
        "sink": "n8n-queue",
        "clientname": "n8n",
        "subscription": "n8n-queue",
        "options": {
          "jsonConvertByteArrayToString": true,
          "jsonParseBody": true,
          "parallelProcessing": true,
          "reconnect": true,
          "reconnectLimit": 500,
          "sleepTime": 100
        }
      },
      "id": "f0f8a0cd-bccb-4990-96d2-81facef15906",
      "name": "AMQP Trigger",
      "type": "n8n-nodes-base.amqpTrigger",
      "typeVersion": 1,
      "position": [
        320,
        900
      ],
      "credentials": {
        "amqp": {
          "id": "fKMAfyK06t8BlD5m",
          "name": "AMQP n8n queue account"
        }
      }
    }
  ],
  "connections": {
    "AMQP Trigger": {
      "main": [
        []
      ]
    }
  },
  "pinData": {},
  "meta": {
    "instanceId": "14af224ec8b33a40192e4e423c7b86e29199c7e603fa98f21a1ac6a499c1a355"
  }
}

Debug info

core

  • n8nVersion: 1.79.2
  • platform: npm
  • nodeJsVersion: 20.18.2
  • database: postgres
  • executionMode: regular
  • concurrency: 3
  • license: enterprise (production)

storage

  • success: all
  • error: all
  • progress: false
  • manual: true
  • binaryMode: memory

pruning

  • enabled: true
  • maxAge: 4032 hours
  • maxCount: 0 executions

client

  • userAgent: mozilla/5.0 (windows nt 10.0; win64; x64) applewebkit/537.36 (khtml, like gecko) chrome/133.0.0.0 safari/537.36
  • isTouchDevice: false

Generated at: 2025-02-23T22:30:09.150Z}

@Joffcom
Copy link
Member

Joffcom commented Feb 23, 2025

Hey @erictmnz,

We have created an internal ticket to look into this which we will be tracking as "GHC-936"

@Joffcom Joffcom added the in linear Issue or PR has been created in Linear for internal review label Feb 23, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
in linear Issue or PR has been created in Linear for internal review
Projects
None yet
Development

No branches or pull requests

2 participants