nrempel

const amqp = require('amqplib/callback_api');

amqp.connect(process.env.RABBIT_URL, (err, conn) => {
  conn.createChannel((err, ch) => {
    // Consume messages from web queue
    var q1 = 'web';
    ch.assertQueue(q1, { durable: false });
    ch.consume(q1, (msg) => {
      console.info('Message received from web process:', msg.content.toString());
    }, {noAck: true});

nrempel

const SimpleCron = require('simple-cron');
const cron = new SimpleCron();
const amqp = require('amqplib/callback_api');

cron.schedule('* * * * *', () => {
  amqp.connect(process.env.RABBIT_URL, (err, conn) => {
    conn.createChannel((err, ch) => {
      const q = 'clock';
      ch.assertQueue(q, { durable: false });
      ch.sendToQueue(q, Buffer.from('hi.'));

nrempel

version: '3'
services:
  ###############################
  # Built from local Dockerfile #
  ###############################
  web:
    # Build the Dockerfile in this directory.
    build: .
    # Mount this directory as a volume at /app
    volumes:

nrempel

Keybase proof

I hereby claim:

• I am nrempel on github.
• I am nbrempel (https://keybase.io/nbrempel) on keybase.
• I have a public key ASAftFlDSiw5r-dyaLSzRVeB4-gNEgjo5w2Rqd2P5KbHPgo

To claim this, I am signing this object: