bunqueue v2.8 API referenceall versions · guide
bunqueue
    Preparing search index...

    Class Forwarder

    Drains a local queue into a remote bunqueue server. Create via queue.forward(options); stop with close().

    Hierarchy

    • EventEmitter
      • Forwarder
    Index
    • Stop forwarding and release connections. Safe to call more than once.

      Returns Promise<void>

    • Adds the listener function to the end of the listeners array for the event named eventName. No checks are made to see if the listener has already been added. Multiple calls passing the same combination of eventName and listener will result in the listener being added, and called, multiple times.

      server.on('connection', (stream) => {
      console.log('someone connected!');
      });

      Returns a reference to the EventEmitter, so that calls can be chained.

      By default, event listeners are invoked in the order they are added. The emitter.prependListener() method can be used as an alternative to add the event listener to the beginning of the listeners array.

      import { EventEmitter } from 'node:events';
      const myEE = new EventEmitter();
      myEE.on('foo', () => console.log('a'));
      myEE.prependListener('foo', () => console.log('b'));
      myEE.emit('foo');
      // Prints:
      // b
      // a

      Parameters

      • event: "forwarded"
      • listener: (info: ForwardedInfo) => void

        The callback function

      Returns this

      v0.1.101

    • Parameters

      • event: "error"
      • listener: (error: Error) => void

      Returns this