diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2009-01-09 15:40:28 +0000 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2009-01-09 15:40:28 +0000 |
| commit | de6ee912350011d9fbc8a2e6788ae2634b47d770 (patch) | |
| tree | 1f475fc3e4cd3be79bd80cd0472f250c97bbc09c /src | |
| parent | 44390de962d29ececdfcf8a03430676b467c7789 (diff) | |
| parent | 58c212d3d871f4fd378846d7e2dc07b86bd50912 (diff) | |
| download | rabbitmq-server-git-de6ee912350011d9fbc8a2e6788ae2634b47d770.tar.gz | |
Merged v1_5_1 into default
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, _) -> |