TsgcWSPClient_STOMP_RabbitMQ › Methods › SubscribeEx
Low-level SUBSCRIBE with a full RabbitMQ destination string supplied by the caller.
procedure SubscribeEx(const aDestination: String; const aDurable: Boolean = True; const aAutoDelete: Boolean = False; const aExclusive: Boolean = False; const aACK: TsgcSTOMPACK = ackAuto; const aOptions: TsgcWSRabbitMQSTOMP_Queue_Options = nil);| Name | Type | Description |
|---|---|---|
aDestination | const String | Raw RabbitMQ STOMP destination, e.g. /topic/prices, /queue/orders, /amq/queue/legacy, /temp-queue/reply or /exchange/amq.topic/stock.*. |
aDurable | const Boolean | If True (default), declares a durable subscription queue that survives a broker restart. |
aAutoDelete | const Boolean | If True, the subscription queue is deleted automatically when the last consumer disconnects. |
aExclusive | const Boolean | If True, the subscription queue is restricted to the current connection and deleted on disconnect. |
aACK | const TsgcSTOMPACK | Acknowledgement mode: ackAuto, ackClient or ackClient-Individual. |
aOptions | const TsgcWSRabbitMQSTOMP_Queue_Options | Optional RabbitMQ x-arguments. When nil the component Queue property is used. |
SubscribeEx bypasses the prefix helpers and sends the destination exactly as provided, which is useful for custom RabbitMQ destinations (for example pre-built exchange bindings or vhost-scoped names). Prefer the prefix-specific helpers for standard cases.
sgcRabbitMQ.SubscribeEx('/exchange/logs/error.*', True, False, False, ackClient);