root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

break ume cycles

This commit is contained in:
Matthias Radestock 2009-05-20 19:41:53 +01:00
parent 3340a360fb
commit 2d97ee9586
1 changed files with 22 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/rabbit_exchange.erl
View File

@ -190,7 +190,10 @@ info_all(VHostPath) -> map(VHostPath, fun (X) -> info(X) end).
info_all(VHostPath, Items) -> map(VHostPath, fun (X) -> info(X, Items) end).
publish(X, Mandatory, Immediate, Txn,
publish(X, Mandatory, Immediate, Txn, Message) ->
publish(X, [], Mandatory, Immediate, Txn, Message).
publish(X, Seen, Mandatory, Immediate, Txn,
Message = #basic_message{routing_key = RK, content = C}) ->
case rabbit_router:deliver(route(X, RK, C),
Mandatory, Immediate, Txn, Message) of
@ -200,15 +203,24 @@ publish(X, Mandatory, Immediate, Txn,
undefined ->
R;
UmeName ->
case lookup(UmeName) of
{ok, Ume} ->
publish(Ume, Mandatory, Immediate, Txn, Message);
{error, not_found} ->
rabbit_log:warning(
"unroutable message exchange for ~s "
"does not exist: ~s",
[rabbit_misc:rs(XName), rabbit_misc:rs(UmeName)]),
R
NewSeen = [XName | Seen],
case lists:member(UmeName, NewSeen) of
true ->
R;
false ->
case lookup(UmeName) of
{ok, Ume} ->
publish(Ume, NewSeen,
Mandatory, Immediate, Txn,
Message);
{error, not_found} ->
rabbit_log:warning(
"unroutable message exchange for ~s "
"does not exist: ~s",
[rabbit_misc:rs(XName),
rabbit_misc:rs(UmeName)]),
R
end
end
end;
R ->