redb.Route.IbmMq 2.0.2

redb.Route.IbmMq

IBM MQ (WebSphere MQ) transport for redb.Route ESB framework. Native MQI access via IBMMQDotnetClient — queues, topics, transactions, RPC, message groups, SSL/TLS, and W3C telemetry.

Installation

dotnet add package redb.Route.IbmMq

Quick Start

services.AddRedbRoute(route =>
{
    route.Services.AddRedbRouteIbmMq();
    route.AddRouteBuilder<MyRoutes>();
});

public class MyRoutes : RouteBuilder
{
    public override void Configure()
    {
        From("wmq:DEV.QUEUE.1?host=mq-host&queueManager=QM1&channel=DEV.APP.SVRCONN")
            .Log("Received: ${body}")
            .To("wmq:ORDERS.OUT?host=mq-host&queueManager=QM1&channel=DEV.APP.SVRCONN");
    }
}

URI Format

wmq:{destination}?{options}

{destination} — queue or topic name (e.g. DEV.QUEUE.1, EVENTS/ORDER).

Fluent DSL

// Queue (point-to-point)
From(Wmq.Queue("DEV.QUEUE.1")
    .Host("mq-host")
    .QueueManager("QM1")
    .Channel("DEV.APP.SVRCONN")
    .User("app")
    .Password("passw0rd"))

// Topic (pub/sub)
From(Wmq.Topic("EVENTS/ORDER")
    .Host("mq-host")
    .QueueManager("QM1")
    .ConcurrentConsumers(4))

// Persistent send with JMS interop
To(Wmq.Queue("ORDERS.OUT")
    .Host("mq-host")
    .Persistent()
    .TargetClient(IbmMqTargetClient.Jms))

// Transacted
From(Wmq.Queue("TXN.QUEUE")
    .Host("mq-host")
    .Transacted())

// RPC (request/reply)
To(Wmq.Queue("RPC.SERVICE")
    .Host("mq-host")
    .ReplyTo()
    .Timeout(10))

// SSL/TLS
From(Wmq.Queue("SECURE.QUEUE")
    .Host("mq-host")
    .SslCipherSpec("TLS_RSA_WITH_AES_256_CBC_SHA256")
    .SslKeyRepository("/var/mqm/ssl/key"))

Options Reference

Connection

Destination

Consumer

Producer

Transactions

RPC

Dead Letter

SSL/TLS

Advanced

Headers

All IBM MQ metadata headers are prefixed with redbIbmMq.:

• redbIbmMq.MsgId — message ID (hex)
• redbIbmMq.CorrelId — correlation ID (hex)
• redbIbmMq.Format — MQMD format
• redbIbmMq.Persistence — persistence flag
• redbIbmMq.Priority — priority
• redbIbmMq.Expiry — expiry
• redbIbmMq.ReplyToQueue — reply-to queue
• redbIbmMq.MsgType — message type
• redbIbmMq.BackoutCount — backout count
• ... and more (see IbmMqHeaders class)

Telemetry

W3C distributed tracing is automatically propagated via MQRFH2 user properties (traceparent, tracestate). OpenTelemetry tags:

• messaging.system = ibmmq
• messaging.operation = receive / publish
• messaging.destination.name = queue/topic name
• messaging.ibmmq.queue_manager = QM name
• messaging.message.id = MQMD MsgId

Docker (Dev/Test)

docker compose -f docker-compose.tests.yml up -d ibmmq

Default dev credentials:

• Host: localhost:1414
• Queue Manager: QM1
• Channel: DEV.APP.SVRCONN
• User: app / passw0rd
• Web Console: https://localhost:9443/ibmmq/console (admin / passw0rd)

Pre-created queues: DEV.QUEUE.1 … DEV.QUEUE.5, DEV.DEAD.LETTER.QUEUE.