diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-06-04 16:14:05 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-06-04 16:14:05 +0100 |
| commit | c310db59b9098ff7632c0f4ddaf736df59ef5646 (patch) | |
| tree | 68d8e3e3fee034141e424617f325fd598dcdab12 /src/rabbit.erl | |
| parent | c384ec140a7c32631f2df37d39d6ad1bf50dc020 (diff) | |
| download | rabbitmq-server-git-c310db59b9098ff7632c0f4ddaf736df59ef5646.tar.gz | |
added dump_queue to the disk queue. This spits out a list of the queue contents from the current read pointer to the end of the queue (i.e. messages for which we are waiting for acks will not be included). Of course, at startup, all the read pointers are at the start of the queue (i.e. not waiting for any acks) so this grabs everything. Some minor refactoring was involved in the addition of this function. Also, I needed to change my definition of unfold so that it's now both simultaneously an anamorphism and a catamorphism instead of just an anamorphism (i.e. the accumulator / 'initial' value is spat out at the end). This could be a hylomorphism. Can't remember...
Diffstat (limited to 'src/rabbit.erl')
0 files changed, 0 insertions, 0 deletions
