Memory Queue integration

What the Memory Queue package does

Provides a FIFO (First-In-First-Out) queue system utility, enabling efficient and reliable task management and processing, essential for streamlined operations in various applications.

In-memory concurrent FIFO queue system for passing data between flow nodes. Supports creating named queues with optional initial elements, enqueueing/dequeueing arbitrary values (strings, numbers, objects), clearing all elements, and deleting queues. Queues are identified by UUID and persist in robot memory for the duration of the flow execution. No authentication required.

Namespace

Robomotion.MemoryQueue

Latest version

0.2.0 (7 versions published)

Written in

Go

Categories

Dev Tools

Memory Queue nodes (6)

These are the node IDs an agentic flow or an RPA bot uses, exactly as they appear in the Flow Designer and in flow code. An agent tool node can also be called by an AI agent on its own. The Toolkit node hands an agent several of the package operations at once.

Platforms

The Memory Queue package runs on Windows, macOS and Linux robots. Any Robomotion robot on these operating systems can run a flow that uses it.

How to install the Memory Queue package

1. Open Packages in the Robomotion Flow Designer.
2. Search for Memory Queue or Robomotion.MemoryQueue, then click Install on its card.
3. The Memory Queue nodes appear in the node palette for everyone in the workspace, because installation is per workspace.

From a terminal, the Robomotion CLI installs the same package:

robomotion install Robomotion.MemoryQueue

Templates that use Memory Queue

12 ready-made templates use Memory Queue nodes in their flows. Open one to start from a working flow.

• Bank Reconciliation

  Takes the payments and receipts the ERP could not reconcile and confirms each one against the real bank statement. It pulls the ERP's flagged paid-bill exceptions and open invoices awaiting cash, then signs in to the bank, searches the operating account by reference and reads what actually settled - quantifying the four ways money and ledger drift apart: a missing payment, a transposed amount, a double payment and unapplied cash. Writes a reconciliation CSV. The story is evidence: the ledger raises the question, the bank statement answers it, and every discrepancy comes out with a number attached.

• Logistics Exception Center

  Builds one worklist of every active delivery exception from the carrier, then dedupes it against the systems that may already be handling it - the mailbox that was notified, and the help desk where a ticket may already exist. Joining the three on the tracking number tells the robot which exceptions were mailed, which already have a ticket, and which nobody has picked up yet. Writes a consolidated exception CSV. The story is consolidation: three systems each hold part of the picture, and the robot joins them so a stuck shipment is neither missed nor double-worked.

• Bulk Shipment Tracking Sweep

  Checks 200 shipment tracking numbers on a public carrier tracker using eight parallel workers pulling from a shared in-memory queue. Reads the tracking list straight from the carrier's bulk page, scrapes status, latest event and ETA for each shipment, and writes a full status CSV plus an exceptions-only CSV covering customs holds, failed deliveries and delays. No login required.

• Clinic Eligibility Morning Run

  Verifies insurance for every appointment on a clinic's eligibility worklist, running the payer checks on nine parallel browsers instead of one at a time. Signs in, reads the worklist, fans out into workers that each claim an appointment from a shared queue, click its eligibility check and read the coverage answer. Writes a full status CSV plus a coverage-problems CSV listing the lapsed and not-covered patients the front desk has to chase.

• Denial Worklist Triage

  Works a clinic's denied insurance claims, choosing a different action for each denial code: fix and resubmit the ones missing a field the chart already has, write off what the payer will never cover, void duplicates of already-paid claims, and escalate the ones that need a human to call the payer. Waits for the resubmitted claims to be re-adjudicated, then reads each claim's real status back off the table and writes denial-actions.csv.

• E-Invoice Portal Harvest

  Downloads every e-invoice for a tax period from a government portal and builds an index spreadsheet of what was collected. Signs in with a one-time code, walks the paged register until the portal says there are no more pages, then opens each document to read its government reference number and pull down both the XML and the PDF. Every download is gated behind a confirmation dialog and an "I am not a robot" checkbox.

• Invoice Inbox to Ledger

  Reads vendor-invoice e-mails out of the mailbox and posts each one as a bill in the ERP. It reads the vendor, reference, gross and purchase-order number from each message, derives the net, and keys a new bill - handling the two controls that fire mid-batch: a duplicate reference (cancelled rather than paid twice) and a failed 3-way match against the purchase order (posted but blocked). Writes a posting report. The story is straight-through processing with judgment: the clean invoices post themselves, and the two that should not go through are caught and reported.

• Leave Request Policing

  Processes the pending leave requests in an HR system by policy: approves the ones that are clean and denies the ones that break a rule - an insufficient balance, an overlap with a teammate already off, or a request inside the month-end blackout - writing the reason into the required comment box. Brings only the edge cases to a human. Writes a decision CSV.

• Refund Request Triage

  Verifies customer refund requests against the bank before approving them. Signs in to AcmeBank through two-factor, pulls every shipment charge from the operating account and groups them by reference; then works the helpdesk's refund queue, and for each ticket looks up the disputed charge to decide whether the customer was really billed twice. Approves the genuine duplicates and escalates the rest to a human with evidence. Writes a decision CSV.

• Tax Portal ERP Reconciliation

  Reconciles the e-invoices a government tax portal received against the vendor bills booked in the ERP, and reports the three ways the two can disagree: an amount that drifted, an e-invoice with no matching bill (arrived in the portal, never booked), and a bill with no e-invoice (booked, never filed). Two-factor signs in to the portal, pages the received register, then filters the ERP vendor-bill worklist per enrolled vendor to compare counts. Writes a reconciliation CSV. The story is a control: two systems that should hold the same set of documents, checked against each other so a gap is caught rather than discovered at audit.

• Tax Portal Morning Board

  Checks every client mandate on a government tax portal and builds one status board. Signs in as an authorised representative, reads all the mandates, then switches the active company for each and reads its dashboard - unread official notices, open penalties and upcoming deadlines. Flags any client with a penalty, an audit request or a late filing, and writes a board sorted worst first. Built for accountants and agencies watching many companies at once.

• Fork Branch With Memory Queue

  Demonstrates parallel browser automation using Fork Branch and Memory Queue. Creates multiple concurrent browser instances that dequeue items from a shared queue, navigate to e-commerce websites, and take screenshots simultaneously.

Related integrations

Packages that share a category or keywords with Memory Queue. It is filed under Dev Tools.

• Apache KafkaConnect to Apache Kafka to produce and consume messages，manage topics，and work with consumer groups
• RabbitMQConnect to RabbitMQ message broker to publish and consume messages, manage queues and exchanges
• Agent ToolsComprehensive toolset for AI agents to perform file operations，code editing，web research，and task management across platforms.
• AlgoliaSearch and manage Algolia indices and records
• ApifyRun Apify Actors, get dataset items, and automate web scraping workflows
• AppsServe a Robomotion App from a flow - one trigger per app action, with progress, events and file transfer over the artifacts store

Memory Queue documentation

The Memory Queue package reference on docs.robomotion.io documents each node and its properties.