gistfile1.txt

Client.new(<some TCP or TLS stream>)
  .connect() //will start the handshake of 7 or so messages, returns a future that resolves once the handshake is done
  .and_then(|client| {
    client.create_channel() // returns a future that resolves once the channel is created
      .map(|channel| {
        channel
          .queue("queue_name") // returns a future that resolves once the queue is declared
          .and_then(|queue| {
            queue.publish(|queue| {
              queue.send(message)
            })
          })
      })
    });
      
    client.create_channel() // returns a future that resolves once the channel is created
      .map(|channel| {
        channel
          .queue("queue_name") // returns a future that resolves once the queue is declared
          .and_then(|queue| {
            queue.consume(|message| {
              //handle messages here
            })
          })
      });
  })