RabbitMQ Endpoint

Support queue and exchange based message tracking and correlation.

Routing

Bind to routing keys and queue names for targeted consumption. RabbitMQ produce mode requires queueName or routingKey (exchange alone is not sufficient).

Client Properties

Use ClientProperties dictionary to attach custom RabbitMQ connection metadata for tracing, tenancy, or environment tagging.

Feature Usage Samples

How to use snippets for RabbitMQ Endpoint.

Switch between C#, Java, Python, TypeScript, and JavaScript to see the native SDK shape for this sample.

Licensing note: every runnable sample requires a valid runner key via WithRunnerKey("...") or config key LoadStrike:RunnerKey.

RabbitMQ Endpoint

var endpoint = new RabbitMqEndpointDefinition
{
    Name = "rabbit-out",
    Mode = TrafficEndpointMode.Consume,
    TrackingField = TrackingFieldSelector.Parse("json:$.trackingId"),
    HostName = "localhost",
    UserName = "guest",
    Password = "guest",
    QueueName = "orders.completed"
};

import com.loadstrike.runtime.LoadStrikeCorrelation.TrackingFieldSelector;
import com.loadstrike.runtime.LoadStrikeTransports;
import com.loadstrike.runtime.RabbitMqEndpointDefinition;

var endpoint = new RabbitMqEndpointDefinition();
endpoint.name = "rabbit-out";
endpoint.mode = LoadStrikeTransports.TrafficEndpointMode.Consume;
endpoint.trackingField = TrackingFieldSelector.parse("json:$.trackingId");
endpoint.hostName = "localhost";
endpoint.userName = "guest";
endpoint.password = "guest";
endpoint.queueName = "orders.completed";

from loadstrike_sdk import RabbitMqEndpointDefinition, TrackingFieldSelector

endpoint = RabbitMqEndpointDefinition(
    name="rabbit-out",
    mode="Consume",
    tracking_field=TrackingFieldSelector.parse("json:$.trackingId"),
    host_name="localhost",
    user_name="guest",
    password="guest",
    queue_name="orders.completed",
)

import { RabbitMqEndpointDefinition, TrackingFieldSelector } from "@loadstrike/loadstrike-sdk";

const endpoint = new RabbitMqEndpointDefinition({
  name: "rabbit-out",
  mode: "Consume",
  trackingField: TrackingFieldSelector.parse("json:$.trackingId"),
  hostName: "localhost",
  userName: "guest",
  password: "guest",
  queueName: "orders.completed"
});

const { RabbitMqEndpointDefinition, TrackingFieldSelector } = require("@loadstrike/loadstrike-sdk");

const endpoint = new RabbitMqEndpointDefinition({
  name: "rabbit-out",
  mode: "Consume",
  trackingField: TrackingFieldSelector.parse("json:$.trackingId"),
  hostName: "localhost",
  userName: "guest",
  password: "guest",
  queueName: "orders.completed"
});

Body Example

HostName

Specifies the RabbitMQ broker host the adapter should connect to.

UserName / Password

Provide broker credentials when the queue is protected.

QueueName

Specifies the queue used for produce or consume mode.

TrackingField

Points to the header or body field that carries the correlation id.

{ "trackingId": "trk-1" }

Diagram

RabbitMQ endpoint diagram — Exchange and queue flows can be correlated with header or body based tracking selectors.