diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-09-07 09:44:39 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-09-07 09:44:39 +0100 |
| commit | bead512b293b379732ad698bad8013d9028534fd (patch) | |
| tree | d66c537957ee0646ba2f1a097b4bf7f2ff17ce29 | |
| parent | 9b8b9efce232aaf7839fcfa3e2847f58b4b0647c (diff) | |
| download | rabbitmq-server-git-bead512b293b379732ad698bad8013d9028534fd.tar.gz | |
shut up dialyzer
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index da94d893ec..b2a03b5841 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -53,6 +53,7 @@ ). -define(TO_DISK_MAX_FLUSH_SIZE, 100000). +-define(MAGIC_MARKER, <<"$magic_marker">>). %%---------------------------------------------------------------------------- @@ -654,7 +655,8 @@ on_disk(mixed, _IsDurable, _IsPersistent) -> false. publish_magic_marker_message(Q) -> Msg = rabbit_basic:message( - none, internal, [], <<>>, rabbit_guid:guid(), true), + rabbit_misc:r(<<"/">>, exchange, <<>>), ?MAGIC_MARKER, + [], <<>>, rabbit_guid:guid(), true), ok = rabbit_disk_queue:publish(Q, ensure_binary_properties(Msg), false). fetch_ack_magic_marker_message(Q) -> @@ -664,8 +666,7 @@ fetch_ack_magic_marker_message(Q) -> {ok, Length}. is_magic_marker_message( - #basic_message { exchange_name = none, routing_key = internal, - is_persistent = true }) -> + #basic_message { routing_key = ?MAGIC_MARKER, is_persistent = true }) -> true; is_magic_marker_message(_) -> false. |