diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-08-06 12:50:57 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-08-06 12:50:57 +0100 |
| commit | 2d38695f77b8d0682c9762a5533c8ed40426b4cc (patch) | |
| tree | ce21dafef58582c4d06cb444a8ece96856d73416 /include | |
| parent | 140c28ab664aa054d9078bf91870224b0350845a (diff) | |
| parent | e65f8c9102abfd8a0b8229fa408c5d32476eb8c7 (diff) | |
| download | rabbitmq-server-git-2d38695f77b8d0682c9762a5533c8ed40426b4cc.tar.gz | |
stable to default
Diffstat (limited to 'include')
| -rw-r--r-- | include/rabbit.hrl | 27 |
1 files changed, 18 insertions, 9 deletions
diff --git a/include/rabbit.hrl b/include/rabbit.hrl index 5ac3197ed9..7a40f9ebf0 100644 --- a/include/rabbit.hrl +++ b/include/rabbit.hrl @@ -39,13 +39,25 @@ -record(resource, {virtual_host, kind, name}). --record(exchange, {name, type, durable, auto_delete, internal, arguments, - scratches, policy, decorators}). --record(exchange_serial, {name, next}). +%% fields described as 'transient' here are cleared when writing to +%% rabbit_durable_<thing> +-record(exchange, { + name, type, durable, auto_delete, internal, arguments, %% immutable + scratches, %% durable, explicitly updated via update_scratch/3 + policy, %% durable, implicitly updated when policy changes + decorators}). %% transient, recalculated in store/1 (i.e. recovery) + +-record(amqqueue, { + name, durable, auto_delete, exclusive_owner = none, %% immutable + arguments, %% immutable + pid, %% durable (just so we know home node) + slave_pids, sync_slave_pids, %% transient + down_slave_nodes, %% durable + policy, %% durable, implicit update as above + gm_pids, %% transient + decorators}). %% transient, recalculated as above --record(amqqueue, {name, durable, auto_delete, exclusive_owner = none, - arguments, pid, slave_pids, sync_slave_pids, policy, - gm_pids, decorators}). +-record(exchange_serial, {name, next}). %% mnesia doesn't like unary records, so we add a dummy 'value' field -record(route, {binding, value = const}). @@ -105,9 +117,6 @@ -define(DESIRED_HIBERNATE, 10000). -define(CREDIT_DISC_BOUND, {2000, 500}). -%% This is dictated by `erlang:send_after' on which we depend to implement TTL. --define(MAX_EXPIRY_TIMER, 4294967295). - -define(INVALID_HEADERS_KEY, <<"x-invalid-headers">>). -define(ROUTING_HEADERS, [<<"CC">>, <<"BCC">>]). -define(DELETED_HEADER, <<"BCC">>). |
