List of basicConsume() Examples

Examples of 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)
eu.mosaic_cloud.drivers.queue.amqp.AmqpDriver.basicConsume()
Start a message consumer. @param queue the name of the queue @param consumer a client-generated consumer tag to establish context @param exclusive true if this is an exclusive consumer @param autoAck true if the server should consider messages acknowledged once delivered; false if the server should expect explicit acknowledgments @param extra @param consumeCallback the consumer callback (this will called when the queuing system will send Consume messages) @param complHandler handlers to be called when the operation finishes @return the client-generated consumer tag to establish context
org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl.basicConsume()

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

      channel.queueBind(queueName, EXCHANGE_NAME, routingKeyFromUser, headers);
    
      System.out.println(" [*] Waiting for messages. To exit press CTRL+C");


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


      while (true) {
        QueueingConsumer.Delivery delivery = consumer.nextDelivery();
        String message = new String(delivery.getBody());
        String routingKeyFromSender = delivery.getEnvelope().getRoutingKey();

View Full Code Here

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

    channel.queueBind(queueName, EXCHANGE_NAME, "");
    
    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");


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


    while (true) {
      QueueingConsumer.Delivery delivery = consumer.nextDelivery();
      String message = new String(delivery.getBody());

View Full Code Here

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

            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

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


  public void testNThreadShutdown() throws Exception{
    Channel channel = connection.createChannel();
    final QueueingConsumer c = new QueueingConsumer(channel);
    channel.queueDeclare(QUEUE, false, true, true, null);
    channel.basicConsume(QUEUE, c);
    final AtomicInteger count = new AtomicInteger(THREADS);
    final CountDownLatch latch = new CountDownLatch(THREADS);


    for(int i = 0; i < THREADS; i++){
      new Thread(){

View Full Code Here

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


            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

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


            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

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

    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

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

    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

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

                Channel ch = conn.createChannel();
                ch.queueDeclare(QUEUE_NAME, true, false, false, null);


                // Consume
                QueueingConsumer qc = new QueueingConsumer(ch);
                ch.basicConsume(QUEUE_NAME, true, qc);
                for (int i = 0; i < msgCount; ++i) {
                    qc.nextDelivery();
                }


                // Cleanup

View Full Code Here

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

        redeclare(q, chan);


        trace("Beginning plateau of " + repeatCount + " repeats, sampling every " + sampleGranularity + " messages");


        QueueingConsumer consumer = new QueueingConsumer(chan);
        chan.basicConsume(q, consumer);


        long startTime = System.currentTimeMillis();
        for (int i = 0; i < repeatCount; i++) {
            if (((i % sampleGranularity) == 0) && (i > 0)) {
                long now = System.currentTimeMillis();

View Full Code Here

0 1 2 3 4 5

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.