substreams-sink-rabbitmq

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

• [x] MacOS
• [x] Linux
• [x] Windows

Install globally via npm

$ npm install -g substreams-sink-rabbitmq

Run

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

Features

Substreams

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

RabbitMQ

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