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 | 134fbbc3b618a628d1323eaad618c0b84862df3a (patch) | |
| tree | 10091bda1c1b597e9c9d5b1507e6d1014ed49ae3 | |
| parent | 8b1fafcca7fe80084f12b4740366c850e748de79 (diff) | |
| download | rabbitmq-server-git-134fbbc3b618a628d1323eaad618c0b84862df3a.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 53f18c5b30..b39f7a35dd 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} -> |