diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-01-09 15:12:18 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-01-09 15:12:18 +0000 |
| commit | d29263cab1a545b309d7cd3e9ab4f99d79c5fe7f (patch) | |
| tree | 9f202e9846987a23f4f84e8bce31e0d583579ae4 /src | |
| parent | f84c74f3b1f59b14513b6aaead2c7609dbcb97fc (diff) | |
| download | rabbitmq-server-git-d29263cab1a545b309d7cd3e9ab4f99d79c5fe7f.tar.gz | |
the #amqqueue.pid is 'none', so return self() instead
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 709e355ee0..6282a8fb6f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -488,7 +488,8 @@ i(name, #q{q = #amqqueue{name = Name}}) -> Name; i(durable, #q{q = #amqqueue{durable = Durable}}) -> Durable; i(auto_delete, #q{q = #amqqueue{auto_delete = AutoDelete}}) -> AutoDelete; i(arguments, #q{q = #amqqueue{arguments = Arguments}}) -> Arguments; -i(pid, #q{q = #amqqueue{pid = Pid}}) -> Pid; +i(pid, _) -> + self(); i(messages_ready, #q{message_buffer = MessageBuffer}) -> queue:len(MessageBuffer); i(messages_unacknowledged, _) -> |