Zerpet

PR #365 repro: skip-and-continue topology recovery livelock

Standalone program used to verify a concern raised in review of rabbitmq/amqp091-go#365.

Setup

1. Start RabbitMQ: docker run --rm -d --name rabbitmq-verify -p 5672:5672 rabbitmq:4-management
2. Check out the PR branch somewhere, e.g.: git clone https://github.com/rabbitmq/amqp091-go.git /tmp/pr365 && cd /tmp/pr365 && git fetch origin pull/365/head:pr-365 && git checkout pr-365

Zerpet

//+go:build integration

package amqp091_test

import (
	"context"
	"fmt"
	amqp "github.com/rabbitmq/amqp091-go"
	"os"
	"strconv"

Zerpet

apiVersion: rabbitmq.com/v1beta1
kind: RabbitmqCluster
metadata:
  annotations:
    prometheus.io/port: "15692"
    prometheus.io/scrape: "true"
  name: bunny
spec:
  image: rabbitmq:3.8
  replicas: 3

Zerpet

apiVersion: apps/v1
kind: Deployment
metadata:
  name: perf-test-deployment
  labels:
    app: perf-test
spec:
  replicas: 1
  selector:
    matchLabels:

Zerpet

{
    "bindings": [
        {
            "arguments": {},
            "destination": "dead",
            "destination_type": "queue",
            "routing_key": "",
            "source": "dlx",
            "vhost": "/"
        },

Zerpet

#!/bin/bash

mkdir -pv testca
cd testca
mkdir -pv certs private
chmod 700 private
echo 01 > serial
touch index.txt

openssl req -x509 -config ../openssl.cnf -newkey rsa:2048 -days 365 -out cacert.pem -outform PEM -subj /CN=MyTestCA/ -nodes

Zerpet

What just happened?

• We used curl to download a Docker Compose template for RabbitMQ 3.6 from the image repo
• We started a new Docker Compose "project" named blazing-fast-rabbit using the template
• The Docker image has an automated procedure in the entry script to automatically join a RabbiMQ cluster
• The management UI ports are exposed and forwarded to localhost ports 15672, 15673 and 15674
• We can get an interactive Bash terminal to the container
• We can execute any command in the container without an interactive terminal!
• We left everything as we found it

Zerpet

Keybase proof

I hereby claim:

• I am Zerpet on github.
• I am zerpet (https://keybase.io/zerpet) on keybase.
• I have a public key whose fingerprint is 2C8F CD9C A8D5 1A8F 89DE D4E7 0E97 3277 AB13 2628

To claim this, I am signing this object: