Skip to content

Instantly share code, notes, and snippets.

View lukebakken's full-sized avatar

Luke Bakken lukebakken

View GitHub Profile
@lukebakken
lukebakken / README.md
Last active December 27, 2017 22:54
queue-index-disk-space-VuICv0AMzKo

PerfTest

--uri amqp://localhost:5672 --producers 1 --consumers 0 \
    --size 2048 --predeclared --exchange exchange-VuICv0AMzKo \
    --routing-key VuICv0AMzKo --flag persistent --rate 1024
lbakken@MESSIAEN ~/vagrant/CENTOS-7
$ vagrant ssh
[vagrant@localhost ~]$ sudo -i
[root@localhost ~]# curl -LO https://packages.erlang-solutions.com/erlang/esl-erlang/FLAVOUR_1_general/esl-erlang_20.1.7-1~centos~7_amd64.rpm
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
100 40.9M 100 40.9M 0 0 3464k 0 0:00:12 0:00:12 --:--:-- 4768k
[root@localhost ~]# yum install ./esl-erlang_20.1.7-1~centos~7_amd64.rpm
Loaded plugins: fastestmirror
Examining ./esl-erlang_20.1.7-1~centos~7_amd64.rpm: esl-erlang-20.1.7-1.x86_64
@lukebakken
lukebakken / README.md
Last active December 27, 2017 13:48
Restart RabbitMQ TLS acceptors with new settings

Restarting RabbitMQ TLS Listeners with new TLS options

Connect via remsh

Be sure to use the correct path to the cookie - probably /var/lib/rabbitmq/.erlang.cookie:

erl -sname node@MESSIAEN -setcookie "$(< $HOME/.erlang.cookie)" -remsh 'rabbit@MESSIAEN'
@lukebakken
lukebakken / FOOTER.md
Last active February 26, 2023 23:21
StackOverflow Answer footer
@lukebakken
lukebakken / README.md
Last active May 17, 2024 19:25
RabbitMQ / MQTT TCP Tuning

rabbitmq.config

[
    {rabbit, [
        {background_gc_enabled, true},
        {background_gc_target_interval, 60000},
        {tcp_listeners, [5672]},
        {num_tcp_acceptors, 10},
        {connection_max, infinity},
@lukebakken
lukebakken / echo-client.go
Created November 19, 2017 14:36 — forked from paulsmith/echo.go
A simple echo server testing a few interesting Go language features, goroutines and channels.
package main
import (
"fmt"
"net"
"os"
"time"
)
func main() {
#!/usr/bin/env python
import pika
import sys
def callback(ch, method, properties, body):
pass
# print(" [x] Received %r" % body)
queue_name = sys.argv[1]
cp = pika.ConnectionParameters('shostakovich')
#!/usr/bin/env ruby
# encoding: utf-8
require 'bunny'
require 'glutton_ratelimit'
require 'pp'
conn = Bunny.new
conn.start
ch = conn.create_channel
@lukebakken
lukebakken / clear-queues.sh
Last active September 20, 2017 22:34
VESC-842
#!/usr/bin/env bash
set -o errexit
set -o nounset
declare -r node='rabbit@shostakovich'
declare -r user='guest'
declare -r pass='guest'
declare -ir queue_count=9