Error sending message to new transport from an EntityListener

[mbopp]

I'm using API Platform. I have many transports and many tests that work great. But after adding a new transport and implementing a test I am getting an error:

 TypeError: Zenstruck\Messenger\Test\Transport\TestTransport::isIntercepting(): Return value must be of type bool, null returned

Which seems to indicate that the new transport isn't found. Here are some of the details that cause this error ('hubspot_transport' is the name of the one that fails)

messenger.yaml

framework:
    messenger:
        reset_on_message: true
        default_bus: event.bus
        buses:
            event.bus:
                default_middleware: allow_no_handlers
                middleware:
                    - App\Messenger\AuditMiddleware

        failure_transport: failed

        transports:
            async_transport:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
            hubspot_transport:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                retry_strategy:
                    max_retries: 1
            failed: 'doctrine://default?queue_name=failed'

        routing:
            'App\Message\ActivityMessage': async_transport
            'App\Message\HubspotUpdateMessage': hubspot_transport

when@test:
    framework:
        messenger:
            transports:
              async_transport: 'test://'
              hubspot_transport: 'test://'


when@dev:
    framework:
        messenger:
            transports:
              async_transport: '%env(MESSENGER_TRANSPORT_DSN)%'
              hubspot_transport: '%env(MESSENGER_TRANSPORT_DSN)%'

relevant test code:

    $client = self::createClient();

    $messenger = $this->transport('hubspot_transport');

    // Error ONLY occurs when this statement exists.
    $messenger->resetAll(); 

    // This request produces error 
    $client->request('POST', '/api/authentication/token', [
      'headers' => ['Content-Type' => 'application/json'],
      'json' => [
        'username' => $username,
        'password' => $password,
      ],
    ]);

The login request alters a field on the user entity...

In my entity listener:

#[AsEntityListener(event: Events::preUpdate, method: 'preUpdate', entity: User::class)]
class UserListener
{
  public function __construct(
    private readonly MessageBusInterface $messageBus,
  ) {
  }

  public function preUpdate(User $user, PreUpdateEventArgs $event): void
  {
    $hubspotMessage = new HubspotUpdateMessage(HubspotUpdateType::CONTACT, $user->getId(), ['updating user']);
    $this->messageBus->dispatch($hubspotMessage); // <<< Error
  }
...
}

Please let me know if there is more info I can provide to help put a finger on what is happening here. Thank you so much for your help!

[nikophil]

Hello @mbopp

I think that if you use $messenger->reset() you won't have the problem.

nonetheless, there is a problem with resetAll() method: we're resetting $intercept and $catchExceptions to null, but isIntercepting() and isCatchingExceptions() must return false. @kbond WDYT?

[kbond]

I think that if you use $messenger->reset() you won't have the problem.

@mbopp, can you confirm this solves the problem?

I don't think resetAll should be used in userland - we should mark as internal. It should only be called in the test trait.

nonetheless, there is a problem with resetAll() method: we're resetting $intercept and $catchExceptions to null, but isIntercepting() and isCatchingExceptions() must return false.

I think the problem is an undefined array key (there's a warning but returns null). We should throw an exception here I think.

[mbopp]

Thanks for the quick response!

That fixed it! I'm very appreciative! This is a fantastic utility.

[Norbytus]

Hi, i have error in similar situation with EntityEvents

TypeError: Zenstruck\Messenger\Test\Transport\TestTransport::isRetriesDisabled(): Return value must be of type bool, null returned```

[kbond]

@Norbytus I just released 1.11.1 that, while doesn't necessarily fix the issue, it throws an LogicException when enchanting your issue. I'm hoping the stack trace could help determine the cause.

Are you using TestTransport::resetAll() anywhere?

[Norbytus]

resetAll

No, but i fix this error call transport()->reset() in setUp