Shopware icon

Shopware

Shopware

Actions778

System Operations → Consume Messages

AI-generated

Overview

This node operation is designed to consume messages from a specified transport receiver in the Symfony Messenger system. It is useful in scenarios where you need to process messages asynchronously from a message queue or bus, such as handling background jobs, event-driven workflows, or inter-service communication within a Symfony application.

Use Case Examples

  1. Consuming messages from a specific transport receiver to process queued tasks.
  2. Batch processing messages with controlled batch size and interval to manage load.
  3. Using proxy and SSL options to securely connect to the message transport endpoint.

Properties

Name Meaning
Receiver The name of the transport in the messenger that should be processed. This determines which message queue or bus the node will consume messages from.
Request Options Additional settings to control the request behavior, including batching, SSL certificate validation, proxy usage, and timeout settings.

Output

JSON

  • messageId - The unique identifier of the consumed message.
  • status - The status of the message consumption process, e.g., success or failure.
  • payload - The content or data of the consumed message.

Dependencies

  • Requires connection to a Symfony Messenger transport system, typically via an API or message broker endpoint.

Troubleshooting

  • Ensure the receiver name is correctly specified and matches the configured transport in Symfony Messenger.
  • Check network connectivity and proxy settings if using a proxy.
  • Verify SSL certificates or enable 'Ignore SSL Issues' if encountering SSL validation errors.
  • Adjust timeout settings if requests are timing out before completion.

Links

Discussion