diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-11-30 12:05:37 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-11-30 12:05:37 +0000 |
| commit | b0e19d5fd7803bfae1b7fe6a73d897f659f5151b (patch) | |
| tree | d1b5e110cef9cae9cb869bc42626012c348f1bb5 /src/rabbit_amqqueue.erl | |
| parent | b1eeb9af85fdd85a44d164f202c6879a74924cb6 (diff) | |
| download | rabbitmq-server-b0e19d5fd7803bfae1b7fe6a73d897f659f5151b.tar.gz | |
Exposing the publishing chpid right through to the BQ (and tidying up tests/types/specs)
Diffstat (limited to 'src/rabbit_amqqueue.erl')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index fd157231..1bbe3f1c 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -499,11 +499,12 @@ delete_queue(QueueName) -> rabbit_binding:remove_transient_for_destination(QueueName). pseudo_queue(QueueName, Pid) -> - #amqqueue{name = QueueName, - durable = false, + #amqqueue{name = QueueName, + durable = false, auto_delete = false, - arguments = [], - pid = Pid}. + arguments = [], + pid = Pid, + extra_pids = []}. safe_delegate_call_ok(F, Pids) -> {_, Bad} = delegate:invoke(Pids, |