diff options
Diffstat (limited to 'src/rabbit_backing_queue.erl')
| -rw-r--r-- | src/rabbit_backing_queue.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_backing_queue.erl b/src/rabbit_backing_queue.erl index 098f5f43..310b8220 100644 --- a/src/rabbit_backing_queue.erl +++ b/src/rabbit_backing_queue.erl @@ -85,6 +85,10 @@ %% content. -callback delete_and_terminate(any(), state()) -> state(). +%% Called to clean up after a crashed queue. In this case we don't +%% have a process and thus a state(), we are just removing on-disk data. +-callback delete_crashed(rabbit_amqqueue:name()) -> 'ok'. + %% Remove all 'fetchable' messages from the queue, i.e. all messages %% except those that have been fetched already and are pending acks. -callback purge(state()) -> {purged_msg_count(), state()}. |