Skip to content

Commit 8b1d4b3

Browse files
committed
fixup! fix queue destination cache
1 parent 83436f3 commit 8b1d4b3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

deps/rabbitmq_stomp/src/rabbit_stomp_processor.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1828,8 +1828,8 @@ util_ensure_endpoint(_, {queue, Name}, Params, State=#proc_state{route_state = R
18281828
vhost = VHost}) ->
18291829
Params1 = rabbit_misc:pmerge(durable, true, Params),
18301830
QueueNameBin = list_to_binary(Name),
1831-
RState1 = case sets:is_element(Params1, RoutingState) of
1832-
true -> State;
1831+
RState1 = case sets:is_element(QueueNameBin, RoutingState) of
1832+
true -> RoutingState;
18331833
_ -> Amqqueue = new_amqqueue(QueueNameBin, queue, Params1, State),
18341834
{ok, Queue} = create_queue(Amqqueue, State),
18351835
#resource{name = QNameBin} = amqqueue:get_name(Queue),

0 commit comments

Comments
 (0)