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 | c43a77640b11446be3fdc276930b771acb4f2dfc (patch) | |
| tree | e093d00636f75f50c19905f508665c33fa9d6c80 | |
| parent | 975b58762b4af83a1d87dbc0fd68d24b14869662 (diff) | |
| download | rabbitmq-server-c43a77640b11446be3fdc276930b771acb4f2dfc.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.
| -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 8f398a8e..38bbf59f 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)), |