Examples of com.rabbitmq.client.Channel.basicConsume()

com.rabbitmq.client.Channel.basicConsume()
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag. @param queue the name of the queue @param callback an interface to the consumer object @return the consumerTag generated by the server @throws java.io.IOException if an error is encountered @see com.rabbitmq.client.AMQP.Basic.Consume @see com.rabbitmq.client.AMQP.Basic.ConsumeOk @see #basicAck @see #basicConsume(String,boolean,String,boolean,boolean,Map,Consumer)

            channel.queueDeclare(queueName, false, false, true, null);


            log.info("Start receiving messages");


            QueueingConsumer consumer = new QueueingConsumer(channel);
            channel.basicConsume(queueName, true, consumer);


            int count = 0;
            while(true) {
                final QueueingConsumer.Delivery msg = consumer.nextDelivery(waitMSecNextMsg);
                if (msg == null) {

View Full Code Here

        String consumerTag;
        final Channel channel = AmqpOperationFactory.this.amqpDriver.getChannel (consumer);
        if (channel != null) {
          AmqpOperationFactory.this.amqpDriver.consumers.put (consumer, consumeCallback);
          channel.basicQos (qos);
          consumerTag = channel.basicConsume (queue, autoAck, consumer, true, exclusive, null, AmqpOperationFactory.this.amqpDriver.new ConsumerCallback ());
          if (!consumer.equals (consumerTag)) {
            AmqpOperationFactory.logger.error ("Received different consumer tag: consumerTag = " + consumerTag + " consumer " + consumer);
          }
        }
        return consumer;

View Full Code Here

        channel.exchangeDeclare(exchangeName, exchangeType);
        String queueName = channel.queueDeclare("", flags.contains("persistent"), true, false, null).getQueue();
        QueueingConsumer consumer = new QueueingConsumer(channel);
        if (prefetchCount > 0)
          channel.basicQos(prefetchCount);
        channel.basicConsume(queueName, autoAck, consumer);
        channel.queueBind(queueName, exchangeName, id);
        Thread t = new Thread(new Consumer(consumer, id, consumerTxSize, autoAck, stats, timeLimit));
        consumerThreads[i] = t;
        t.start();
      }

View Full Code Here

        Thread.sleep(100);
      }
      assertTrue("Message count = 0", n < 100);
      Channel channel = connectionFactory.createConnection().createChannel(false);
      DefaultConsumer consumer = new DefaultConsumer(channel);
      channel.basicConsume(queueName, true, consumer);
      n = 0;
      while (n++ < 100 && messageCount(rabbitAdmin, queueName) > 0) {
        Thread.sleep(100);
      }
      assertTrue("Message count > 0", n < 100);

View Full Code Here

0 1 2 3 4 5 6 7

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.