Substreams RabbitMQ CLI Node.js

substreams-sink-rabbitmq is a tool that allows developers to pipe data extracted from a blockchain to a RabbitMQ instance.

📖 Documentation

Further resources

• Substreams documentation
• RabbitMQ documentation

CLI

Use pre-built binaries

• MacOS
• Linux
• Windows

Install globally via npm

$ npm install -g substreams-sink-rabbitmq

Run

$ substreams-sink-rabbitmq run [options] <spkg>

Features

Substreams

• Consume *.spkg from:
  • Load URL or IPFS
  • Read from *.spkg local filesystem
  • Read from substreams.yaml local filesystem
• Handle cursor restart

RabbitMQ

• Handle direct exchange type
• Handle fanout exchange type
• Handle topic exchange type with routing key
• Handle headers exchange type
• Handle durable exchange flag