public static Read read() {
    return new AutoValue_RabbitMqIO_Read.Builder()
        .setQueueDeclare(false)
        .setExchangeDeclare(false)
        .setMaxReadTime(null)
        .setMaxNumRecords(Long.MAX_VALUE)
        .setUseCorrelationId(false)
        .build();
  }
@Test(expected = Pipeline.PipelineExecutionException.class)
  public void testQueueDeclareWithoutQueueNameFails() throws Exception {
    RabbitMqIO.Read read = RabbitMqIO.read().withQueueDeclare(true);
    doExchangeTest(new ExchangeTestPlan(read, 1));
  }