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 | 1ab002d33e0e05312d94651faaa259c576ec73c5 (patch) | |
| tree | 9f202e9846987a23f4f84e8bce31e0d583579ae4 | |
| parent | 98a812b0bc541e7ebc39908f4395f90dc4ba1f78 (diff) | |
| download | rabbitmq-server-bug20089.tar.gz | |
the #amqqueue.pid is 'none', so return self() insteadbug20089
| -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 709e355e..6282a8fb 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, _) -> |