extern crate amqp;
extern crate env_logger;

use amqp::{Session, Table, Basic, protocol};
use std::default::Default;
use std::io;

fn main() {
    env_logger::init().unwrap();
    let mut amqp_url = String::new();
    println!("Please input the AMQP endpoint to use: ");
    io::stdin().read_line(&mut amqp_url).ok().expect("Unable to read URL!");
    let mut session = match Session::open_url(&amqp_url[..]) {
        Ok(session) => session,
        Err(error) => panic!("Can't create session: {:?}", error)
    };
    let mut channel = session.open_channel(1).ok().expect("Can't open channel!");

    let queue_name = "test_queue";
    channel.queue_declare(queue_name, false, true, false, false, false, Table::new()).ok().expect("Unable to declare queue!");

    println!("Type some text here below, it will be sent into the '{}' queue. Hit Enter when done.", queue_name);
    let mut input_data = String::new();
    io::stdin().read_line(&mut input_data).ok().expect("Unable to read input data!");

    println!("Sending data...\n");
    channel.basic_publish("", queue_name, true, false,
        protocol::basic::BasicProperties{ content_type: Some("text".to_string()), ..Default::default()},
        input_data.trim_right().to_string().into_bytes()).unwrap();

     for get_result in channel.basic_get(queue_name, false) {
        println!("Received: {:?}", String::from_utf8_lossy(&get_result.body));
        get_result.ack();
    }

    println!("Queue is now empty, quitting...");
    channel.close(200, "Bye");
    session.close(200, "Good Bye");
}