diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-08-31 15:51:41 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-08-31 15:51:41 +0100 |
| commit | c32bfbf56428c3a2d6b12eb252034cca113c7524 (patch) | |
| tree | e093d00636f75f50c19905f508665c33fa9d6c80 /src | |
| parent | 05d369412de0107fdb0c46c49901cd8a50c0cc9d (diff) | |
| download | rabbitmq-server-git-c32bfbf56428c3a2d6b12eb252034cca113c7524.tar.gz | |
actually, it looks like the slave might receive messages before `length'
This is not a problem, since the worse that can happen is that we have a
bogus sync state in the until `length' is received.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 8f398a8e2a..38bbf59f3c 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -133,7 +133,7 @@ init(#amqqueue { name = QueueName } = Q) -> known_senders = pmon:new(), synchronised = false, - external_pending = undefined + external_pending = 0 }, rabbit_event:notify(queue_slave_created, infos(?CREATION_EVENT_KEYS, State)), |