Skip to content

Commit fcea5f3

Browse files
committed
Remove older experimental code
1 parent 7cbf16a commit fcea5f3

10 files changed

+251
-972
lines changed

deps/rabbit/src/rabbit.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,10 +248,10 @@
248248
[]}},
249249
{requires, [core_initialized, recovery]},
250250
{enables, routing_ready}]}).
251-
-rabbit_boot_step({rabbit_cli_http_listener,
251+
-rabbit_boot_step({rabbit_cli_http_server,
252252
[{description, "RabbitMQ CLI HTTP listener"},
253253
{mfa, {rabbit_sup, start_restartable_child,
254-
[rabbit_cli_http_listener]}},
254+
[rabbit_cli_http_server]}},
255255
{requires, [core_initialized, recovery]},
256256
{enables, routing_ready}]}).
257257

deps/rabbit/src/rabbit_cli.erl

Lines changed: 0 additions & 242 deletions
This file was deleted.

deps/rabbit/src/rabbit_cli_curses.erl

Lines changed: 0 additions & 6 deletions
This file was deleted.

deps/rabbit/src/rabbit_cli_frontend.erl

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -146,13 +146,13 @@ connect_to_node(
146146
#rabbit_cli{arg_map = ArgMap, priv = Priv} = Context) ->
147147
Ret = case ArgMap of
148148
#{node := NodenameOrUri} ->
149-
rabbit_cli_transport2:connect(NodenameOrUri);
149+
rabbit_cli_transport:connect(NodenameOrUri);
150150
_ ->
151-
rabbit_cli_transport2:connect()
151+
rabbit_cli_transport:connect()
152152
end,
153153
{ClientInfo, Priv1} = case Ret of
154154
{ok, Connection} ->
155-
{rabbit_cli_transport2:get_client_info(
155+
{rabbit_cli_transport:get_client_info(
156156
Connection),
157157
Priv#?MODULE{connection = Connection}};
158158
{error, _Reason} ->
@@ -249,7 +249,7 @@ run_command(
249249
maybe
250250
process_flag(trap_exit, true),
251251
ContextMap = context_to_map(Context),
252-
{ok, Backend} ?= rabbit_cli_transport2:run_command(
252+
{ok, Backend} ?= rabbit_cli_transport:run_command(
253253
Connection, ContextMap),
254254
Priv1 = Priv#?MODULE{backend = Backend},
255255
Context1 = Context#rabbit_cli{priv = Priv1},
@@ -312,7 +312,7 @@ main_loop(
312312
end;
313313
{frontend_request, From, Request} ->
314314
{reply, Reply, Context1} = handle_request(Request, Context),
315-
_ = rabbit_cli_transport2:gen_reply(Connection, From, Reply),
315+
_ = rabbit_cli_transport:gen_reply(Connection, From, Reply),
316316
main_loop(Context1);
317317
{io_request, From, ReplyAs, Request}
318318
when element(1, Request) =:= put_chars andalso is_port(Pager) ->
@@ -334,7 +334,7 @@ main_loop(
334334
main_loop(Context);
335335
{signal, Signal} = Event ->
336336
?LOG_DEBUG("CLI: got Unix signal: ~ts", [Signal]),
337-
_ = rabbit_cli_transport2:send(Connection, Backend, Event),
337+
_ = rabbit_cli_transport:send(Connection, Backend, Event),
338338
main_loop(Context);
339339
Info ->
340340
?LOG_ALERT("CLI: unknown info: ~0p", [Info]),

0 commit comments

Comments
 (0)