Skip to content

Commit

Permalink
fix(AMQP Trigger Node): Manual execution updated error reduced wait t…
Browse files Browse the repository at this point in the history
…ime (n8n-io#10035)

Co-authored-by: Shireen Missi <94372015+ShireenMissi@users.noreply.github.com>
  • Loading branch information
michael-radency and ShireenMissi authored Jul 12, 2024
1 parent c4c25ea commit f78f4ea
Showing 1 changed file with 8 additions and 3 deletions.
11 changes: 8 additions & 3 deletions packages/nodes-base/nodes/Amqp/AmqpTrigger.node.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit f78f4ea

Please sign in to comment.