veda-node-queue-consumer

Node.js module for consuming messages from Veda file-based queues. Uses Rust (via Neon) for high-performance queue operations.

Documentation

Complete documentation is available in the doc directory:

• Quick Start Guide ⚡ - Get started in 5 minutes
• Overview - Introduction and key features
• Installation Guide - Setup and installation
• Configuration Guide - Configuration options
• API Reference - Complete API documentation
• Architecture - Technical architecture
• Usage Examples - Code examples
• FAQ - Frequently asked questions

Quick Start

import QueueModule from 'veda-node-queue-consumer';

class MyModule extends QueueModule {
  async process(el) {
    console.log('Processing:', el.cmd, el.uri);
  }
}

const module = new MyModule({
  name: 'my-consumer',
  path: './queue',
  queue: 'individuals-flow',
  notifyChannelUrl: 'tcp://127.0.0.1:9323'
});

module.start();

Installing

Installation requires a supported version of Node and Rust.

You can install the project with npm. In the project directory, run:

$ npm install

This fully installs the project, including installing any dependencies and running the build.

Building

If you have already installed the project and only want to run the build, run:

$ npm run build

This command uses the cargo-cp-artifact utility to run the Rust build and copy the built library into ./index.node.

Exploring

After building, you can explore the module:

$ npm install
$ node
> import('./index.js').then(m => console.log(m.default))

Available Scripts

In the project directory, you can run:

npm install

Installs the project, including running npm run build.

npm run build

Builds the Node addon (index.node) from source.

Additional cargo build arguments may be passed to npm run build and build commands. For example, to enable a cargo feature:

npm run build -- --feature=beetle

npm run build-debug

Alias for npm run build.

npm run build-release

Same as npm run build but, builds the module with the release profile. Release builds will compile slower, but run faster.

npm test

Runs the JavaScript test suites for queue consumer functionality.

npm run test-rust

Runs Rust unit tests by calling cargo test. You can learn more about adding tests to your Rust code from the Rust book.

Project Layout

The directory structure of this project is:

veda-node-queue-consumer/
├── Cargo.toml
├── README.md
├── index.node
├── package.json
├── src/
|   └── lib.rs
└── target/

Cargo.toml

The Cargo manifest file, which informs the cargo command.

README.md

This file.

index.node

The Node addon—i.e., a binary Node module—generated by building the project. This is the main module for this package, as dictated by the "main" key in package.json.

Under the hood, a Node addon is a dynamically-linked shared object. The "build" script produces this file by copying it from within the target/ directory, which is where the Rust build produces the shared object.

package.json

The npm manifest file, which informs the npm command.

src/

The directory tree containing the Rust source code for the project.

src/lib.rs

The Rust library's main module.

target/

Binary artifacts generated by the Rust build.

Learn More

To learn more about Neon, see the Neon documentation.

To learn more about Rust, see the Rust documentation.

To learn more about Node, see the Node documentation.