ZeroMQ

zeromq.js

import zmq from "zeromq";

const SOCKET_ADDRESS = "tcp://127.0.0.1:3000"

const connectZeroMQ = () => {
    const socket = zmq.socket('sub');

    socket.connect(SOCKET_ADDRESS);
    socket.subscribe('');

    return socket;
}

const zmq = connectZeroMQ();

zmq.on('rawblock', (error, block) => {
  if(err !== null) return;
  // store on your databasae
})

zmq.on('rawtxn', (error, txn) => {
  if(err !== null) return;
  // store on your databasae
})