JMS

BindingsCollection.JMS registers server, channel, and message binding parsers.

Write

Attach a destination definition to the channel model:

using System.Collections.Generic;
using ByteBard.AsyncAPI.Bindings.JMS;
using ByteBard.AsyncAPI.Models;

var channel = new AsyncApiChannel();
channel.Bindings.Add(new JMSChannelBinding
{
    Destination = "orders",
    DestinationType = "queue",
});

var server = new AsyncApiServer();
server.Bindings.Add(new JMSServerBinding
{
    JmsConnectionFactory = "ConnectionFactory",
    ClientID = "worker",
    Properties = new List<JMSProperty>
    {
        new() { Name = "enabled", Value = new AsyncApiAny(false) },
        new() { Name = "priority", Value = new AsyncApiAny(3) },
        new() { Name = "region", Value = new AsyncApiAny("west") },
    },
});

var message = new AsyncApiMessage();
message.Bindings.Add(new JMSMessageBinding
{
    Headers = new AsyncApiJsonSchemaReference("#/components/schemas/jmsHeaders"),
});

Read and use

Register JMS parsers and read back the typed channel binding and its destination:

using ByteBard.AsyncAPI;
using ByteBard.AsyncAPI.Bindings;
using ByteBard.AsyncAPI.Bindings.JMS;
using ByteBard.AsyncAPI.Models;
using ByteBard.AsyncAPI.Readers;

var settings = new AsyncApiReaderSettings { Bindings = BindingsCollection.JMS };
var parsed = new AsyncApiStringReader(settings).ReadFragment<AsyncApiChannel>("""
    bindings:
      jms:
        destination: orders
        destinationType: queue
    """, AsyncApiVersion.AsyncApi3_0, out var diagnostics);

if (parsed.Bindings.TryGetValue<JMSChannelBinding>(out var jms))
{
    Console.WriteLine(jms.Destination);
}

var parsedServer = new AsyncApiStringReader(settings).ReadFragment<AsyncApiServer>("""
    bindings:
      jms:
        jmsConnectionFactory: ConnectionFactory
        properties:
          - name: enabled
            value: false
          - name: priority
            value: 3
    """, AsyncApiVersion.AsyncApi3_0, out diagnostics);
if (parsedServer.Bindings.TryGetValue<JMSServerBinding>(out var jmsServer))
{
    var enabled = jmsServer.Properties[0].Value.GetValue<bool>();
    var priority = jmsServer.Properties[1].Value.GetValue<decimal>();
    Console.WriteLine($"{enabled}, {priority}");
}

var parsedMessage = new AsyncApiStringReader(settings).ReadFragment<AsyncApiMessage>("""
    bindings:
      jms:
        headers:
          $ref: '#/components/schemas/jmsHeaders'
    """, AsyncApiVersion.AsyncApi3_0, out diagnostics);
if (parsedMessage.Bindings.TryGetValue<JMSMessageBinding>(out var jmsMessage)
    && jmsMessage.Headers is AsyncApiJsonSchemaReference headersReference)
{
    Console.WriteLine(headersReference.Reference.Reference);
}

Server metadata: JmsConnectionFactory, ClientID, and Properties (IList<JMSProperty>; each has Name and AsyncApiAny Value). Read JSON-typed property values with Value.GetValue<T>(). Channel metadata: Destination and DestinationType strings. Message metadata: Headers (AsyncApiJsonSchema), which accepts inline schemas or AsyncApiJsonSchemaReference values.

The collection also supports server (JMSServerBinding) and message (JMSMessageBinding) bindings on their respective elements. Destination type and property values are not broker-validated by these models.