mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-11 21:07:28 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(AMQP Trigger Node): Manual execution updated error reduced wait time (#10035)

Browse source 
Co-authored-by: Shireen Missi <94372015+ShireenMissi@users.noreply.github.com>
This commit is contained in:
Michael Kret 2024-07-12 17:56:30 +03:00 committed by GitHub
parent c4c25eadfd
commit f78f4ea349
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
packages/nodes-base/nodes/Amqp/AmqpTrigger.node.ts
View file

@ -276,11 +276,16 @@ export class AmqpTrigger implements INodeType {
connection.close();
reject(
new Error(
'Aborted, no message received within 30secs. This 30sec timeout is only set for "manually triggered execution". Active Workflows will listen indefinitely.',
new NodeOperationError(
this.getNode(),
'Aborted because no message received within 15 seconds',
{
description:
'This 15sec timeout is only set for "manually triggered execution". Active Workflows will listen indefinitely.',
},
),
);
}, 30000);
}, 15000);
container.on('message', (context: EventContext) => {
// Check if the only property present in the message is body
// in which case we only emit the content of the body property