test() ->
    AmqpParams = #amqp_params{username = ?USERNAME, password = ?PASSWORD,
                  virtual_host = ?VIRTUAL_HOST, host = ?HOST,
                  port = ?PORT},
    Queue = <<?RESPONSE_QUEUE>>,
    Connection = amqp_connection:start_network(AmqpParams),
    Channel = amqp_connection:open_channel(Connection),

    Declare = #'queue.declare'{queue = Queue},
    #'queue.declare_ok'{} = amqp_channel:call(Channel, Declare),

    % Now poll the queue for incoming messages.
    Get = #'basic.get'{queue = Queue, no_ack = true},
    {#'basic.get_ok'{}, Content} = amqp_channel:call(Channel, Get),
    #amqp_msg{payload = Payload} = Content,
    io:format("Received from queue ~p~n", [Payload]),

    amqp_channel:close(Channel),
    amqp_connection:close(Connection).


%% And here's the outpout

Erlang R13B03 (erts-5.7.4) [source] [64-bit] [smp:2:2] [rq:2] [async-threads:0] [hipe] [kernel-poll:false]

Eshell V5.7.4  (abort with ^G)
1> amqp_test:test().
** exception error: undefined function amqp_connection:start_direct/0
     in function  amqp_test:test/0