handle_call ({ delete_account }, _From, State) ->
amqp_channel:call(State, # 'exchange.declare' {exchange = << " delete " >>, type = << " topic " >>}),
amqp_channel:call(State, # 'queue.declare' {queue = << " delete_user " >>, durable = true }),
Binding = #'queue.bind'{exchange = << " delete " >>, routing_key = << " delete.user " >>, queue = << " delete_user " >>},
#'queue.bind_ok'{} = amqp_channel:call (State, Binding),
io:format( " [*] Waiting for logs. To exit press CTRL+C ~ n " ),
amqp_channel:subscribe(State, # 'basic.consume' {queue = << " delete_user " >>, no_ack = true }, self ()),
Returned =loop(),
io:format("~nReti=~p",[Returned]),
{reply,Returned,State};
与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…