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:
I hereby claim:
To claim this, I am signing this object:
| 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}); |
| const express = require('express'); | |
| const pg = require('pg'); | |
| const redis = require('redis'); | |
| const amqp = require('amqplib/callback_api'); | |
| const app = express(); | |
| app.get('/', (req, res) => { | |
| res.send('Hello World!') | |
| }); |
| #!/bin/bash | |
| set -e | |
| SCRIPT_HOME="$( cd "$( dirname "$0" )" && pwd )" | |
| cd $SCRIPT_HOME | |
| case "$1" in | |
| start) | |
| docker-compose up web worker clock |
| # Inherit from node base image | |
| FROM node | |
| # This is an alternative to mounting our source code as a volume. | |
| # ADD . /app | |
| # Install Yarn repository | |
| RUN curl -sS http://dl.yarnpkg.com/debian/pubkey.gpg | apt-key add - | |
| RUN echo "deb http://dl.yarnpkg.com/debian/ stable main" | tee /etc/apt/sources.list.d/yarn.list |
| version: '3' | |
| services: | |
| ############################### | |
| # Built from local Dockerfile # | |
| ############################### | |
| web: | |
| # Build the Dockerfile in this directory. | |
| build: . | |
| # Mount this directory as a volume at /app | |
| volumes: |
| 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.')); |
| -- show running queries (pre 9.2) | |
| SELECT procpid, age(query_start, clock_timestamp()), usename, current_query | |
| FROM pg_stat_activity | |
| WHERE current_query != '<IDLE>' AND current_query NOT ILIKE '%pg_stat_activity%' | |
| ORDER BY query_start desc; | |
| -- show running queries (9.2) | |
| SELECT pid, age(query_start, clock_timestamp()), usename, query | |
| FROM pg_stat_activity | |
| WHERE query != '<IDLE>' AND query NOT ILIKE '%pg_stat_activity%' |
| 'use strict'; | |
| /* | |
| |-------------------------------------------------------------------------- | |
| | Application Providers | |
| |-------------------------------------------------------------------------- | |
| | | |
| | Here we configure the providers required to run adonis application. They | |
| | are registered only once and can be used inside any file using `use` | |
| | keyword. |
| 'use strict'; | |
| /* | |
| |-------------------------------------------------------------------------- | |
| | HTTP Server Setup | |
| |-------------------------------------------------------------------------- | |
| | | |
| | Here we join different pieces and start the HTTP server. It will be | |
| | a matter of seconds to start your shiny Adonis application. | |
| | |