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, bindingKey);


      System.out.println(" [*] " + _consumerId + " Waiting for messages on " + bindingKey + ". 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()


      System.out.println(" [*] " + _consumerId + " Waiting for messages on " + bindingKey
          + ". 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 routingKey = delivery.getEnvelope().getRoutingKey();

View Full Code Here

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

        }
        try {
          Channel chan = connection.getConnection().createChannel();
          chan.queueDeclarePassive(amqpQueue);
          AmqpConsumer consumer = new AmqpConsumer(chan, connection.getName());
          chan.basicConsume(amqpQueue, false, consumer);
          channels.add(chan);
        } catch (Exception e) {
          logger.log(BasicLevel.ERROR,
              "Error while starting consumer on connection: " + connection.getName(), e);
        }

View Full Code Here

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


                String queueName = channel.queueDeclare().getQueue();
                channel.queueBind(queueName, AMQPUtil.EXCHANGE_NAME_TOPIC, topic.getNativeKey());


                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()


                String queueName = channel.queueDeclare().getQueue();
                channel.queueBind(queueName, AMQPUtil.EXCHANGE_NAME_FANOUT, "");


                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()


                String queueName = channel.queueDeclare().getQueue();
                channel.queueBind(queueName, AMQPUtil.EXCHANGE_NAME_DIRECT, key.getNativeKey());


                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()

            availableChannels.put(channelID, channel);
            String queueName = channel.queueDeclare().getQueue();


            BasicConsumer consumer = new
                    BasicConsumer(new JSONMessageParser(), localPublisher);          // here we use local publisher
            channel.basicConsume(queueName, true, consumer);
            String filterString = CommonUtils.getRoutingKey(monitorID.getUserName(), hostAddress);
            // here we queuebind to a particular user in a particular machine
            channel.queueBind(queueName, "glue2.computing_activity", filterString);
            logger.info("Using filtering string to monitor: " + filterString);
        } catch (IOException e) {

View Full Code Here

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

    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();
    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
    QueueingConsumer consumer = new QueueingConsumer(channel);
    channel.basicConsume(QUEUE_NAME, true, consumer);
    while (true) {
      QueueingConsumer.Delivery delivery = consumer.nextDelivery();
      String message = new String(delivery.getBody());
      System.out.println(" [x] Received '" + message + "'");
    }

View Full Code Here

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

    channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
    String queueName = channel.queueDeclare().getQueue();
    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());
      System.out.println(" [x] Received '" + message + "'");
    }

View Full Code Here

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

    for (String severity : argv) {
      channel.queueBind(queueName, EXCHANGE_NAME, severity);
    }
    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 routingKey = delivery.getEnvelope().getRoutingKey();
      System.out.println(" [x] Received '" + routingKey + "':'" + message

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.