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).