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

Transparent temp queues

This commit is contained in:
Emile Joubert 2013-02-22 14:16:02 +00:00
parent b4c7d30330
commit 3c4cc8d053
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/rabbitmq_stomp/src/rabbit_stomp_processor.erl vendored
View File

@ -669,8 +669,8 @@ ensure_reply_to(Frame = #stomp_frame{headers = Headers}, State) ->
{Frame, State};
{ok, ReplyTo} ->
{ok, Destination} = rabbit_routing_util:parse_endpoint(ReplyTo),
case Destination of
{temp_queue, TempQueueId} ->
case rabbit_routing_util:dest_temp_queue(Destination) of
TempQueueId ->
{ReplyQueue, State1} =
ensure_reply_queue(TempQueueId, State),
{Frame#stomp_frame{
@ -678,7 +678,7 @@ ensure_reply_to(Frame = #stomp_frame{headers = Headers}, State) ->
?HEADER_REPLY_TO, 1, Headers,
{?HEADER_REPLY_TO, ReplyQueue})},
State1};
_ ->
none ->
{Frame, State}
end
end.