diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-09-29 10:19:44 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-09-29 10:19:44 +0100 |
| commit | 1aaccecd4313449b0d642e436b33e2b29c68e992 (patch) | |
| tree | e7e3b0dfbc3250ea881e1ef9ae7def0d7c2eea2e /src | |
| parent | 306c4035eef6342102a879bd209f9947ff8ecc96 (diff) | |
| download | rabbitmq-server-git-1aaccecd4313449b0d642e436b33e2b29c68e992.tar.gz | |
Move #msg_status{} back to rabbit_variable_queue
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index d11aa639ed..0ef0043ede 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -264,6 +264,17 @@ -record(rates, { egress, ingress, avg_egress, avg_ingress, timestamp }). +-record(msg_status, + { seq_id, + msg_id, + msg, + is_persistent, + is_delivered, + msg_on_disk, + index_on_disk, + msg_props + }). + -record(delta, { start_seq_id, %% start_seq_id is inclusive count, @@ -283,7 +294,6 @@ -define(TRANSIENT_MSG_STORE, msg_store_transient). -include("rabbit.hrl"). --include("rabbit_backing_queue.hrl"). %%---------------------------------------------------------------------------- |