diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2013-03-25 13:08:15 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2013-03-25 13:08:15 +0000 |
| commit | 0dbe4e89faff2869ce29db3b2305e15d20a0ac1b (patch) | |
| tree | b03f17a9583212b6facf5acff939ee7b2b03d1ee | |
| parent | c264931b22021db0697e5ec35f0d733ca6ee8ed5 (diff) | |
| download | rabbitmq-server-bug25500.tar.gz | |
Queue copy testbug25500
| -rw-r--r-- | src/rabbit_tests.erl | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 1188c554..baa52356 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -63,6 +63,7 @@ all_tests() -> passed = test_server_status(), passed = test_amqp_connection_refusal(), passed = test_confirms(), + passed = test_queue_copy(), passed = do_if_secondary_node( fun run_cluster_dependent_tests/1, @@ -1302,6 +1303,24 @@ test_confirms() -> passed. +test_queue_copy() -> + {new, #amqqueue { name = QName1 } = Q1} = + rabbit_amqqueue:declare(queue_name(<<"test1">>), false, false, [], none), + {new, #amqqueue { name = QName2 } = Q2} = + rabbit_amqqueue:declare(queue_name(<<"test2">>), false, false, [], none), + Payload = "queue copy test payload", + publish_and_confirm(Q1, erlang:term_to_binary(Payload), 1), + rabbit_amqqueue:copy(Q1, QName2), + {ok, 0, {QName1, _Pid1, undefined, false, Msg1}} = + rabbit_amqqueue:basic_get(Q1, self(), true), + {ok, 0, {QName2, _Pid2, undefined, false, Msg2}} = + rabbit_amqqueue:basic_get(Q2, self(), true), + Payload = msg2int(Msg1), + Payload = msg2int(Msg2), + rabbit_amqqueue:delete(Q1, false, false), + rabbit_amqqueue:delete(Q2, false, false), + passed. + test_statistics_event_receiver(Pid) -> receive Foo -> Pid ! Foo, test_statistics_event_receiver(Pid) |