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 testUseCorrelationIdFailsWhenIdsMissing() throws Exception {
    int messageCount = 1;
    AMQP.BasicProperties publishProps = null;
    doExchangeTest(
        new ExchangeTestPlan(
            RabbitMqIO.read()
                .withExchange("CorrelationIdFailure", "fanout")
                .withUseCorrelationId(true),
            messageCount,
            messageCount,
            publishProps));
  }