Create new message queue

Hello,

I have faced the situation where it is needed to create a separate cron task to be run independently from others strictly each minute so it would not depend on the system potential high load.

I have already tried increasing message consumers number but it did not As I can see there is just one queue ‘oro.default’ by default. Is it pretty clear how to set up a consumer to process a specific queue, but I have not found any examples/docs about multi-queueing and its using.

Could you please contribute with a new message queue creation/configuration?

Thank you.

Topic

[irina.k.melnikovaParticipant]

Correction: I have already tried increasing message consumers number but it did not solve the problem.

[Andrey YatsenkoModerator]

The ‘oro:message-queue:consume’ command apply an argument:
‘clientDestinationName’ – Queues to consume messages from,
I never tested this feature on Community Edition but this should work. The idea is that you can run the consumer that will work only on messages sent to a specific destination.

While registering processor in DI you can add destinationName to it as a param.

YAML

- { name: 'oro_message_queue.client.message_processor', destinationName: my_custom_destination }

1	- { name: 'oro_message_queue.client.message_processor', destinationName: my_custom_destination }

Then you can run separately consumers for default destination and for my_custom_destination

YAML

app/console oro:message-queue:consume default -vv --env=prod app/console oro:message-queue:consume my_custom_destination -vv --env=prod

1 2	app/console oro:message-queue:consume default -vv --env=prod app/console oro:message-queue:consume my_custom_destination -vv --env=prod

As a result consumer for custom_destination will work independently from default one.

[irina.k.melnikovaParticipant]

Thank you so much! It is exactly what I was looking for.

[Author]

Replies