Implement azure storage queues transport

Author: TraGicCode

src/BuslyCLI.Console/Factories/RawEndpointFactory.cs

@@ -49,7 +49,9 @@ private TransportDefinition CreateTransport(TransportConfig transportConfig)
 
     private TransportDefinition CreateAzureStorageQueuesTransport(string connectionString)
     {
-        return new AzureStorageQueueTransport(connectionString);
+        var transport = new AzureStorageQueueTransport(connectionString);
+        transport.MessageWrapperSerializationDefinition = new SystemJsonSerializer();
+        return transport;
     }
 
     private TransportDefinition CreateSqlServerTransport(SqlServerTransportConfig sqlServerTransportConfig)

tests/BuslyCLI.Console.Tests/EndToEnd/AzureStorageQueues/AzureStorageQueuesEndToEndTestBase.cs

@@ -10,6 +10,7 @@ public abstract class AzureStorageQueuesEndToEndTestBase : SingletonTestFixtureB
     protected override AzuriteContainer CreateContainer()
     {
         return new AzuriteBuilder()
+            .WithCommand("--skipApiVersionCheck")
             .Build();
     }
 

tests/BuslyCLI.Console.Tests/EndToEnd/Infrastructure/ITestEndpointFactory.cs

@@ -105,6 +105,8 @@ public async Task<TestEndpoint> CreateAzureStorageQueuesTestEndpoint(string conn
     {
         var name = GenerateUniqueEndpointName();
         var transport = new AzureStorageQueueTransport(connectionString);
+        transport.MessageWrapperSerializationDefinition = new SystemJsonSerializer();
+
         return await InternalCreateTestEndpoint(name, transport);
     }
 }

website/docs/transports/azure-storage-queues.md

@@ -0,0 +1,40 @@
+# Azure Storage Queues
+
+The **Azure Storage Queues Transport** is used to communicate to Azure Storage Queues. It is suitable for development, testing, and production environments.
+
+## Configuration
+
+To use the Azure Storage Queues Transport, define it under `transports` and reference it as `current-transport`.
+
+### Example
+
+```yaml
+current-transport: local-azure-service-bus
+
+transports:
+  - name: local-azure-service-bus
+    azure-storage-queues-transport-config:
+      connection-string: Endpoint=amqp://127.0.0.1:32799/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true
+```
+
+---
+
+## `azure-storage-queues-transport-config` Fields
+
+| Field               | Required | Type   | Default | Description                                |
+| ------------------- | -------- | ------ | ------- | ------------------------------------------ |
+| `connection-string` | **Yes**  | string | —       | Connection string to Azure Storage Queues. |
+
+---
+
+## Field Details
+
+### `connection-string` (required)
+
+A standard conection string for Azure Storage Queues.
+
+Examples:
+
+```yaml
+connection-string: UseDevelopmentStorage=true
+```