added tests for amqp connection
begin adding amqp protocol