Luke Bakken lukebakken

Setup

Clone tls-gen, then in the two_shared_intermediates sub-directory:

make CN=HOSTNAME_1
cp result/* path/to/root_ca_1
make clean
make CN=HOSTNAME_2
cp result/* path/to/root_ca_2

Run PerfTest with the following arguments:

--rate 1 --producers 1 --consumers 1 --exchange gh-976 --routing-key gh-976

	# -- mode: ruby --
	# vi: set ft=ruby :

	$script = <<SCRIPT
	export DEBIAN_FRONTEND=noninteractive
	echo "deb https://dl.bintray.com/rabbitmq/debian xenial main" \| sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
	wget -O- https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc \| sudo apt-key add -
	wget https://packages.erlang-solutions.com/erlang-solutions_1.0_all.deb
	dpkg -i erlang-solutions_1.0_all.deb
	apt-get -yq update

	// This example declares a durable Exchange, an ephemeral (auto-delete) Queue,
	// binds the Queue to the Exchange with a binding key, and consumes every
	// message published to that Exchange with that routing key.
	//
	package main

	import (
	"flag"
	"fmt"
	"github.com/streadway/amqp"

	import logging
	from pika import SelectConnection, URLParameters
	from threading import Thread
	from time import sleep
	from argparse import ArgumentParser

	class AsyncConnection():
	def __init__(self, host):
	self.connection_params = URLParameters('amqp://guest:guest@{}:5672/%2F'.format(host))
	self.log = logging.getLogger(self.__class__.__name__)

	*.pkcs12
	rabbitmq-perf-test-*/