Skip to content

[Messenger] Looks like default retry_strategy drops my messages in RabbitMQ queue. And i can't cancel it. #34461

Closed
@dvc

Description

@dvc

Symfony version(s) affected: v4.3.8

Description

# 
framework:
    messenger:
        transports:
            sync: 'sync://'
            async: '%env(MESSENGER_TRANSPORT_DSN)%'
        routing:
            App\Message\Event\TestEvent: async
        default_bus: bus
        buses:
            bus:

RabbitMQ "messages" exchange is fanout by default. All RabbitMQ entities created by Symfony Messenger.

Actual

After last symfony update (v4.3.4 to v4.3.8) my messages drops from queue after 1-2 seconds. It's very very bad defaults!

And i have no idea, how to cancel this angry helper. It's always active with very small TTL.

Expected

IMHO retry policy must check connect with RabbitMQ, not delivery to subscriber(s). My consumer can't use persistent connect and gets messages by cron.

Additional context

publish some messages (no active consumers in queue):

image

after couple of seconds:

image

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions