aymdev/messenger-azure-bundle

Symfony Messenger bundle for Azure Service Bus

Installs: 102 726

Dependents: 1

Suggesters: 0

Security: 0

Stars: 10

Watchers: 2

Forks: 7

Open Issues: 6

Type:symfony-bundle

v2.0.0 2024-02-14 21:09 UTC

This package is auto-updated.

Last update: 2024-10-14 22:28:33 UTC


README

A PHP 8.1+ & Symfony 5 / 6 / 7 bundle providing a Symfony Messenger transport for Azure Service Bus using the Azure REST API.

Testing Coding Standards Bundle installation Latest Stable Version License

Installation

You only need to install the bundle using Composer:

composer require aymdev/messenger-azure-bundle

As it uses Symfony HttpClient, you will need to install a PSR-18 client. Example:

composer require nyholm/psr7

Configuration

Transport DSN

Your DSN must respect the following format to build the authentication header for a specific namespace:

azure://KEY_NAME:KEY_VALUE@NAMESPACE

Where KEY_NAME is your shared access key name, KEY_VALUE is your shared access key and NAMESPACE is your Azure Service Bus namespace. Important note: the keys can contain special characters that could break the URL parsing. Be sure to URL encode them.

Transport options

Detailed list of transport options:

Example config/packages/messenger.yaml:

framework:
    messenger:
        transports:
            azure_transport:
                dsn: '%env(AZURE_SERVICE_BUS_DSN)%'
                serializer: 'App\Messenger\YourAzureSerializer'
                options:
                    entity_path: 'your-topic'
                    subscription: 'subscription-name'
                    token_expiry: 60
                    receive_mode: 'receive-and-delete'

Stamps

This transport provides a few stamps:

AzureMessageStamp

The AymDev\MessengerAzureBundle\Messenger\Stamp\AzureMessageStamp stamp is added to sent and received messages and contains:

  • the topic or queue name
  • the original sent/received message
  • the subscription name for received messages from topics
  • the delete URL for received messages in peek-lock receive mode

AzureBrokerPropertiesStamp

The AymDev\MessengerAzureBundle\Messenger\Stamp\AzureBrokerPropertiesStamp stamp is used for the message properties. It is automatically decoded when consuming a message and is encoded when producing a message if added to the envelope.

Serialization

Creating your serializers

There is no serializer provided, but here is the expected array structure of an encoded envelope:

  • body: your plain text message
  • headers: optional HTTP headers (either received from Azure Service Bus response or to send to the REST API)

Logging decoding errors

When a serializer throws a Symfony\Component\Messenger\Exception\MessageDecodingFailedException while decoding a message, it will be converted to a AymDev\MessengerAzureBundle\Messenger\Exception\SerializerDecodingException which contains an envelope with an empty message but with the same stamps as a successfully decoded message.

You can then listen to the console.error Symfony event and get the topic/queue name where then decoding failure happened, the original message, etc.