Queue

00Overview

Run an Oracle Cloud message queue straight from a flow — create and configure queues, then put messages onto them and consume them in batches, extend or shorten how long a consumed message stays hidden, and delete messages once they are handled. Read queue and dead-letter statistics, list channels, purge a queue, and move queues between compartments. Because queue changes happen asynchronously, the node also lets you follow work requests until each operation finishes.

Every field below is exactly what you see in the Flomation editor. Fields marked ● live picker let you choose from a list pulled live from your account — no IDs to look up.

01Connecting Queue

1. The Authentication dropdown offers two paths. Choose Connect Oracle Cloud to pick a managed Oracle Cloud connection an admin has already set up — Flomation supplies the signing details for you. Choose API signing key (advanced) to enter the credentials by hand, as described below.
2. In the OCI Console, open the profile menu (top-right) → My profile, then under Resources choose API keys → Add API key. Let OCI generate a key pair and download the private key, or upload your own public key.
3. From the Configuration file preview OCI shows after the key is added, copy the values into the node's Tenancy OCID, User OCID, Region (a plain identifier such as uk-london-1) and Key Fingerprint fields.
4. Set Compartment OCID to the compartment that holds (or will hold) your queues — it is required to create or list queues and scopes the other actions.
5. Store the downloaded PEM as a Flomation environment secret (e.g. queue_secret) and select it in the node's Private Key (PEM) field; add a Private Key Passphrase secret only if the key is encrypted.

02Get

OCI Queue: Get Stats

oracle/queue/get_stats · Action

Read the message statistics for a queue — visible and in-flight message counts and size in bytes — for the queue, its dead-letter queue, and optionally one channel.

Returns: tool_result, stats, channel_id, success, error

03List

OCI Queue: List Channels

oracle/queue/list_channels · Action

List the non-empty channels of a queue. Supply the queue OCID and an optional channel-name filter; the queue's endpoint is resolved automatically.

Returns: tool_result, channels, count, truncated, success, error

04Message

OCI Queue: Delete Message

oracle/queue/message_delete · Action

Delete a single message from a queue using the receipt returned by a prior Get Messages call.

Returns: tool_result, success, error

OCI Queue: Delete Messages

oracle/queue/message_delete_batch · Action

Delete several messages from a queue at once. Supply the queue OCID and a comma-separated list of receipts; the queue's endpoint is resolved automatically.

Returns: tool_result, server_failures, client_failures, results, count, success, error

OCI Queue: Get Messages

oracle/queue/message_get · Action

Consume a batch of messages from a queue. Each message includes a receipt token for deleting it or updating its visibility; the queue's endpoint is resolved automatically.

Returns: tool_result, messages, count, success, error

OCI Queue: Put Message

oracle/queue/message_put · Action

Put a message onto a queue. Supply the queue OCID and the message content; the queue's endpoint is resolved automatically.

Returns: tool_result, id, expire_after, results, success, error

OCI Queue: Update Message

oracle/queue/message_update · Action

Extend or shorten a message's visibility timeout. Supply the queue OCID, the message receipt, and the new visibility in seconds relative to now.

Returns: tool_result, id, visible_after, success, error

OCI Queue: Update Messages (Batch)

oracle/queue/message_update_batch · Action

Update the visibility of several in-flight messages at once. Supply the queue OCID and a JSON array of entries, each with a message receipt and a new visibility timeout in seconds.

Returns: tool_result, server_failures, client_failures, results, count, success, error

05Queue

OCI Queue: Move Queue to Compartment

oracle/queue/queue_change_compartment · Action

Move a queue into a different compartment. Returns a work-request id — the move completes asynchronously.

Returns: tool_result, id, destination_compartment_id, work_request_id, success, error

OCI Queue: Create Queue

oracle/queue/queue_create · Action

Create a queue. Set an optional retention, visibility timeout and dead-letter delivery count. Returns the queue in a CREATING state plus a work-request id — poll Get Queue until ACTIVE.

Returns: tool_result, queue, id, lifecycle_state, work_request_id, success, error

OCI Queue: Delete Queue

oracle/queue/queue_delete · Action

Delete a queue by its OCID. Asynchronous — returns a work-request id while the queue moves to DELETING then DELETED.

Returns: tool_result, id, work_request_id, success, error

OCI Queue: Get Queue

oracle/queue/queue_get · Action

Fetch a queue by OCID. Returns its lifecycle state, settings and messages endpoint.

Returns: tool_result, queue, id, lifecycle_state, messages_endpoint, success, error

OCI Queue: List Queues

oracle/queue/queue_list · Action

List the queues in a compartment. Optionally filter by queue OCID, exact display name or lifecycle state. Walks pagination up to a safe cap.

Returns: tool_result, queues, count, truncated, success, error

OCI Queue: Purge Queue

oracle/queue/queue_purge · Action

Delete messages from a queue — the normal queue, the dead-letter queue, or both, optionally scoped to specific channels. Returns a work-request id to poll.

Returns: tool_result, id, work_request_id, success, error

OCI Queue: Update Queue

oracle/queue/queue_update · Action

Partially update a queue — change any of its display name, visibility timeout, long-poll timeout, dead-letter delivery count, channel consumption limit or freeform tags. Returns the queue in an UPDATING state plus a work-request id — poll Get Queue until ACTIVE.

Returns: tool_result, id, lifecycle_state, work_request_id, success, error

06Work

OCI Queue: List Work Request Errors

oracle/queue/work_request_errors_list · Action

List the errors recorded against a Queue work request, so you can see why an asynchronous create, update, delete or purge failed. Walks pagination up to a safe cap.

Returns: tool_result, errors, count, truncated, success, error

OCI Queue: Get Work Request

oracle/queue/work_request_get · Action

Fetch an OCI Queue work request by OCID — reports its operation type, status and completion percentage so you can poll an async queue operation until it finishes.

Returns: tool_result, work_request, status, percent_complete, success, error

OCI Queue: List Work Requests

oracle/queue/work_request_list · Action

List the asynchronous work requests in a compartment, with each one's operation type, status and progress. Walks pagination up to a safe cap.

Returns: tool_result, work_requests, count, truncated, success, error

OCI Queue: List Work Request Logs

oracle/queue/work_request_logs_list · Action

List the log messages recorded against a Queue work request, so you can follow the progress of an asynchronous create, update, delete or purge. Walks pagination up to a safe cap.

Returns: tool_result, logs, count, truncated, success, error

07Notes & Limitations

Behaviours and constraints worth knowing before you build with these nodes.

• Creating, updating, deleting, purging and moving a queue all run asynchronously and return a work-request id, so poll Get Work Request — or Get Queue for a queue's lifecycle state — until the operation settles before a later step relies on the result.
• Message actions such as Put Message and Get Messages only work once a queue reaches the ACTIVE state, because they target the queue's own messages endpoint, which is not published while the queue is still creating.
• A receipt returned by Get Messages stops working the moment the message's visibility timeout lapses and the message becomes available again, so delete or extend it before that window closes.
• Message content travels as plain text, so serialise structured payloads to JSON before putting them and parse them yourself after getting them.
• The listing actions walk pagination only up to an internal cap of 25 pages, so very large compartments or work-request histories can come back as a partial set flagged as truncated.
• The Region must be a plain OCI region identifier such as uk-london-1, not a full endpoint URL.