@Test(expected = IOException.class) public void failOnNonExistingQueue() throws Exception { Connection conn = new TestConnection(null, null); try (AMQPConsumer consumer = new AMQPConsumer(conn, "hello", true)) { consumer.consume(); } }
public GetResponse consume() { return responseQueue.poll(); }
AMQPConsumer extends AMQPWorker { public GetResponse consume() { return responseQueue.poll(); } }
AMQPConsumer extends AMQPWorker { public GetResponse consume() { return responseQueue.poll(); } AMQPConsumer(final Connection connection, final String queueName, final boolean autoAcknowledge); }
AMQPConsumer extends AMQPWorker { public GetResponse consume() { return responseQueue.poll(); } AMQPConsumer(final Connection connection, final String queueName, final boolean autoAcknowledge); GetResponse consume(); void acknowledge(final GetResponse response); @Override void close(); @Override String toString(); }
AMQPConsumer extends AMQPWorker { public GetResponse consume() { return responseQueue.poll(); } AMQPConsumer(final Connection connection, final String queueName, final boolean autoAcknowledge); GetResponse consume(); void acknowledge(final GetResponse response); @Override void close(); @Override String toString();  }