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)


        LatencyExperimentConsumer callback = new LatencyExperimentConsumer(channel, queueName);
        callback._autoAck = this._autoAck;


        channel.basicConsume(queueName, _autoAck, callback);
        channel.basicConsume(completionQueue, true, "completion", callback);
        callback.report(_writeStats);


        System.out.println("Deleting test queue.");
        channel.queueDelete(queueName);

View Full Code Here

    Channel channel = connection.createChannel();
    channel.exchangeDeclare("x", "direct");
    channel.queueDeclare("q", false, false, false, null);
    channel.queueBind("q", "x", "k");


    channel.basicConsume("q", true, new DefaultConsumer(channel){
        @Override
        public void handleDelivery(String consumerTag,
                                   Envelope envelope,
                                   AMQP.BasicProperties properties,
                                   byte[] body) {

View Full Code Here


            String queueName = ch1.queueDeclare().getQueue();
            ch1.queueBind(queueName, exchange, "#");


            QueueingConsumer consumer = new QueueingConsumer(ch1);
            ch1.basicConsume(queueName, true, consumer);
            while (true) {
                QueueingConsumer.Delivery delivery = consumer.nextDelivery();
                String routingKey = delivery.getEnvelope().getRoutingKey();
                String contentType = delivery.getProperties().getContentType();
                System.out.println("Content-type: " + contentType);

View Full Code Here

    ch.exchangeDeclare(exchange, exchangeType);
    ch.queueBind(queueName, exchange, routingKey);
      }


            QueueingConsumer consumer = new QueueingConsumer(ch);
            ch.basicConsume(queueName, consumer);
            while (true) {
                QueueingConsumer.Delivery delivery = consumer.nextDelivery();
    Map<String, Object> headers = delivery.getProperties().getHeaders();
    byte[] body = delivery.getBody();
    Object headerFilenameO = headers.get("filename");

View Full Code Here

            final Channel ch = conn.createChannel();


            ch.queueDeclare(queueName, false, false, false, null);


            QueueingConsumer consumer = new QueueingConsumer(ch);
            ch.basicConsume(queueName, consumer);
            while (true) {
                QueueingConsumer.Delivery delivery = consumer.nextDelivery();
                System.out.println("Message: " + new String(delivery.getBody()));
                ch.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
            }

View Full Code Here


            System.out.println("Listening to exchange " + exchange + ", pattern " + topicPattern +
                               " from queue " + queue);


            QueueingConsumer consumer = new QueueingConsumer(channel);
            channel.basicConsume(queue, consumer);
            while (true) {
                QueueingConsumer.Delivery delivery = consumer.nextDelivery();
                Envelope envelope = delivery.getEnvelope();
                System.out.println(envelope.getRoutingKey() + ": " + new String(delivery.getBody()));
                channel.basicAck(envelope.getDeliveryTag(), false);

View Full Code Here

        QueueingConsumer c1 = new QueueingConsumer(ch1);
        QueueingConsumer c2 = new QueueingConsumer(ch2);
        String q1 = declareBindConsume(ch1, c1, false);
        String q2 = declareBindConsume(ch2, c2, false);
        ch1.basicConsume(q2, false, c1);
        ch2.basicConsume(q1, false, c2);
        ch1.basicQos(1, true);
        ch2.basicQos(1, true);
        fill(5);
        List<Delivery> d1 = drain(c1, 1);
        List<Delivery> d2 = drain(c2, 1);

View Full Code Here

        sendTestMessage();
        Channel consumerChannel = connectionFactory.newConnection().createChannel();
        AckingConsumer consumer = new AckingConsumer();
        consumer.setChannel(consumerChannel);
        consumer.setConfiguration(new ConsumerConfiguration(TestBrokerSetup.TEST_QUEUE, true));
        consumerChannel.basicConsume(TestBrokerSetup.TEST_QUEUE, consumer);
        Thread.sleep(100);
        Assert.assertTrue(consumer.called);
        brokerAssert.queueEmtpy(TestBrokerSetup.TEST_QUEUE);
        brokerAssert.queueEmtpy(TestBrokerSetup.TEST_QUEUE_DEAD);
    }

View Full Code Here

        sendTestMessage();
        Channel consumerChannel = connectionFactory.newConnection().createChannel();
        NackingConsumer consumer = new NackingConsumer();
        consumer.setChannel(consumerChannel);
        consumer.setConfiguration(new ConsumerConfiguration(TestBrokerSetup.TEST_QUEUE, false));
        consumerChannel.basicConsume(TestBrokerSetup.TEST_QUEUE, consumer);
        Thread.sleep(100);
        Assert.assertTrue(consumer.called);
        brokerAssert.queueEmtpy(TestBrokerSetup.TEST_QUEUE);
        brokerAssert.queueNotEmtpy(TestBrokerSetup.TEST_QUEUE_DEAD);
    }

View Full Code Here

      }
      channel.queueBind(queueName, exchangeName, routingKey);


      boolean noAck = false;
      QueueingConsumer consumer = new QueueingConsumer(channel);
      channel.basicConsume(queueName, noAck, consumer);


      while (true) {
         QueueingConsumer.Delivery delivery;
         try {
            delivery = consumer.nextDelivery(mqRecvTimeoutMs);

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.