diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-12-14 14:25:44 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-12-14 14:25:44 +0000 |
| commit | 952e5a00af0a217bbc29b6dac1eacd42b3c625ba (patch) | |
| tree | 10091bda1c1b597e9c9d5b1507e6d1014ed49ae3 | |
| parent | 1db2d04c860e4299b0f0722488f6244f2932113a (diff) | |
| download | rabbitmq-server-952e5a00af0a217bbc29b6dac1eacd42b3c625ba.tar.gz | |
Fix accidental change
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 53f18c5b..b39f7a35 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -151,7 +151,7 @@ syncer_loop({Ref, MPid} = Args, SPidsMRefs) -> SPidsMRefs1 = wait_for_credit(SPidsMRefs, Ref), [begin credit_flow:send(SPid), - SPid ! Msg + SPid ! {sync_msg, Ref, Msg, MsgProps} end || {SPid, _} <- SPidsMRefs1], syncer_loop(Args, SPidsMRefs1); {cancel, Ref} -> |