Merge lp:~mbruzek/charms/precise/rabbitmq-server/add-tests into lp:charms/rabbitmq-server

[Matt Bruzek]

Adding tests for the rabbitmq-server charm.

[Ryan Beisner (1chb1n)]

Thank you for the amulet test coverage work on rmq, much appreciated!

If we can get this added to Makefile, that will make OSCI's engine happy:

test:
    @echo Starting amulet tests...
    @juju test -v -p AMULET_HTTP_PROXY --timeout 900

I just sent your branch with ^ that mod through to confirm:
  juju-test.conductor.00_setup.sh RESULT : ✔
  juju-test.conductor.10_basic_deploy_test.py RESULT : ✔
  juju-test.conductor.20_deploy_relations_test.py RESULT : ✔
  juju-test.conductor.30_configuration_test.py RESULT : ✔
  juju-test INFO : Results: 4 passed, 0 failed, 0 errored

I think most of the openstack charms use the 'test' target name. But actually, you can name the make target anything as OSCI just looks for '@juju test' in a target and runs that target.

[lp:~mbruzek/charms/precise/rabbitmq-server/add-tests]

76. By Matt Bruzek on 2015-01-12

Adding Makefile changes

[Matt Bruzek (mbruzek)]

Thanks for the review. I added the functional_test target to the Makefile so these tests work on both testing systems. Charmers please review these changes for inclusion to the precise charm.

[Ryan Beisner (1chb1n)]

Re-confirmed with rev76. Precise charm amulet tests succeed. Clear from the OSCI perspective. Thanks again!

review: Approve

[José Antonio Rey (jose)]

Hey Matt!

Thank you for taking the time to write this tests. I have ran them on EC2, and turns out they successfully pass!

I will be pushing these on the next few minutes. Thanks again!

review: Approve (charmers)

[Review Queue (review-queue)]

This items has failed automated testing! Results available here http://reports.vapour.ws/charm-tests/charm-bundle-test-10905-results

review: Needs Fixing (automated testing)

=== modified file 'Makefile'
--- Makefile	2014-10-08 15:57:57 +0000
+++ Makefile	2015-01-12 15:19:55 +0000
@@ -20,7 +20,11 @@
 	bzr push lp:charms/rabbitmq-server
 	bzr push lp:charms/trusty/rabbitmq-server
 
+functional_test: 
+	@echo Starting functional tests...
+	@juju test -v -p AMULET_HTTP_PROXY --timeout 900
+
 unit_test:
-	@echo Starting tests...
+	@echo Starting unit tests...
 	CHARM_DIR=$(CHARM_DIR) $(TEST_PREFIX) nosetests unit_tests
 

=== added directory 'tests'
=== added file 'tests/00_setup.sh'
--- tests/00_setup.sh	1970-01-01 00:00:00 +0000
+++ tests/00_setup.sh	2015-01-12 15:19:55 +0000
@@ -0,0 +1,16 @@
+#!/bin/sh
+
+# Install Juju Amulet and any other applications that are needed for the tests.
+
+set -x
+
+# Check if amulet is installed before adding repository and updating apt-get.
+dpkg -s amulet
+if [ $? -ne 0 ]; then 
+    sudo add-apt-repository -y ppa:juju/stable
+    sudo apt-get update 
+    sudo apt-get install -y amulet
+fi
+
+# Install any additional python packages, or software here.
+sudo apt-get install -y python python-pika python3-requests

=== added file 'tests/10_basic_deploy_test.py'
--- tests/10_basic_deploy_test.py	1970-01-01 00:00:00 +0000
+++ tests/10_basic_deploy_test.py	2015-01-12 15:19:55 +0000
@@ -0,0 +1,101 @@
+#!/usr/bin/python3
+
+# This Amulet test performs a basic deploy and checks if rabbitmq is running.
+
+import amulet
+import os
+import socket
+import ssl
+
+# The number of seconds to wait for the environment to setup.
+seconds = 900
+# Get the directory in this way to load the files from the tests directory.
+path = os.path.abspath(os.path.dirname(__file__))
+
+key_path = os.path.join(path, 'rabbit-server-privkey.pem')
+# Read the private key file.
+with open(key_path) as f:
+    privateKey = f.read()
+# Read the certificate file.
+cert_path = os.path.join(path, 'rabbit-server-cert.pem')
+with open(cert_path) as f:
+    certificate = f.read()
+
+# Create a dictionary for the rabbitmq configuration.
+rabbitmq_configuration = {
+    'ssl_enabled': True,
+    'ssl_key': privateKey,
+    'ssl_cert': certificate,
+    'ssl_port': 5671
+}
+
+d = amulet.Deployment()
+# Add the rabbitmq-server charm to the deployment.
+d.add('rabbitmq-server')
+# Configure options on the rabbitmq-server.
+d.configure('rabbitmq-server', rabbitmq_configuration)
+# Expose the server so we can connect.
+d.expose('rabbitmq-server')
+
+try:
+    # Execute the deployer with the current mapping.
+    d.setup(timeout=seconds)
+except amulet.helpers.TimeoutError:
+    message = 'The environment did not setup in %d seconds.' % seconds
+    # The SKIP status enables skip or fail the test based on configuration.
+    amulet.raise_status(amulet.SKIP, msg=message)
+except:
+    raise
+print('The rabbitmq-server has been successfully deployed.')
+
+###############################################################################
+## Verify that the rabbit service is running on the deployed server.
+###############################################################################
+rabbitmq_sentry = d.sentry.unit['rabbitmq-server/0']
+# Get the public address for rabbitmq-server instance.
+server_address = rabbitmq_sentry.info['public-address']
+# Create the command that checks if the rabbitmq-server service is running.
+command = 'rabbitmqctl status'
+print(command)
+# Execute the command on the deployed service.
+output, code = rabbitmq_sentry.run(command)
+print(output)
+# Check the return code for the success and failure of this test.
+if (code != 0):
+    message = 'The ' + command + ' did not return the expected code of 0.'
+    amulet.raise_status(amulet.FAIL, msg=message)
+else:
+    print('The rabbitmq-server is running on %s' % server_address)
+
+###############################################################################
+## Test the ssl certificate.
+###############################################################################
+# Get the port for ssl_port instance.
+server_port = rabbitmq_configuration['ssl_port']
+
+# Get the path to the certificate authority file.
+ca_cert_path = os.path.join(path, 'rabbit-server-cacert.pem')
+
+print('Testing ssl connection to rabbitmq-server.')
+try:
+    # Create a normal socket.
+    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    # Require a certificate from the server, since a self-signed certificate
+    # was used, the ca_certs must be the server certificate file itself.
+    ssl_sock = ssl.wrap_socket(s, ca_certs=ca_cert_path,
+                               cert_reqs=ssl.CERT_REQUIRED)
+    # Connect to the rabbitmq server using ssl.
+    ssl_sock.connect((server_address, server_port))
+    # Get the certificate.
+    certificate = ssl_sock.getpeercert()
+    # SSL socket connected and got the certificate, this passes the ssl test!
+    print('Connected to the rabbitmq-server {0}:{1} using ssl!'.format(
+          server_address, server_port))
+except Exception as e:
+    message = 'Failed to create an ssl connection to {0}:{1}\n{2}'.format(
+              server_address, server_port, str(e))
+    amulet.raise_status(amulet.FAIL, msg=message)
+finally:
+    ssl_sock.close()
+
+print('The rabbitmq-server passed the basic deploy test!')

=== added file 'tests/20_deploy_relations_test.py'
--- tests/20_deploy_relations_test.py	1970-01-01 00:00:00 +0000
+++ tests/20_deploy_relations_test.py	2015-01-12 15:19:55 +0000
@@ -0,0 +1,214 @@
+#!/usr/bin/python3
+
+# This Amulet test deploys rabbitmq-server, and the related charms.
+
+import amulet
+import os
+import subprocess
+import time
+
+# The number of seconds to wait for the environment to setup.
+seconds = 900
+# The number of units to scale rabbitmq-server to.
+scale = 2
+# The port that amqp traffic is sent on.
+amqp_port = '5672'
+# The directory to use as a block devie for the ceph
+devices = '/srv/osd1'
+# The default version of ceph does not support directories as devices.
+havana = 'cloud:precise-updates/havana'
+# Create a dictionary of configuration values for ceph.
+ceph_configuration = {
+    'fsid': 'ecbb8960-0e21-11e2-b495-83a88f44db01',
+    'monitor-secret': 'AQBomftSyK1LORAAhg71ukxBxN9ml90stexqEw==',
+    'osd-devices': devices,
+    'source': havana
+}
+# Create a dictionary of configuration values for cinder.
+cinder_configuration = {
+    'block-device': 'None'
+}
+# Create a dictionary of the rabbit configuration values.
+rabbit_configuration = {
+    'vip': '192.168.77.11',
+    'vip_cidr': 19,
+    'vip_iface': 'eth0',
+    'ha-bindiface': 'eth0',
+    'ha-mcastport': 5406,
+    'rbd-size': '2G',
+    'rbd-name': 'testrabbit1'
+}
+
+# The AMQP package is only available for python version 2.x.
+python2 = '/usr/bin/python'
+if not os.path.isfile(python2):
+    error_message = 'Error, python version 2 is required for this test.'
+    amulet.raise_status(amulet.FAIL, msg=error_message)
+
+d = amulet.Deployment()
+# Add rabbitmq-server to the deployment.
+d.add('rabbitmq-server', units=scale)
+# Add the ceph charm to the deployment.
+d.add('ceph')
+# Add cinder to the deployment to test the AMQP relation.
+d.add('cinder')
+# Add hacluster to the deployment to test the ha relation.
+d.add('hacluster')
+# The ceph charm requires configuration to deploy successfully.
+d.configure('ceph', ceph_configuration)
+# Configure the cinder charm.
+d.configure('cinder', cinder_configuration)
+# Configure the rabbit charm.
+d.configure('rabbitmq-server', rabbit_configuration)
+# Add relation from rabbitmq-server to ceph testing the ceph relation.
+d.relate('rabbitmq-server:ceph', 'ceph:client')
+# Add relation from rabbitmq-server to cinder testing the amqp relation.
+d.relate('rabbitmq-server:amqp', 'cinder:amqp')
+# Add relation from rabibtmq-server to hacluster testing the ha relation.
+d.relate('rabbitmq-server:ha', 'hacluster:ha')
+# Expose the rabbitmq-server.
+d.expose('rabbitmq-server')
+
+try:
+    # Execute the deployer with the current mapping.
+    d.setup(timeout=seconds)
+    # Wait for the relation to finish the transations.
+    d.sentry.wait(seconds)
+except amulet.helpers.TimeoutError:
+    message = 'The environment did not setup in %d seconds.' % seconds
+    # The SKIP status enables skip or fail the test based on configuration.
+    amulet.raise_status(amulet.FAIL, msg=message)
+except:
+    raise
+print('The environment successfully deployed.')
+
+# Create a counter to make the messages unique.
+counter = 1
+# Get the directory in this way to load the files from the tests directory.
+path = os.path.abspath(os.path.dirname(__file__))
+# Create a path to the python test file to call.
+amqp_tester = os.path.join(path, 'amqp_tester.py')
+if not os.path.isfile(amqp_tester):
+    error_message = 'Unable to locate python test file %s' % amqp_tester
+    amulet.raise_status(amulet.FAIL, msg=error_message)
+
+# Verify the ceph unit was created.
+ceph_unit = d.sentry.unit['ceph/0']
+# Verify the cinder unit was created.
+cinder_unit = d.sentry.unit['cinder/0']
+rabbit_units = []
+for n in range(scale):
+    # Get each rabbitmq unit that was deployed.
+    rabbit_units.append(d.sentry.unit['rabbitmq-server/%d' % n])
+
+# Iterate over every rabbitmq-unit to get the different relations.
+for rabbit_unit in rabbit_units:
+    ###########################################################################
+    ## Test Relations
+    ###########################################################################
+    # Verify the ceph relation was created for the rabbit unit.
+    rabbit_relation = rabbit_unit.relation('ceph', 'ceph:client')
+    print('rabbit relation to ceph:')
+    for key, value in rabbit_relation.items():
+        print(key, value)
+    # Verify the amqp relation was created for the rabbit unit.
+    rabbit_relation = rabbit_unit.relation('amqp', 'cinder:amqp')
+    print('rabbit relation to amqp:')
+    for key, value in rabbit_relation.items():
+        print(key, value)
+
+    # The hacluster charm is a subordinate, since the relation-sentry is also
+    # a subordinate charm no sentry is created for the hacluster relation.
+
+    #  Verify the rabbit relation was created with the ceph unit.
+    ceph_relation = ceph_unit.relation('client', 'rabbitmq-server:ceph')
+    print('ceph relation to rabbitmq-server:')
+    for key, value in ceph_relation.items():
+        print(key, value)
+    # Verify the rabbit relation was created with the cinder unit.
+    cinder_relation = cinder_unit.relation('amqp', 'rabbitmq-server:amqp')
+    print('cinder relation to rabbitmq-server:')
+    for key, value in cinder_relation.items():
+        print(key, value)
+
+    ###########################################################################
+    ## Test AMQP
+    ###########################################################################
+
+    # The AMQP python library is only available for python2 at this time.
+    # Call out a command to run the python2 code to test the AMQP protocol.
+
+    # Get the public address for rabbitmq-server instance.
+    server_address = rabbit_unit.info['public-address']
+    # Create a time stamp to help make the AMQP message unique.
+    time_stamp = time.strftime('%F %r')
+    # Create the message to send on the AMPQ protocol.
+    amqp_message = "Message #{0} to send using the AMPQ protocol {1}".format(
+        counter, time_stamp)
+    # Create the command with arguments that sends the message.
+    send_command = [python2, amqp_tester, server_address, amqp_port,
+                    amqp_message]
+    print(send_command)
+    # Call the python command to send the AMQP message to the server.
+    output = subprocess.check_output(send_command)
+    # Create the command with arguments to receive messages.
+    receive_command = [python2, amqp_tester, server_address, amqp_port]
+    print(receive_command)
+    # Call the python command to receive the AMQP message from the same server.
+    output = subprocess.check_output(receive_command)
+    # The output is a byte string so convert the message to a byte string.
+    if output.find(amqp_message.encode()) == -1:
+        print('The AMQP test to {0}:{1} failed.'.format(server_address,
+              amqp_port))
+        amulet.raise_status(amulet.FAIL, msg=output)
+    else:
+        print('The AMQP test to {0}:{1} completed successfully.'.format(
+            server_address, amqp_port))
+    counter += 1
+
+    ###########################################################################
+    ## Verify that the rabbitmq cluster status is correct.
+    ###########################################################################
+    # Create the command that checks if the rabbitmq-server service is running.
+    command = 'rabbitmqctl cluster_status'
+    print(command)
+    # Execute the command on the deployed service.
+    output, code = rabbit_unit.run(command)
+    print(output)
+    # Check the return code for the success and failure of this test.
+    if (code != 0):
+        message = 'The ' + command + ' did not return the expected code of 0.'
+        amulet.raise_status(amulet.FAIL, msg=message)
+    else:
+        print('The rabbitmq-server cluster status is OK.')
+
+###############################################################################
+## Test the AMQP messages can be sent from and read from another.
+###############################################################################
+# Get the public address for rabbitmq-server instance 0.
+send_address = rabbit_units[0].info['public-address']
+# Create a message to send from instance 0 and read it from instance 1.
+amqp_message = "Message #{0} sent from {1} using the AMQP protocol.".format(
+               counter, send_address)
+counter += 1
+# Create the command that sends the message to instance 0.
+send_command = [python2, amqp_tester, send_address, amqp_port, amqp_message]
+print(send_command)
+output = subprocess.check_output(send_command)
+# Get the public address for rabbitmq-server instance 1.
+receive_address = rabbit_units[1].info['public-address']
+# Create the command that receives the message from instance 1.
+recieve_command = [python2, amqp_tester, receive_address, amqp_port]
+print(recieve_command)
+output = subprocess.check_output(receive_command)
+# The output is a byte string so convert the message to a byte string.
+if output.find(amqp_message.encode()) == -1:
+    print(output)
+    message = 'Server {0} did not receive the AMQP message "{1}"'.format(
+              receive_address, amqp_message)
+    amulet.raise_status(amulet.FAIL, msg=message)
+else:
+    print('Server {0} received the AMQP message sent from {1}'.format(
+          receive_address, send_address))
+
+print('The rabbitmq-server charm passed this relations test.')

=== added file 'tests/30_configuration_test.py'
--- tests/30_configuration_test.py	1970-01-01 00:00:00 +0000
+++ tests/30_configuration_test.py	2015-01-12 15:19:55 +0000
@@ -0,0 +1,142 @@
+#!/usr/bin/python3
+
+# This Amulet test exercises the configuration options for rabbitmq-server.
+
+import amulet
+import os
+import requests
+import socket
+import ssl
+
+# The number of seconds to wait for the environment to setup.
+seconds = 900
+# Get the directory in this way to load the files from the tests directory.
+path = os.path.abspath(os.path.dirname(__file__))
+key_path = os.path.join(path, 'rabbit-server-privkey.pem')
+# Read the private key file.
+with open(key_path) as f:
+    privateKey = f.read()
+cert_path = os.path.join(path, 'rabbit-server-cert.pem')
+# Read the certificate file.
+with open(cert_path) as f:
+    certificate = f.read()
+
+# Create a dictionary of all the configuration values.
+rabbit_configuration = {
+    'management_plugin': True,
+    'ssl_enabled': True,
+    'ssl_port': 5999,
+    'ssl_key': privateKey,
+    'ssl_cert': certificate
+}
+
+d = amulet.Deployment()
+# Add the rabbitmq-server charm to the deployment.
+d.add('rabbitmq-server')
+# Configure all the options on rabbitmq-server.
+d.configure('rabbitmq-server', rabbit_configuration)
+# Expose the rabbitmq-server.
+d.expose('rabbitmq-server')
+
+try:
+    # Execute the deployer with the current mapping.
+    d.setup(timeout=seconds)
+    # Wait for the relation to finish the transations.
+    #d.sentry.wait(seconds)
+except amulet.helpers.TimeoutError:
+    message = 'The environment did not setup in %d seconds.' % seconds
+    # The SKIP status enables skip or fail the test based on configuration.
+    amulet.raise_status(amulet.SKIP, msg=message)
+except:
+    raise
+
+rabbit_unit = d.sentry.unit['rabbitmq-server/0']
+###############################################################################
+## Verify that the rabbit service is running on the deployed server.
+###############################################################################
+# Create the command that checks if the rabbitmq-server service is running.
+command = 'rabbitmqctl status'
+print(command)
+# Execute the command on the deployed service.
+output, code = rabbit_unit.run(command)
+print(output)
+# Check the return code for the success and failure of this test.
+if (code != 0):
+    message = 'The ' + command + ' did not return the expected code of 0.'
+    amulet.raise_status(amulet.FAIL, msg=message)
+else:
+    print('The rabbitmq-server is running.')
+
+###############################################################################
+## Verify the configuration values.
+###############################################################################
+# Get the contents of the private key from the rabbitmq-server
+contents = rabbit_unit.file_contents('/etc/rabbitmq/rabbit-server-privkey.pem')
+# Verify the private key was saved on the rabbitmq server correctly.
+if contents != privateKey:
+    message = 'The private keys did not match!'
+    amulet.raise_status(amulet.FAIL, msg=message)
+else:
+    print('The private keys was configured properly on the rabbitmq server.')
+
+# Get the contents of the certificate from the rabbitmq-server.
+contents = rabbit_unit.file_contents('/etc/rabbitmq/rabbit-server-cert.pem')
+# Verify the certificate was saved on the rabbitmq server correctly.
+if contents != certificate:
+    message = 'The certificates did not match!'
+    amulet.raise_status(amulet.FAIL, msg=message)
+else:
+    print('The certificate was configured properly on the rabbitmq server.')
+
+# Get the public address for rabbitmq-server instance.
+rabbit_host = rabbit_unit.info['public-address']
+
+###############################################################################
+## Verify the management plugin is running and responding on correct port.
+## According to this: http://www.rabbitmq.com/access-control.html
+## The guest account can only log in from local host.
+## Since this test runs on a different system there is no way to test
+## the management plugin.
+###############################################################################
+# Create a url for the rabbitmq server's managment plugin (uses 55672).
+#management_url = 'http://{0}:55672'.format(rabbit_host)
+#print(management_url)
+# Get the management url with the authentication for guest.
+#r = requests.get(management_url, auth=('guest', 'guest'))
+# Raise an exception if response is not 200 OK.
+#r.raise_for_status()
+#print(str(r))
+#print('Successfully authenticated to the management console at %s' %
+#      management_url)
+
+###############################################################################
+## Verify that SSL is set up on the non-default port.
+###############################################################################
+# Get the port for ssl_port instance.
+ssl_port = rabbit_configuration['ssl_port']
+
+# Get the path to the certificate authority file.
+ca_cert_path = os.path.join(path, 'rabbit-server-cacert.pem')
+
+try:
+    # Create a normal socket.
+    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    # Require a certificate from the server, since a self-signed certificate
+    # was used, the ca_certs must be the server certificate file itself.
+    ssl_sock = ssl.wrap_socket(s, ca_certs=ca_cert_path,
+                               cert_reqs=ssl.CERT_REQUIRED)
+    # Connect to the rabbitmq server using ssl.
+    ssl_sock.connect((rabbit_host, ssl_port))
+    # Get the certificate.
+    certificate = ssl_sock.getpeercert()
+    # SSL scoket connected and got the certificate, this passes the ssl test!
+    print('Connected to the rabbitmq-server {0}:{1} using ssl!'.format(
+          rabbit_host, ssl_port))
+except Exception as e:
+    message = 'Failed to create an ssl connection to {0}:{1}\n{2}'.format(
+              rabbit_host, ssl_port, str(e))
+    amulet.raise_status(amulet.FAIL, msg=message)
+finally:
+    ssl_sock.close()
+
+print('The rabbitmq-server passed the configuration tests.')

=== added file 'tests/amqp_tester.py'
--- tests/amqp_tester.py	1970-01-01 00:00:00 +0000
+++ tests/amqp_tester.py	2015-01-12 15:19:55 +0000
@@ -0,0 +1,65 @@
+#!/usr/bin/python
+
+# This class uses Python to make AMQP calls to send and receive messages.
+# To send an AMQP message call this module with a host, port, and message.
+# To receive an AMQP message call this module with a host and port only.
+
+import logging
+import pika
+import sys
+
+
+def send(host, port, message, queue='test'):
+    """ Send an AMQP message to a host and port."""
+    connection = None
+    try:
+        parameters = pika.ConnectionParameters(host, port)
+        connection = pika.BlockingConnection(parameters)
+
+        channel = connection.channel()
+        channel.queue_declare(queue)
+        channel.basic_publish(exchange='', routing_key=queue, body=message)
+        print('Message published to {0}:{1}'.format(host, port))
+    except Exception as e:
+        print('Unable to send message to {0}:{1}'.format(host, port))
+        print(e)
+    finally:
+        if connection:
+            connection.close()
+
+
+def callback(ch, method, properties, body):
+    """ Handle the callback when the channel receives a message. """
+    print(body)
+
+
+def receive(host, port, queue='test'):
+    """ Connects to host and port, and consumes AMQP messages. """
+    connection = None
+    try:
+        parameters = pika.ConnectionParameters(host, port)
+        connection = pika.BlockingConnection(parameters)
+        channel = connection.channel()
+        channel.queue_declare(queue)
+        channel.basic_consume(callback, queue, no_ack=True)
+    except Exception as e:
+        print('Unable to receive message from {0}:{1}'.format(host, port))
+        print(e)
+    finally:
+        if connection:
+            connection.close()
+
+# Needed to disable pika complaining about logging levels not set.
+logging.basicConfig(level=logging.ERROR)
+
+if len(sys.argv) == 3:
+    host = sys.argv[1]
+    port = int(sys.argv[2])
+    receive(host, port)
+elif len(sys.argv) > 3:
+    host = sys.argv[1]
+    port = int(sys.argv[2])
+    message = ' '.join(sys.argv[3:])
+    send(host, port, message)
+else:
+    print('Not enough arguments, host and port are required.')

=== added file 'tests/rabbit-server-cacert.pem'
--- tests/rabbit-server-cacert.pem	1970-01-01 00:00:00 +0000
+++ tests/rabbit-server-cacert.pem	2015-01-12 15:19:55 +0000
@@ -0,0 +1,17 @@
+-----BEGIN CERTIFICATE-----
+MIICxjCCAa6gAwIBAgIJAIOIZyP0JpvLMA0GCSqGSIb3DQEBBQUAMBMxETAPBgNV
+BAMTCE15VGVzdENBMB4XDTE0MDIyMzIwMDgxOFoXDTE1MDIyMzIwMDgxOFowEzER
+MA8GA1UEAxMITXlUZXN0Q0EwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIB
+AQDceXBJOhn9d68M9UiOViWz00Znds1xk9i+GbZFEsqLPkoReS9g/SeXvR5ZFZlU
+5gzAcg8z8b+n26wgZLFQJ4wQAIVELIu0S6e4sUPKfKl/fo9NmRVv/sPkfZWUZ5sc
+d9DEk8MiNYjjXT+Ff4TV7DFxdDOJLIDrc09JWzIKrmfOXP5wLFCsIllGbellfNvY
+FxiHHm3Iz5t3t077+uUXeMD5p1Qd2qQdbJ2p8Dwkg2AyTPNG8RA71tEMIT7FX0nB
+sTX5M217ocdEZJI67x+3Z8Ll21m6blcnJI3V3Zk5kvccvYRlDuyGh7tiWcv4YKmv
+xuP64L9174nQ3HXnwipfjBkBAgMBAAGjHTAbMAwGA1UdEwQFMAMBAf8wCwYDVR0P
+BAQDAgEGMA0GCSqGSIb3DQEBBQUAA4IBAQAaQWYVUuPKRtAFd6kyugL/UpVhIa/o
+zfm/2b23UviPA1TIYzzf4m1eDV7kxJynOeP1RRPp166el+sVx7+vqhBsqcm4b5e+
+epShI3jff0gtODxo5rUVrROS3T6xjHA7AVm60/xmGIIybhDonXzA5YJ8YVBpHUdZ
+Yc2neOwdDT8k/H95cPXBU3pf3vTVpndjN827fBuyO7KwKDAiKHwtwmSedc1uZtLN
+sfwkonXF+gNAHXlk28VeygGQ1jHdloIrNG0zYc4ZX4zqPHd7HDeyYItBBHjrznow
+nf1X6fNjP4YnG5EkUN8hRXf3ct+L8iq8puMNhjb8ssW+bsFRBIufVFaC
+-----END CERTIFICATE-----

=== added file 'tests/rabbit-server-cert.pem'
--- tests/rabbit-server-cert.pem	1970-01-01 00:00:00 +0000
+++ tests/rabbit-server-cert.pem	2015-01-12 15:19:55 +0000
@@ -0,0 +1,18 @@
+-----BEGIN CERTIFICATE-----
+MIIC5TCCAc2gAwIBAgIBATANBgkqhkiG9w0BAQUFADATMREwDwYDVQQDEwhNeVRl
+c3RDQTAeFw0xNDAyMjMyMDA5MjFaFw0xNTAyMjMyMDA5MjFaMCgxFTATBgNVBAMM
+DHJlYWxtcy1zbGljZTEPMA0GA1UECgwGc2VydmVyMIIBIjANBgkqhkiG9w0BAQEF
+AAOCAQ8AMIIBCgKCAQEApc6WxtgQZL+PcDHL1S/kLqFyGPaKiJQrOPGYq9djM5pr
+VGPHUZ3F26VWtlBtPB8PgQFT10Sjr+ec7hC9aqT+THyNq2U8qCizGq4l4e44tfEI
+LPuE9IluF/dZuVWFR2nbVYp3FeAjuRQ68AwzpcZOXVup3xsXx7dJrGL4KUx/7NUb
+5+6TzboM1nXX7o/DYCE5BvXncM7U3cLg16SV58T6Rs+JYATAFdzveN6X88AgvQpB
+rDSD42tSQmQzYu9mO2RwtP48jLvYLHv34dZo2h6G5zNWe/PkUjXxKEGJXHkeXy83
+vx4UV62Vo8pMLeSSqL4wUV3KMRHJ+MBskP42lmruwQIDAQABoy8wLTAJBgNVHRME
+AjAAMAsGA1UdDwQEAwIFIDATBgNVHSUEDDAKBggrBgEFBQcDATANBgkqhkiG9w0B
+AQUFAAOCAQEArEFhWRHb1Nn1ACDNXbRueiMSdqwWtiAEU4yAFB+1maKyAG1VAQC2
+IegIJ7INbzfwDp6CzNpI3CCyelNO2rcBGwOlXre6XA5K7TxKM6WLJDdodPUt30dY
+3+/DF/XwH5S/C4oGbeRVWxzCBAFbStMlJqpXFIQkAYYCOfvWKoZzSslxGe7Zj+hQ
+NYqJbc8BDe0UTyM8KoL9OWucEbdQMQgn0FxwAPqSLXgDkpSo6XHKL15MUbES1u5/
+iT9gRJU1eN+bIWfrJA3dqh4JxXntTLDZ28pBdFtOV4WEF2O4fmxGiSktCi34tjK6
+DsIScb+0mUeKS9b2cyQzLSUCwj8LgJW3rQ==
+-----END CERTIFICATE-----

=== added file 'tests/rabbit-server-privkey.pem'
--- tests/rabbit-server-privkey.pem	1970-01-01 00:00:00 +0000
+++ tests/rabbit-server-privkey.pem	2015-01-12 15:19:55 +0000
@@ -0,0 +1,27 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIEpAIBAAKCAQEApc6WxtgQZL+PcDHL1S/kLqFyGPaKiJQrOPGYq9djM5prVGPH
+UZ3F26VWtlBtPB8PgQFT10Sjr+ec7hC9aqT+THyNq2U8qCizGq4l4e44tfEILPuE
+9IluF/dZuVWFR2nbVYp3FeAjuRQ68AwzpcZOXVup3xsXx7dJrGL4KUx/7NUb5+6T
+zboM1nXX7o/DYCE5BvXncM7U3cLg16SV58T6Rs+JYATAFdzveN6X88AgvQpBrDSD
+42tSQmQzYu9mO2RwtP48jLvYLHv34dZo2h6G5zNWe/PkUjXxKEGJXHkeXy83vx4U
+V62Vo8pMLeSSqL4wUV3KMRHJ+MBskP42lmruwQIDAQABAoIBAE6jo/ldQrE19acF
+xyIum6/OHJpgXCYY+EMCuyFNf5xa8erNhBxekxfw3CaOELECHk1WPtiLkoL8e/6h
+a+UnqgDG1j5jPpiW7ROLYyY74SPR1MnY5R9CCzhMtX5kZFkRiNiSWpbCfs7qHGX7
+s4c9fa9jqTbK18V+Ve/v5LlZsha13OQRISQLqZlCM6vKRtHZorQHZVM1KIV4bzdP
+75/YTrhUA8GKGA+4Le5vZ1PQY8ubTAXPHeeqILvClsmkZ6k0RC/zesB3DUXzMvjA
+ycbarcpZ+muxyp0Icuv9B7pj3iT/dL4udc+BM82Qg3KvLLiteE9aeOPsW3aJxAHa
+YYLLCQECgYEA2EUF4QVgJE1U6RHFsRO6xP1KBJO0mVMMlEpgywPV3oN7D5gOVrCK
+A/iNkyt2ggaX2o2+QHMe+WjINdMLhY6TdhRiYrUQhLteNSrp0w/HDYyY2Cz1IhH3
+Y/0qHm9rGZhetOWoJ5Ejn/9vnL/ZfsGfSNzwS1VjCUHyXShebS9NHRECgYEAxERZ
+5HX3zctB2lzzS8KTNAWijUc+hc8c0LV/GcCC8LMsUPNb/V+wQNiSInJa994YI5+9
+1BkJkw4Lnexvx8GQPaAkX6DzZsWSmwaNSkLICd75f2ga4dqeohWOAIvS3xb4fanr
+szCLZfd4L8MEb6lVI2wzpM5yADK42y/w03t0drECgYBvDAn3v93c5gRKZIDA6uOE
+0JXYAcvCypzz67kFpSOEzLg8ipQaOS202kQ/pBqGq0H/y7Y7u6DU6dObp5EL8+iN
+weu+yUABF4BJBo7ne/t2XpIAthzscJM5uT2OQSGaE93VPvL31hOXzP4PW4cfCeZy
+8FdGJ0Lh9wWuhdLud1I+MQKBgQC7CwzEPmy38mJC8VxoMfnJlSkyDNiX+ybR/HYx
+m5buP0MXrqVXVe8KDZtPOr5ZBI7qvFzTmjzWqYcGrQJmU6DcKhcgD6qHofiyx061
+m+k6BwatlhAweAHAJFydRqPjOef9Eofu0G+48FvY4LkElVLvHDoncRuR9sTXFtwj
+H7+BMQKBgQDNWXHeXi4bYm17KsBHpK+DMT6O9cF1BqYpgbqLyro554ZjYLYpt0li
+iiekhVM55NpWlbsOfje0lhD8mr0ZYzW+SmWd/XMj03ZF9EeOBHx8SvWemsrz69Es
+wAjiQtQoZlvczaLOHLV89p9EaK3OA1trqjAkqq9GFdLBVmG/zVzSaQ==
+-----END RSA PRIVATE KEY-----