Skip to content

Commit 9ff53e9

Browse files
committed
Resolve conflict
1 parent a9b420b commit 9ff53e9

File tree

1 file changed

+0
-17
lines changed

1 file changed

+0
-17
lines changed

deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -85,23 +85,6 @@ declare(Q0, _Node) ->
8585
{arguments, amqqueue:get_arguments(Q0)},
8686
{user_who_performed_action, ActingUser}]),
8787
{new, Q};
88-
<<<<<<< HEAD
89-
{absent, OldQ, nodedown} ->
90-
%% This case body can be deleted once Mnesia is unsupported.
91-
OldPid = amqqueue:get_pid(OldQ),
92-
OldNode = node(OldPid),
93-
rabbit_log_queue:debug(
94-
"Overwriting record of ~s of type ~s on node ~s since "
95-
"formerly hosting node ~s seems to be down (former pid ~p)",
96-
[rabbit_misc:rs(amqqueue:get_name(Q0)), ?MODULE, node(), OldNode, OldPid]),
97-
case rabbit_amqqueue:internal_declare(Q0, true) of
98-
{created, Q} ->
99-
{new, Q};
100-
Other ->
101-
Other
102-
end;
103-
=======
104-
>>>>>>> 78b4fcc899 (Allow MQTT QoS 0 subscribers to reconnect)
10588
Other ->
10689
Other
10790
end.

0 commit comments

Comments
 (0)