|
53 | 53 | * |
54 | 54 | * // Declare a queue and bind it to an exchange. |
55 | 55 | * String queueName = ch1.queueDeclare().{@link AMQP.Queue.DeclareOk#getQueue getQueue}(); |
56 | | - * ch1.{@link Channel#queueBind queueBind}(queueName, "amq.direct", queueName); |
| 56 | + * ch1.{@link Channel#queueBind queueBind}(queueName, exchangeName, queueName); |
57 | 57 | * |
58 | 58 | * // Create the QueueingConsumer and have it consume from the queue |
59 | 59 | * QueueingConsumer consumer = new {@link QueueingConsumer#QueueingConsumer QueueingConsumer}(ch1); |
60 | | - * ch1.{@link Channel#basicConsume basicConsume}(queueName, true, consumer); |
| 60 | + * ch1.{@link Channel#basicConsume basicConsume}(queueName, false, consumer); |
61 | 61 | * |
62 | 62 | * // Process deliveries |
63 | | - * while (true) { |
| 63 | + * while (/* some condition * /) { |
64 | 64 | * {@link QueueingConsumer.Delivery} delivery = consumer.{@link QueueingConsumer#nextDelivery nextDelivery}(); |
| 65 | + * ch1.{@link Channel#basicAck basicAck}(delivery.{@link QueueingConsumer.Delivery#getEnvelope getEnvelope}().{@link Envelope#getDeliveryTag getDeliveryTag}(), false); |
65 | 66 | * // process delivery |
66 | 67 | * } |
67 | 68 | * </pre> |
68 | 69 | * |
69 | | - * For a more complete example, see LogTail in the test/src/com/rabbitmq/examples |
70 | | - * directory of the source distribution. |
| 70 | + * <p>For a more detailed explanation, see <a href="http://www.rabbitmq.com/api-guide.html#consuming">the java api guide</a>.</p> |
| 71 | + * |
| 72 | + * <p>For a more complete example, see LogTail in the test/src/com/rabbitmq/examples |
| 73 | + * directory of the source distribution.</p> |
71 | 74 | */ |
72 | 75 | public class QueueingConsumer extends DefaultConsumer { |
73 | 76 | private final BlockingQueue<Delivery> _queue; |
|
0 commit comments