Welcome to ShenZhenJia Knowledge Sharing Community for programmer and developer-Open, Learning and Share
menu search
person
Welcome To Ask or Share your Answers For Others

Categories

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};

与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
thumb_up_alt 0 like thumb_down_alt 0 dislike
517 views
Welcome To Ask or Share your Answers For Others

1 Answer

等待大神答复

与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
thumb_up_alt 0 like thumb_down_alt 0 dislike
Welcome to ShenZhenJia Knowledge Sharing Community for programmer and developer-Open, Learning and Share
...