diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2018-10-19 11:47:30 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2019-01-29 16:03:31 +0100 |
| commit | 1388df59de4f713f942dce4cd9f9a58bbdaec055 (patch) | |
| tree | 3747d04e043ba08e07089f95d77ceb2a3b9a33c4 /deps/rabbitmq_management_agent | |
| parent | 87705a430c264751c140b511e65f65aeb3c8af9e (diff) | |
| download | rabbitmq-server-git-1388df59de4f713f942dce4cd9f9a58bbdaec055.tar.gz | |
Make #amqqueue{} a private record
See the corresponding commit in rabbitmq-server for all the
explanations.
Now, all accesses to the #amqqueue{} record are made through the
`amqqueue` module (available in rabbitmq-server). The new type name is
`amqqueue:amqqueue()`.
The `amqqueue.hrl` header also provides some macros to help with pattern
matching and guard expressions.
[#159298729]
Diffstat (limited to 'deps/rabbitmq_management_agent')
| -rw-r--r-- | deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl b/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl index 9a553a534b..24a3a80b3f 100644 --- a/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl +++ b/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl @@ -42,6 +42,7 @@ -include_lib("rabbit_common/include/rabbit.hrl"). -include_lib("rabbit_common/include/rabbit_framing.hrl"). +-include_lib("rabbit/include/amqqueue.hrl"). %%-------------------------------------------------------------------- @@ -378,13 +379,14 @@ exchange(X) -> %% We get queues using rabbit_amqqueue:list/1 rather than :info_all/1 since %% the latter wakes up each queue. Therefore we have a record rather than a %% proplist to deal with. -queue(#amqqueue{name = Name, - durable = Durable, - auto_delete = AutoDelete, - exclusive_owner = ExclusiveOwner, - arguments = Arguments, - pid = Pid, - state = State} = Q) -> +queue(Q) when ?is_amqqueue(Q) -> + Name = amqqueue:get_name(Q), + Durable = amqqueue:is_durable(Q), + AutoDelete = amqqueue:is_auto_delete(Q), + ExclusiveOwner = amqqueue:get_exclusive_owner(Q), + Arguments = amqqueue:get_arguments(Q), + Pid = amqqueue:get_pid(Q), + State = amqqueue:get_state(Q), format( [{name, Name}, {durable, Durable}, |