TsgcWSPClient_STOMP_RabbitMQ › Methods › SubscribeQueueOutside
Subscribes to a queue already declared outside STOMP (e.g. via AMQP) using the /amq/queue/name prefix.
procedure SubscribeQueueOutside(const aQueue: 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 |
|---|---|---|
aQueue | const String | Name of an existing AMQP queue declared outside the STOMP gateway (for example through the management UI or by a native AMQP client). The component builds the destination as /amq/queue/aQueue. |
aDurable | const Boolean | Informational flag forwarded as a header; the queue itself is not declared by this call. |
aAutoDelete | const Boolean | Informational flag forwarded as a header; the queue itself is not declared by this call. |
aExclusive | const Boolean | Informational flag forwarded as a header; the queue itself is not declared by this call. |
aACK | const TsgcSTOMPACK | Acknowledgement mode: ackAuto, ackClient or ackClient-Individual. When not ackAuto the application must call ACK or NACK for every received message. |
aOptions | const TsgcWSRabbitMQSTOMP_Queue_Options | Optional subscription-level x-arguments attached to the SUBSCRIBE frame. When nil the component Queue property is used. |
Use this method when the queue has been created by an AMQP client, the RabbitMQ management UI or a policy and must not be declared by the STOMP gateway. The queue must already exist before the SUBSCRIBE frame is sent; otherwise RabbitMQ returns an ERROR.
sgcRabbitMQ.SubscribeQueueOutside('legacy.orders');