3 provider_class = Puppet::Type.type(:rabbitmq_exchange).provider(:rabbitmqadmin)
4 describe provider_class do
6 Puppet::Type::Rabbitmq_exchange.new(
7 name: 'test.headers@/',
13 'hash-headers' => 'message-distribution-hash'
17 let(:provider) { provider_class.new(resource) }
19 it 'returns instances' do
20 provider_class.expects(:rabbitmqctl).with('-q', 'list_vhosts').returns <<-EOT
23 provider_class.expects(:rabbitmqctl).with('-q', 'list_exchanges', '-p', '/', 'name', 'type', 'internal', 'durable', 'auto_delete', 'arguments').returns <<-EOT
24 direct false true false []
25 amq.direct direct false true false []
26 amq.fanout fanout false true false []
27 amq.headers headers false true false []
28 amq.match headers false true false []
29 amq.rabbitmq.log topic true true false []
30 amq.rabbitmq.trace topic true true false []
31 amq.topic topic false true false []
32 test.headers x-consistent-hash false true false [{"hash-header","message-distribution-hash"}]
34 instances = provider_class.instances
35 expect(instances.size).to eq(9)
38 it 'calls rabbitmqadmin to create as guest' do
39 provider.expects(:rabbitmqadmin).with('declare', 'exchange', '--vhost=/', '--user=guest', '--password=guest', 'name=test.headers', 'type=headers', 'internal=false', 'durable=true', 'auto_delete=false', 'arguments={"hash-headers":"message-distribution-hash"}', '-c', '/etc/rabbitmq/rabbitmqadmin.conf')
43 it 'calls rabbitmqadmin to destroy' do
44 provider.expects(:rabbitmqadmin).with('delete', 'exchange', '--vhost=/', '--user=guest', '--password=guest', 'name=test.headers', '-c', '/etc/rabbitmq/rabbitmqadmin.conf')
48 context 'specifying credentials' do
50 Puppet::Type::Rabbitmq_exchange.new(
51 name: 'test.headers@/',
59 'hash-header' => 'message-distribution-hash'
63 let(:provider) { provider_class.new(resource) }
65 it 'calls rabbitmqadmin to create with credentials' do
66 provider.expects(:rabbitmqadmin).with('declare', 'exchange', '--vhost=/', '--user=colin', '--password=secret', 'name=test.headers', 'type=headers', 'internal=false', 'durable=true', 'auto_delete=false', 'arguments={"hash-header":"message-distribution-hash"}', '-c', '/etc/rabbitmq/rabbitmqadmin.conf')